VideoConferencePresenter.kt

package chat.rocket.android.videoconference.presenter

import chat.rocket.android.analytics.AnalyticsManager
import chat.rocket.android.analytics.event.SubscriptionTypeEvent
import chat.rocket.android.core.lifecycle.CancelStrategy
import chat.rocket.android.helper.JitsiHelper
import chat.rocket.android.helper.UserHelper
import chat.rocket.android.server.domain.CurrentServerRepository
import chat.rocket.android.server.domain.GetSettingsInteractor
import chat.rocket.android.server.domain.PublicSettings
import chat.rocket.android.server.domain.isJitsiSSL
import chat.rocket.android.server.domain.jitsiDomain
import chat.rocket.android.server.domain.jitsiPrefix
import chat.rocket.android.server.domain.uniqueIdentifier
import chat.rocket.android.server.infrastructure.ConnectionManagerFactory
import chat.rocket.android.util.extension.launchUI
import chat.rocket.common.model.RoomType
import chat.rocket.common.model.roomTypeOf
import chat.rocket.core.RocketChatClient
import chat.rocket.core.internal.rest.updateJitsiTimeout
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.launch
import timber.log.Timber
import java.net.URL
import java.util.*
import javax.inject.Inject
import kotlin.concurrent.timer

class VideoConferencePresenter @Inject constructor(
    private val view: JitsiVideoConferenceView,
    private val strategy: CancelStrategy,
    private val currentServerRepository: CurrentServerRepository,
    private val connectionManagerFactory: ConnectionManagerFactory,
    private val settings: GetSettingsInteractor,
    private val analyticsManager: AnalyticsManager
) {
    private var client: RocketChatClient? = null
    private lateinit var publicSettings: PublicSettings
    private lateinit var chatRoomId: String
    private lateinit var chatRoomType: String
    private lateinit var timer: Timer

    fun setup(chatRoomId: String, chatRoomType: String) {
        currentServerRepository.get()?.let {
            client = connectionManagerFactory.create(it)?.client
            publicSettings = settings.get(it)
        }
        this.chatRoomId = chatRoomId
        this.chatRoomType = chatRoomType
    }

    fun initVideoConference() {
        launchUI(strategy) {
            try {
                with(publicSettings) {
                    view.setupVideoConference(
                        URL(JitsiHelper.getJitsiServerUrl(isJitsiSSL(), jitsiDomain()))
                    )
                    view.startVideoConference(
                        JitsiHelper.getJitsiRoom(jitsiPrefix(), uniqueIdentifier(), chatRoomId)
                    )

                    updateJitsiTimeout()
                    logVideoConferenceEvent()
                }
            } catch (ex: Exception) {
                Timber.e(ex)
                view.finishVideoConference()
            }
        }
    }

    fun invalidateTimer() = timer.cancel()

    // Jitsi update call needs to be called every 10 seconds to make sure call is not ended and is available to web users.
    private fun updateJitsiTimeout() {
        timer = timer(daemon = false, initialDelay = 0L, period = 10000) {
            GlobalScope.launch(Dispatchers.IO + strategy.jobs) {
                client?.updateJitsiTimeout(chatRoomId)
            }
        }
    }

    private fun logVideoConferenceEvent() = when {
        roomTypeOf(chatRoomType) is RoomType.DirectMessage ->
            analyticsManager.logVideoConference(SubscriptionTypeEvent.DirectMessage)
        roomTypeOf(chatRoomType) is RoomType.Channel ->
            analyticsManager.logVideoConference(SubscriptionTypeEvent.Channel)
        else -> analyticsManager.logVideoConference(SubscriptionTypeEvent.Group)
    }
}