Kynetics/uf-android-client

/*
 * Copyright © 2017-2023  Kynetics  LLC
 * 
 * This program and the accompanying materials are made
 * available under the terms of the Eclipse Public License 2.0
 * which is available at https://www.eclipse.org/legal/epl-2.0/
 *
 * SPDX-License-Identifier: EPL-2.0
 */

package com.kynetics.uf.android.communication

import android.os.Message
import android.util.Log
import com.kynetics.uf.android.api.ApiCommunicationVersion
import com.kynetics.uf.android.api.Communication.Companion.SERVICE_API_VERSION_KEY
import com.kynetics.uf.android.client.RestartableClientService
import com.kynetics.uf.android.communication.impl.CommunicationApiV0_1Impl
import com.kynetics.uf.android.communication.impl.CommunicationApiV1Impl
import com.kynetics.uf.android.communication.impl.CommunicationApiV1_1Impl
import com.kynetics.uf.android.communication.impl.CommunicationApiV1_2Impl
import com.kynetics.uf.android.configuration.AndroidDeploymentPermitProvider
import com.kynetics.uf.android.configuration.ConfigurationHandler

class CommunicationApiStrategy private constructor(
    private val communicationApis: Map<ApiCommunicationVersion, CommunicationApi>
):CommunicationApi {


    override fun onMessage(msg: Message) {
        runCatching {
            val api = ApiCommunicationVersion.fromVersionCode(msg.getApiVersionCode())
            communicationApis.getValue(api).onMessage(msg)
        }.onFailure { e ->
            Log.w(TAG, "unsupported communication version used by the client (api: ${msg.getApiVersionCode()}", e)
        }


    }

    private fun Message.getApiVersionCode():Int = data.getInt(SERVICE_API_VERSION_KEY, 0)

    companion object{
        private val TAG:String = CommunicationApiStrategy::class.java.simpleName

        fun newInstance(
            configurationHandler: ConfigurationHandler,
            restartableClientService: RestartableClientService,
            softDeploymentPermitProvider: AndroidDeploymentPermitProvider
        ) :CommunicationApiStrategy{
            return CommunicationApiStrategy(
                mapOf(
                    ApiCommunicationVersion.V0_1 to CommunicationApiV0_1Impl(
                        configurationHandler,
                        restartableClientService,
                        softDeploymentPermitProvider
                    ),

                    ApiCommunicationVersion.V1 to CommunicationApiV1Impl(
                        configurationHandler,
                        restartableClientService,
                        softDeploymentPermitProvider
                    ),

                    ApiCommunicationVersion.V1_1 to CommunicationApiV1_1Impl(
                        configurationHandler,
                        restartableClientService,
                        softDeploymentPermitProvider
                    ),

                    ApiCommunicationVersion.V1_2 to CommunicationApiV1_2Impl(
                        configurationHandler,
                        restartableClientService,
                        softDeploymentPermitProvider
                    )

                )
            )
        }
    }

}