mirror of
https://github.com/hmalik144/LiveTemplatesDictionary.git
synced 2025-12-10 03:05:28 +00:00
93 lines
3.6 KiB
Kotlin
93 lines
3.6 KiB
Kotlin
// Dependencies to be added to app/build.gradle:
|
|
//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
|
|
)
|