/* * Nextcloud Talk application * * @author Mario Danic * Copyright (C) 2017-2018 Mario Danic * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ package com.nextcloud.talk.controllers import android.annotation.SuppressLint import android.content.Context import android.graphics.drawable.Drawable import android.graphics.drawable.LayerDrawable import android.os.Bundle import android.text.TextUtils import android.util.Log import android.view.LayoutInflater import android.view.MenuItem import android.view.View import android.view.ViewGroup import android.widget.ProgressBar import androidx.appcompat.widget.SwitchCompat import androidx.emoji.widget.EmojiTextView import androidx.recyclerview.widget.RecyclerView import androidx.work.Data import androidx.work.OneTimeWorkRequest import androidx.work.WorkManager import autodagger.AutoInjector import butterknife.BindView import butterknife.OnClick import com.afollestad.materialdialogs.LayoutMode.WRAP_CONTENT import com.afollestad.materialdialogs.MaterialDialog import com.afollestad.materialdialogs.bottomsheets.BottomSheet import com.afollestad.materialdialogs.datetime.dateTimePicker import com.bluelinelabs.conductor.RouterTransaction import com.bluelinelabs.conductor.changehandler.HorizontalChangeHandler import com.facebook.drawee.backends.pipeline.Fresco import com.facebook.drawee.view.SimpleDraweeView import com.nextcloud.talk.R import com.nextcloud.talk.adapters.items.UserItem import com.nextcloud.talk.api.NcApi import com.nextcloud.talk.application.NextcloudTalkApplication import com.nextcloud.talk.controllers.base.BaseController import com.nextcloud.talk.controllers.bottomsheet.items.BasicListItemWithImage import com.nextcloud.talk.controllers.bottomsheet.items.listItemsWithImage import com.nextcloud.talk.events.EventStatus import com.nextcloud.talk.jobs.DeleteConversationWorker import com.nextcloud.talk.jobs.LeaveConversationWorker import com.nextcloud.talk.models.database.UserEntity import com.nextcloud.talk.models.json.conversations.Conversation import com.nextcloud.talk.models.json.conversations.RoomOverall import com.nextcloud.talk.models.json.converters.EnumNotificationLevelConverter import com.nextcloud.talk.models.json.generic.GenericOverall import com.nextcloud.talk.models.json.participants.Participant import com.nextcloud.talk.models.json.participants.Participant.ActorType.GROUPS import com.nextcloud.talk.models.json.participants.Participant.ActorType.USERS import com.nextcloud.talk.models.json.participants.ParticipantsOverall import com.nextcloud.talk.utils.ApiUtils import com.nextcloud.talk.utils.DateUtils import com.nextcloud.talk.utils.DisplayUtils import com.nextcloud.talk.utils.bundle.BundleKeys import com.nextcloud.talk.utils.preferences.preferencestorage.DatabaseStorageModule import com.yarolegovich.lovelydialog.LovelySaveStateHandler import com.yarolegovich.lovelydialog.LovelyStandardDialog import com.yarolegovich.mp.MaterialChoicePreference import com.yarolegovich.mp.MaterialPreferenceCategory import com.yarolegovich.mp.MaterialPreferenceScreen import com.yarolegovich.mp.MaterialStandardPreference import com.yarolegovich.mp.MaterialSwitchPreference import eu.davidea.flexibleadapter.FlexibleAdapter import eu.davidea.flexibleadapter.common.SmoothScrollLinearLayoutManager import io.reactivex.Observer import io.reactivex.android.schedulers.AndroidSchedulers import io.reactivex.disposables.Disposable import io.reactivex.schedulers.Schedulers import org.greenrobot.eventbus.EventBus import org.greenrobot.eventbus.Subscribe import org.greenrobot.eventbus.ThreadMode import java.util.Calendar import java.util.Collections import java.util.Comparator import java.util.Locale import javax.inject.Inject @AutoInjector(NextcloudTalkApplication::class) class ConversationInfoController(args: Bundle) : BaseController(args), FlexibleAdapter.OnItemClickListener { @BindView(R.id.notification_settings) lateinit var notificationsPreferenceScreen: MaterialPreferenceScreen @BindView(R.id.progressBar) lateinit var progressBar: ProgressBar @BindView(R.id.conversation_info_message_notifications) lateinit var messageNotificationLevel: MaterialChoicePreference @BindView(R.id.webinar_settings) lateinit var conversationInfoWebinar: MaterialPreferenceScreen @BindView(R.id.conversation_info_lobby) lateinit var conversationInfoLobby: MaterialSwitchPreference @BindView(R.id.conversation_info_name) lateinit var nameCategoryView: MaterialPreferenceCategory @BindView(R.id.start_time_preferences) lateinit var startTimeView: MaterialStandardPreference @BindView(R.id.avatar_image) lateinit var conversationAvatarImageView: SimpleDraweeView @BindView(R.id.display_name_text) lateinit var conversationDisplayName: EmojiTextView @BindView(R.id.conversation_description) lateinit var descriptionCategoryView: MaterialPreferenceCategory @BindView(R.id.description_text) lateinit var conversationDescription: EmojiTextView @BindView(R.id.participants_list_category) lateinit var participantsListCategory: MaterialPreferenceCategory @BindView(R.id.addParticipantsAction) lateinit var addParticipantsAction: MaterialStandardPreference @BindView(R.id.recycler_view) lateinit var recyclerView: RecyclerView @BindView(R.id.deleteConversationAction) lateinit var deleteConversationAction: MaterialStandardPreference @BindView(R.id.leaveConversationAction) lateinit var leaveConversationAction: MaterialStandardPreference @BindView(R.id.ownOptions) lateinit var ownOptionsCategory: MaterialPreferenceCategory @BindView(R.id.muteCalls) lateinit var muteCalls: MaterialSwitchPreference @set:Inject lateinit var ncApi: NcApi @set:Inject lateinit var context: Context @set:Inject lateinit var eventBus: EventBus private val conversationToken: String? private val conversationUser: UserEntity? private val hasAvatarSpacing: Boolean private val credentials: String? private var roomDisposable: Disposable? = null private var participantsDisposable: Disposable? = null private var databaseStorageModule: DatabaseStorageModule? = null private var conversation: Conversation? = null private var adapter: FlexibleAdapter? = null private var recyclerViewItems: MutableList = ArrayList() private var saveStateHandler: LovelySaveStateHandler? = null private val workerData: Data? get() { if (!TextUtils.isEmpty(conversationToken) && conversationUser != null) { val data = Data.Builder() data.putString(BundleKeys.KEY_ROOM_TOKEN, conversationToken) data.putLong(BundleKeys.KEY_INTERNAL_USER_ID, conversationUser.id) return data.build() } return null } init { setHasOptionsMenu(true) NextcloudTalkApplication.sharedApplication?.componentApplication?.inject(this) conversationUser = args.getParcelable(BundleKeys.KEY_USER_ENTITY) conversationToken = args.getString(BundleKeys.KEY_ROOM_TOKEN) hasAvatarSpacing = args.getBoolean(BundleKeys.KEY_ROOM_ONE_TO_ONE, false) credentials = ApiUtils.getCredentials(conversationUser!!.username, conversationUser.token) } override fun onOptionsItemSelected(item: MenuItem): Boolean { when (item.itemId) { android.R.id.home -> { router.popCurrentController() return true } else -> return super.onOptionsItemSelected(item) } } override fun inflateView(inflater: LayoutInflater, container: ViewGroup): View { return inflater.inflate(R.layout.controller_conversation_info, container, false) } override fun onAttach(view: View) { super.onAttach(view) eventBus.register(this) if (databaseStorageModule == null) { databaseStorageModule = DatabaseStorageModule(conversationUser!!, conversationToken) } notificationsPreferenceScreen.setStorageModule(databaseStorageModule) conversationInfoWebinar.setStorageModule(databaseStorageModule) fetchRoomInfo() } override fun onViewBound(view: View) { super.onViewBound(view) if (saveStateHandler == null) { saveStateHandler = LovelySaveStateHandler() } addParticipantsAction.visibility = View.GONE } private fun setupWebinaryView() { if (conversationUser!!.hasSpreedFeatureCapability("webinary-lobby") && ( conversation!!.type == Conversation.ConversationType.ROOM_GROUP_CALL || conversation!!.type == Conversation.ConversationType.ROOM_PUBLIC_CALL ) && conversation!!.canModerate(conversationUser) ) { conversationInfoWebinar.visibility = View.VISIBLE val isLobbyOpenToModeratorsOnly = conversation!!.lobbyState == Conversation.LobbyState.LOBBY_STATE_MODERATORS_ONLY (conversationInfoLobby.findViewById(R.id.mp_checkable) as SwitchCompat) .isChecked = isLobbyOpenToModeratorsOnly reconfigureLobbyTimerView() startTimeView.setOnClickListener { MaterialDialog(activity!!, BottomSheet(WRAP_CONTENT)).show { val currentTimeCalendar = Calendar.getInstance() if (conversation!!.lobbyTimer != null && conversation!!.lobbyTimer != 0L) { currentTimeCalendar.timeInMillis = conversation!!.lobbyTimer * 1000 } dateTimePicker( minDateTime = Calendar.getInstance(), requireFutureDateTime = true, currentDateTime = currentTimeCalendar, show24HoursView = true, dateTimeCallback = { _, dateTime -> reconfigureLobbyTimerView(dateTime) submitLobbyChanges() } ) } } (conversationInfoLobby.findViewById(R.id.mp_checkable) as SwitchCompat).setOnCheckedChangeListener { _, _ -> reconfigureLobbyTimerView() submitLobbyChanges() } } else { conversationInfoWebinar.visibility = View.GONE } } fun reconfigureLobbyTimerView(dateTime: Calendar? = null) { val isChecked = (conversationInfoLobby.findViewById(R.id.mp_checkable) as SwitchCompat).isChecked if (dateTime != null && isChecked) { conversation!!.lobbyTimer = (dateTime.timeInMillis - (dateTime.time.seconds * 1000)) / 1000 } else if (!isChecked) { conversation!!.lobbyTimer = 0 } conversation!!.lobbyState = if (isChecked) Conversation.LobbyState .LOBBY_STATE_MODERATORS_ONLY else Conversation.LobbyState.LOBBY_STATE_ALL_PARTICIPANTS if (conversation!!.lobbyTimer != null && conversation!!.lobbyTimer != java.lang.Long.MIN_VALUE && conversation!!.lobbyTimer != 0L) { startTimeView.setSummary(DateUtils.getLocalDateStringFromTimestampForLobby(conversation!!.lobbyTimer)) } else { startTimeView.setSummary(R.string.nc_manual) } if (isChecked) { startTimeView.visibility = View.VISIBLE } else { startTimeView.visibility = View.GONE } } fun submitLobbyChanges() { val state = if ( ( conversationInfoLobby.findViewById( R.id.mp_checkable ) as SwitchCompat ).isChecked ) 1 else 0 val apiVersion = ApiUtils.getConversationApiVersion(conversationUser, intArrayOf(ApiUtils.APIv4, 1)) ncApi.setLobbyForConversation( ApiUtils.getCredentials(conversationUser!!.username, conversationUser.token), ApiUtils.getUrlForRoomWebinaryLobby(apiVersion, conversationUser.baseUrl, conversation!!.token), state, conversation!!.lobbyTimer ) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(object : Observer { override fun onComplete() { } override fun onSubscribe(d: Disposable) { } override fun onNext(t: GenericOverall) { } override fun onError(e: Throwable) { } }) } private fun showLovelyDialog(dialogId: Int, savedInstanceState: Bundle) { when (dialogId) { ID_DELETE_CONVERSATION_DIALOG -> showDeleteConversationDialog(savedInstanceState) else -> { } } } @Subscribe(threadMode = ThreadMode.MAIN) fun onMessageEvent(eventStatus: EventStatus) { getListOfParticipants() } override fun onDetach(view: View) { super.onDetach(view) eventBus.unregister(this) } private fun showDeleteConversationDialog(savedInstanceState: Bundle?) { if (activity != null) { LovelyStandardDialog(activity, LovelyStandardDialog.ButtonLayout.HORIZONTAL) .setTopColorRes(R.color.nc_darkRed) .setIcon( DisplayUtils.getTintedDrawable( context!!.resources, R.drawable.ic_delete_black_24dp, R.color.bg_default ) ) .setPositiveButtonColor(context!!.resources.getColor(R.color.nc_darkRed)) .setTitle(R.string.nc_delete_call) .setMessage(R.string.nc_delete_conversation_more) .setPositiveButton(R.string.nc_delete) { deleteConversation() } .setNegativeButton(R.string.nc_cancel, null) .setInstanceStateHandler(ID_DELETE_CONVERSATION_DIALOG, saveStateHandler!!) .setSavedInstanceState(savedInstanceState) .show() } } override fun onSaveViewState(view: View, outState: Bundle) { saveStateHandler!!.saveInstanceState(outState) super.onSaveViewState(view, outState) } override fun onRestoreViewState(view: View, savedViewState: Bundle) { super.onRestoreViewState(view, savedViewState) if (LovelySaveStateHandler.wasDialogOnScreen(savedViewState)) { // Dialog won't be restarted automatically, so we need to call this method. // Each dialog knows how to restore its state showLovelyDialog(LovelySaveStateHandler.getSavedDialogId(savedViewState), savedViewState) } } private fun setupAdapter() { if (activity != null) { if (adapter == null) { adapter = FlexibleAdapter(recyclerViewItems, activity, true) } val layoutManager = SmoothScrollLinearLayoutManager(activity) recyclerView.layoutManager = layoutManager recyclerView.setHasFixedSize(true) recyclerView.adapter = adapter adapter!!.addListener(this) } } private fun handleParticipants(participants: List) { var userItem: UserItem var participant: Participant recyclerViewItems = ArrayList() var ownUserItem: UserItem? = null for (i in participants.indices) { participant = participants[i] userItem = UserItem(participant, conversationUser, null) if (participant.sessionId != null) { userItem.isOnline = !participant.sessionId.equals("0") } else { userItem.isOnline = !participant.sessionIds!!.isEmpty() } if (participant.getActorType() == USERS && participant.getActorId() == conversationUser!!.userId) { ownUserItem = userItem ownUserItem.model.sessionId = "-1" ownUserItem.isOnline = true } else { recyclerViewItems.add(userItem) } } Collections.sort(recyclerViewItems, UserItemComparator()) if (ownUserItem != null) { recyclerViewItems.add(0, ownUserItem) } setupAdapter() participantsListCategory.visibility = View.VISIBLE adapter!!.updateDataSet(recyclerViewItems) } override fun getTitle(): String? { return if (hasAvatarSpacing) { " " + resources!!.getString(R.string.nc_conversation_menu_conversation_info) } else { resources!!.getString(R.string.nc_conversation_menu_conversation_info) } } private fun getListOfParticipants() { var apiVersion = 1 // FIXME Fix API checking with guests? if (conversationUser != null) { apiVersion = ApiUtils.getConversationApiVersion(conversationUser, intArrayOf(ApiUtils.APIv4, 1)) } ncApi.getPeersForCall( credentials, ApiUtils.getUrlForParticipants(apiVersion, conversationUser!!.baseUrl, conversationToken) ) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(object : Observer { override fun onSubscribe(d: Disposable) { participantsDisposable = d } override fun onNext(participantsOverall: ParticipantsOverall) { handleParticipants(participantsOverall.ocs.data) } override fun onError(e: Throwable) { } override fun onComplete() { participantsDisposable!!.dispose() } }) } @OnClick(R.id.addParticipantsAction) internal fun addParticipants() { val bundle = Bundle() val existingParticipantsId = arrayListOf() for (userItem in recyclerViewItems) { if (userItem.model.getActorType() == USERS) { existingParticipantsId.add(userItem.model.getActorId()) } } bundle.putBoolean(BundleKeys.KEY_ADD_PARTICIPANTS, true) bundle.putStringArrayList(BundleKeys.KEY_EXISTING_PARTICIPANTS, existingParticipantsId) bundle.putString(BundleKeys.KEY_TOKEN, conversation!!.token) getRouter().pushController( ( RouterTransaction.with( ContactsController(bundle) ) .pushChangeHandler( HorizontalChangeHandler() ) .popChangeHandler( HorizontalChangeHandler() ) ) ) } @OnClick(R.id.leaveConversationAction) internal fun leaveConversation() { workerData?.let { WorkManager.getInstance().enqueue( OneTimeWorkRequest.Builder( LeaveConversationWorker::class .java ).setInputData(it).build() ) popTwoLastControllers() } } private fun deleteConversation() { workerData?.let { WorkManager.getInstance().enqueue( OneTimeWorkRequest.Builder( DeleteConversationWorker::class.java ).setInputData(it).build() ) popTwoLastControllers() } } @OnClick(R.id.deleteConversationAction) internal fun deleteConversationClick() { showDeleteConversationDialog(null) } private fun popTwoLastControllers() { var backstack = router.backstack backstack = backstack.subList(0, backstack.size - 2) router.setBackstack(backstack, HorizontalChangeHandler()) } private fun fetchRoomInfo() { var apiVersion = 1 // FIXME Fix API checking with guests? if (conversationUser != null) { apiVersion = ApiUtils.getConversationApiVersion(conversationUser, intArrayOf(ApiUtils.APIv4, 1)) } ncApi.getRoom(credentials, ApiUtils.getUrlForRoom(apiVersion, conversationUser!!.baseUrl, conversationToken)) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(object : Observer { override fun onSubscribe(d: Disposable) { roomDisposable = d } override fun onNext(roomOverall: RoomOverall) { conversation = roomOverall.ocs.data val conversationCopy = conversation if (conversationCopy!!.canModerate(conversationUser)) { addParticipantsAction.visibility = View.VISIBLE } else { addParticipantsAction.visibility = View.GONE } if (isAttached && (!isBeingDestroyed || !isDestroyed)) { ownOptionsCategory.visibility = View.VISIBLE setupWebinaryView() if (!conversation!!.canLeave(conversationUser)) { leaveConversationAction.visibility = View.GONE } else { leaveConversationAction.visibility = View.VISIBLE } if (!conversation!!.canDelete(conversationUser)) { deleteConversationAction.visibility = View.GONE } else { deleteConversationAction.visibility = View.VISIBLE } if (Conversation.ConversationType.ROOM_SYSTEM == conversation!!.type) { muteCalls.visibility = View.GONE } getListOfParticipants() progressBar.visibility = View.GONE nameCategoryView.visibility = View.VISIBLE conversationDisplayName.text = conversation!!.displayName if (conversation!!.description != null && !conversation!!.description.isEmpty()) { conversationDescription.text = conversation!!.description descriptionCategoryView.visibility = View.VISIBLE } loadConversationAvatar() adjustNotificationLevelUI() notificationsPreferenceScreen.visibility = View.VISIBLE } } override fun onError(e: Throwable) { } override fun onComplete() { roomDisposable!!.dispose() } }) } private fun adjustNotificationLevelUI() { if (conversation != null) { if (conversationUser != null && conversationUser.hasSpreedFeatureCapability("notification-levels")) { messageNotificationLevel.isEnabled = true messageNotificationLevel.alpha = 1.0f if (conversation!!.notificationLevel != Conversation.NotificationLevel.DEFAULT) { val stringValue: String = when (EnumNotificationLevelConverter().convertToInt(conversation!!.notificationLevel)) { 1 -> "always" 2 -> "mention" 3 -> "never" else -> "mention" } messageNotificationLevel.value = stringValue } else { setProperNotificationValue(conversation) } } else { messageNotificationLevel.isEnabled = false messageNotificationLevel.alpha = 0.38f setProperNotificationValue(conversation) } } } private fun setProperNotificationValue(conversation: Conversation?) { if (conversation!!.type == Conversation.ConversationType.ROOM_TYPE_ONE_TO_ONE_CALL) { // hack to see if we get mentioned always or just on mention if (conversationUser!!.hasSpreedFeatureCapability("mention-flag")) { messageNotificationLevel.value = "always" } else { messageNotificationLevel.value = "mention" } } else { messageNotificationLevel.value = "mention" } } private fun loadConversationAvatar() { when (conversation!!.type) { Conversation.ConversationType.ROOM_TYPE_ONE_TO_ONE_CALL -> if ( !TextUtils.isEmpty(conversation!!.name) ) { val draweeController = Fresco.newDraweeControllerBuilder() .setOldController(conversationAvatarImageView.controller) .setAutoPlayAnimations(true) .setImageRequest( DisplayUtils.getImageRequestForUrl( ApiUtils.getUrlForAvatarWithName( conversationUser!!.baseUrl, conversation!!.name, R.dimen.avatar_size_big ), conversationUser ) ) .build() conversationAvatarImageView.controller = draweeController } Conversation.ConversationType.ROOM_GROUP_CALL -> conversationAvatarImageView.hierarchy.setPlaceholderImage( R.drawable.ic_circular_group ) Conversation.ConversationType.ROOM_PUBLIC_CALL -> conversationAvatarImageView.hierarchy.setPlaceholderImage( R.drawable.ic_circular_link ) Conversation.ConversationType.ROOM_SYSTEM -> { val layers = arrayOfNulls(2) layers[0] = context.getDrawable(R.drawable.ic_launcher_background) layers[1] = context.getDrawable(R.drawable.ic_launcher_foreground) val layerDrawable = LayerDrawable(layers) conversationAvatarImageView.hierarchy.setPlaceholderImage(DisplayUtils.getRoundedDrawable(layerDrawable)) } else -> { } } } private fun toggleModeratorStatus(apiVersion: Int, participant: Participant) { val subscriber = object : Observer { override fun onSubscribe(d: Disposable) { } override fun onNext(genericOverall: GenericOverall) { getListOfParticipants() } @SuppressLint("LongLogTag") override fun onError(e: Throwable) { Log.e(TAG, "Error toggling moderator status", e) } override fun onComplete() { } } if (participant.type == Participant.ParticipantType.MODERATOR || participant.type == Participant.ParticipantType.GUEST_MODERATOR ) { ncApi.demoteAttendeeFromModerator( credentials, ApiUtils.getUrlForRoomModerators( apiVersion, conversationUser!!.baseUrl, conversation!!.token ), participant.attendeeId ) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(subscriber) } else if (participant.type == Participant.ParticipantType.USER || participant.type == Participant.ParticipantType.GUEST ) { ncApi.promoteAttendeeToModerator( credentials, ApiUtils.getUrlForRoomModerators( apiVersion, conversationUser!!.baseUrl, conversation!!.token ), participant.attendeeId ) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(subscriber) } } private fun toggleModeratorStatusLegacy(apiVersion: Int, participant: Participant) { val subscriber = object : Observer { override fun onSubscribe(d: Disposable) { } override fun onNext(genericOverall: GenericOverall) { getListOfParticipants() } @SuppressLint("LongLogTag") override fun onError(e: Throwable) { Log.e(TAG, "Error toggling moderator status", e) } override fun onComplete() { } } if (participant.type == Participant.ParticipantType.MODERATOR) { ncApi.demoteModeratorToUser( credentials, ApiUtils.getUrlForRoomModerators( apiVersion, conversationUser!!.baseUrl, conversation!!.token ), participant.userId ) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(subscriber) } else if (participant.type == Participant.ParticipantType.USER) { ncApi.promoteUserToModerator( credentials, ApiUtils.getUrlForRoomModerators( apiVersion, conversationUser!!.baseUrl, conversation!!.token ), participant.userId ) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(subscriber) } } fun removeAttendeeFromConversation(apiVersion: Int, participant: Participant) { if (apiVersion >= ApiUtils.APIv4) { ncApi.removeAttendeeFromConversation( credentials, ApiUtils.getUrlForAttendees( apiVersion, conversationUser!!.baseUrl, conversation!!.token ), participant.attendeeId ) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(object : Observer { override fun onSubscribe(d: Disposable) { } override fun onNext(genericOverall: GenericOverall) { getListOfParticipants() } @SuppressLint("LongLogTag") override fun onError(e: Throwable) { Log.e(TAG, "Error removing attendee from conversation", e) } override fun onComplete() { } }) } else { if (participant.type == Participant.ParticipantType.GUEST || participant.type == Participant.ParticipantType.USER_FOLLOWING_LINK ) { ncApi.removeParticipantFromConversation( credentials, ApiUtils.getUrlForRemovingParticipantFromConversation( conversationUser!!.baseUrl, conversation!!.token, true ), participant.sessionId ) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(object : Observer { override fun onSubscribe(d: Disposable) { } override fun onNext(genericOverall: GenericOverall) { getListOfParticipants() } @SuppressLint("LongLogTag") override fun onError(e: Throwable) { Log.e(TAG, "Error removing guest from conversation", e) } override fun onComplete() { } }) } else { ncApi.removeParticipantFromConversation( credentials, ApiUtils.getUrlForRemovingParticipantFromConversation( conversationUser!!.baseUrl, conversation!!.token, false ), participant.userId ) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(object : Observer { override fun onSubscribe(d: Disposable) { } override fun onNext(genericOverall: GenericOverall) { getListOfParticipants() } @SuppressLint("LongLogTag") override fun onError(e: Throwable) { Log.e(TAG, "Error removing user from conversation", e) } override fun onComplete() { } }) } } } override fun onItemClick(view: View?, position: Int): Boolean { if (!conversation!!.canModerate(conversationUser)) { return true } val userItem = adapter?.getItem(position) as UserItem val participant = userItem.model val apiVersion = ApiUtils.getConversationApiVersion(conversationUser, intArrayOf(ApiUtils.APIv4, 1)) if (participant.getActorType() == USERS && participant.getActorId() == conversationUser!!.userId) { if (participant.attendeePin.isNotEmpty()) { val items = mutableListOf( BasicListItemWithImage( R.drawable.ic_lock_grey600_24px, context.getString(R.string.nc_attendee_pin, participant.attendeePin) ) ) MaterialDialog(activity!!, BottomSheet(WRAP_CONTENT)).show { cornerRadius(res = R.dimen.corner_radius) title(text = participant.displayName) listItemsWithImage(items = items) { dialog, index, _ -> if (index == 0) { removeAttendeeFromConversation(apiVersion, participant) } } } } return true } if (participant.type == Participant.ParticipantType.OWNER) { // Can not moderate owner return true } if (participant.getActorType() == GROUPS) { val items = mutableListOf( BasicListItemWithImage( R.drawable.ic_delete_grey600_24dp, context.getString(R.string.nc_remove_group_and_members) ) ) MaterialDialog(activity!!, BottomSheet(WRAP_CONTENT)).show { cornerRadius(res = R.dimen.corner_radius) title(text = participant.displayName) listItemsWithImage(items = items) { dialog, index, _ -> if (index == 0) { removeAttendeeFromConversation(apiVersion, participant) } } } return true } var items = mutableListOf( BasicListItemWithImage( R.drawable.ic_lock_grey600_24px, context.getString(R.string.nc_attendee_pin, participant.attendeePin) ), BasicListItemWithImage(R.drawable.ic_pencil_grey600_24dp, context.getString(R.string.nc_promote)), BasicListItemWithImage(R.drawable.ic_pencil_grey600_24dp, context.getString(R.string.nc_demote)), BasicListItemWithImage( R.drawable.ic_delete_grey600_24dp, context.getString(R.string.nc_remove_participant) ) ) if (participant.type == Participant.ParticipantType.MODERATOR || participant.type == Participant.ParticipantType.GUEST_MODERATOR ) { items.removeAt(1) } else if (participant.type == Participant.ParticipantType.USER || participant.type == Participant.ParticipantType.GUEST ) { items.removeAt(2) } else { // Self joined users can not be promoted nor demoted items.removeAt(2) items.removeAt(1) } if (participant.attendeePin.isEmpty()) { items.removeAt(0) } if (items.isNotEmpty()) { MaterialDialog(activity!!, BottomSheet(WRAP_CONTENT)).show { cornerRadius(res = R.dimen.corner_radius) title(text = participant.displayName) listItemsWithImage(items = items) { dialog, index, _ -> var actionToTrigger = index if (participant.attendeePin.isEmpty()) { actionToTrigger++ } if (participant.type == Participant.ParticipantType.USER_FOLLOWING_LINK) { actionToTrigger++ } if (actionToTrigger == 0) { // Pin, nothing to do } else if (actionToTrigger == 1) { // Promote/demote if (apiVersion >= ApiUtils.APIv4) { toggleModeratorStatus(apiVersion, participant) } else { toggleModeratorStatusLegacy(apiVersion, participant) } } else if (actionToTrigger == 2) { // Remove from conversation removeAttendeeFromConversation(apiVersion, participant) } } } } return true } companion object { private const val TAG = "ConversationInfoController" private const val ID_DELETE_CONVERSATION_DIALOG = 0 } /** * Comparator for participants, sorts by online-status, moderator-status and display name. */ class UserItemComparator : Comparator { override fun compare(left: UserItem, right: UserItem): Int { val leftIsGroup = left.model.actorType == GROUPS val rightIsGroup = right.model.actorType == GROUPS if (leftIsGroup != rightIsGroup) { // Groups below participants return if (rightIsGroup) { -1 } else { 1 } } if (left.isOnline && !right.isOnline) { return -1 } else if (!left.isOnline && right.isOnline) { return 1 } val moderatorTypes = ArrayList() moderatorTypes.add(Participant.ParticipantType.MODERATOR) moderatorTypes.add(Participant.ParticipantType.OWNER) moderatorTypes.add(Participant.ParticipantType.GUEST_MODERATOR) if (moderatorTypes.contains(left.model.type) && !moderatorTypes.contains(right.model.type)) { return -1 } else if (!moderatorTypes.contains(left.model.type) && moderatorTypes.contains(right.model.type)) { return 1 } return left.model.displayName.toLowerCase(Locale.ROOT).compareTo( right.model.displayName.toLowerCase(Locale.ROOT) ) } } }