Create scarletmessenger.kt

scarletmessenger.kt

@@ -0,0 +1,91 @@
+//def scarlet_version = '0.1.9'
+//implementation "com.tinder.scarlet:scarlet:${scarlet_version}"
+//implementation "com.tinder.scarlet:websocket-okhttp:${scarlet_version}"
+//implementation "com.tinder.scarlet:message-adapter-gson:${scarlet_version}"
+//implementation "com.tinder.scarlet:stream-adapter-coroutines:${scarlet_version}"
+//implementation "com.tinder.scarlet:lifecycle-android:${scarlet_version}"
+//def okhttp3_version = '4.9.0'
+//implementation "com.squareup.okhttp3:okhttp:${okhttp3_version}"
+//implementation "com.squareup.okhttp3:logging-interceptor:${okhttp3_version}"
+//implementation "com.google.code.gson:gson:2.8.6"
+
+interface MessengerApi {
+
+    // Receive websocket messages in the form of string
+    @com.tinder.scarlet.ws.Receive
+    fun observerMessage(): kotlinx.coroutines.channels.ReceiveChannel<MessageItem>
+
+    @com.tinder.scarlet.ws.Receive
+    fun observerEvent(): kotlinx.coroutines.channels.ReceiveChannel<com.tinder.scarlet.WebSocket.Event>
+
+    // Send message to websocket and return pass/fail boolean result
+    @com.tinder.scarlet.ws.Send
+    fun send(message: MessageItem): Boolean
+
+
+    // invoke method creating an invocation of the api call
+    companion object{
+        operator fun invoke(
+            webSocketUrl: String = "ws://echo.websocket.org/",
+            networkInterceptor: NetworkConnectionInterceptor
+        ) : MessengerApi {
+
+            val okHttpClient = okhttp3.OkHttpClient.Builder()
+                    .addNetworkInterceptor(networkInterceptor)
+                    .readTimeout(60, java.util.concurrent.TimeUnit.SECONDS)
+                    .writeTimeout(60, java.util.concurrent.TimeUnit.SECONDS)
+                    .connectTimeout(60, java.util.concurrent.TimeUnit.SECONDS)
+                    .build()
+
+
+            // creation of Api class for websocket
+            return com.tinder.scarlet.Scarlet.Builder()
+                .webSocketFactory(okHttpClient.newWebSocketFactory(webSocketUrl))
+                .addMessageAdapterFactory(com.tinder.scarlet.messageadapter.gson.GsonMessageAdapter.Factory())
+                .addStreamAdapterFactory(com.tinder.streamadapter.coroutines.CoroutinesStreamAdapterFactory())
+                .build()
+                .create()
+
+        }
+    }
+}
+
+/**
+ * Network interceptor to verify valid network connection
+ * Throws an [IOException] if there no valid internet connection
+ */
+class NetworkConnectionInterceptor(
+    context: android.content.Context
+): okhttp3.Interceptor {
+    private val applicationContext = context.applicationContext
+
+    override fun intercept(chain: okhttp3.Interceptor.Chain): okhttp3.Response {
+        if (!isInternetAvailable()) {
+            throw java.io.IOException("Make sure you have an active data connection")
+        }
+
+        return chain.proceed(chain.request())
+    }
+
+    private fun isInternetAvailable(): Boolean {
+        var result = false
+        val connectivityManager =
+            applicationContext.getSystemService(android.content.Context.CONNECTIVITY_SERVICE) as android.net.ConnectivityManager?
+        connectivityManager?.let {
+            it.getNetworkCapabilities(connectivityManager.activeNetwork)?.apply {
+                result = when {
+                    hasTransport(android.net.NetworkCapabilities.TRANSPORT_WIFI) -> true
+                    hasTransport(android.net.NetworkCapabilities.TRANSPORT_CELLULAR) -> true
+                    else -> false
+                }
+            }
+        }
+        return result
+    }
+}
+
+data class MessageItem(
+    @com.google.gson.annotations.SerializedName("")
+    @com.google.gson.annotations.Expose
+    var body: HashMap<String, Any>? = null
+)