/**
 * Представляет SignalR-реализацию слушателя внешних событий.
 * @param sslSocketFactory Модифицированный протокол безопасной передачи данных.
 * @param trustAllCerts Модифицированный X509TrustManager для доверия всем сертификатам.
 */
class SignalRListener (
    private val sslSocketFactory: SSLSocketFactory,
    private val trustAllCerts: TrustAllCerts
) : ISignalRListener {

    private val apiUrl = "https://something.com/api/"   //Адрес Вашего api
    private val hubConnection = HubConnectionBuilder.create(apiUrl + "GatewayHub")   //
        .setHttpClientBuilderCallback {
            it.sslSocketFactory(sslSocketFactory, trustAllCerts)
        }
        .build()

    override val connectionId: String?
        get() = hubConnection.connectionId
    override val connectionState: HubConnectionState
        get() = hubConnection.connectionState

    override fun startConnection() {
        hubConnection.start()
    }

    override fun stopConnection() {
        hubConnection.stop()
    }

    override fun subscribe(
        eventName: String,
        handler: (event: LinkedTreeMap<String, String>) -> Unit
    ) {
        hubConnection.on(
            eventName,
            handler,
            LinkedTreeMap::class.java
        )
    }

    override fun unsubscribe(eventName: String) {
        hubConnection.remove(eventName)
    }
}

/**
 * Описывает реализацию слушателя внешних событий.
 */
interface ISignalRListener {
    /**
     * Возвращает id подключения к SignalR.
     */
    val connectionId: String?

    /**
     * Возвращает статус подключения к SignalR.
     */
    val connectionState: HubConnectionState

    /**
     * Выполняет подключение к серверу SignalR.
     */
    fun startConnection()

    /**
     * Выполняет отключение от сервера SignalR.
     */
    fun stopConnection()

    /**
     * Подписывается на событие.
     * @param eventName Имя события.
     * @param handler Обработчик события.
     */
    fun subscribe(eventName: String, handler: (LinkedTreeMap<String, String>) -> Unit)

    /**
     * Отписывается от события.
     * @param eventName Имя события.
     */
    fun unsubscribe(eventName: String)
}

/**
 * Представляет реализацию подписок на ресурсы.
 */
class SignalRService (
    private val signalRListener: ISignalRListener
) : ISignalRService {
    /**
     * Возвращает или устанавливает подписку на ресурсы.
     */
    private val resourcesSubscriptions = mutableListOf<ResourceSubscriptionModel>()

    init {
        subscribeOnResourceChanged()
    }

    /**
     * Подписывается на события изменения ресурса.
     */
    private fun subscribeOnResourceChanged() {
        signalRListener.subscribe(
            "ResourceChangedEventOccurred"
        ) { event ->
            resourcesSubscriptions.forEach { subscription ->
                val resourceName = event["resourceName"]
                if (resourceName != null && resourceName.contains(subscription.resourceName)) {
                    //Реагируем на изменение ресурса.
                    subscription.callback()
                }
            }
        }
    }

    override fun subscribe(subscriptionsForAdd: List<ResourceSubscriptionModel>) {
        subscriptionsForAdd.forEach { resourceSubscription ->
            resourcesSubscriptions.add(resourceSubscription)
        }
    }

    override fun unsubscribe(subscriptionsForRemove: List<ResourceSubscriptionModel>) {
        subscriptionsForRemove.forEach { resourceSubscription ->
            resourcesSubscriptions.remove(resourceSubscription)
        }
    }
}

/**
 * Описывает методы подписки на внешние события.
 */
interface ISignalRService {
    /**
     * Добавляет ресурсы в подписку.
     * @param subscriptionsAdd Список ресурсов для подписки.
     */
    fun subscribe(subscriptionsAdd: List<ResourceSubscriptionModel>)

    /**
     * Удаляет ресурсы из подписки.
     * @param subscriptionsRemove Список ресурсов для отписки.
     */
    fun unsubscribe(subscriptionsRemove: List<ResourceSubscriptionModel>)
}

/**
 * Представляет подписку на ресурс.
 */
data class ResourceSubscriptionModel(
    /**
     * Имя ресурса для отслеживания событий.
     */
    val resourceName: String,
    /**
     * Метод выполняемый при получении события.
     */
    val callback: () -> Unit
)

/**
 * Позволяет доверять всем сертификатом.
 */
class TrustAllCerts : X509TrustManager {
    override fun getAcceptedIssuers(): Array<X509Certificate> = arrayOf()
    override fun checkClientTrusted(certs: Array<X509Certificate>, authType: String) = Unit
    override fun checkServerTrusted(certs: Array<X509Certificate>, authType: String) = Unit
}

/**
 * Представляет приложение.
 */
class SignalRApplication : Application() {

    lateinit var signalRListener: ISignalRListener   // Слушатель внешних событий.
    lateinit var signalRService: ISignalRService   // Сервис подписок на ресурсы.

    companion object {
        lateinit var application: SignalRApplication
    }

    override fun onCreate() {
        super.onCreate()
        application = this

        // Модифицированный X509TrustManager для доверия всем сертификатам.
        val trustAllCerts = TrustAllCerts()
        // Модифицированный протокол безопасной передачи данных.
        val sslSocketFactory = SSLContext.getInstance("TLSv1.2").apply {
                init(null, arrayOf<TrustManager>(trustAllCerts), SecureRandom())
            }.socketFactory

        signalRListener = SignalRListener(sslSocketFactory, trustAllCerts)
        signalRService = SignalRService(signalRListener)
    }

}

/**
 * Представляет базовый класс Activity
 */
abstract class BaseActivity : AppCompatActivity() {

    /**
     * Сервис подписок на ресурсы.
     */
    private val _signalRService = SignalRApplication.application.signalRService

    /**
     * Лист подписок.
     */
    private val _resourceSubscriptions: MutableList<ResourceSubscriptionModel> = mutableListOf()

    override fun onStop() {
        super.onStop()
        _signalRService.unsubscribe(_resourceSubscriptions)
    }

    /**
     * Устанавливает подписки на ресурсы.
     * @param resourceSubscriptions Лист подписок.
     */
    fun setSignalRSubscriptions(
        resourceSubscriptions: List<ResourceSubscriptionModel>
    ) {
        _resourceSubscriptions.addAll(resourceSubscriptions)
        _signalRService.subscribe(resourceSubscriptions)
    }
}