Small fix

Author: anton-knyazev

.idea/gradle.xml

@@ -53,21 +53,6 @@ internal class SocketClient(
         }
     }
 
-    override fun onClose(code: Int, reason: String?, remote: Boolean) {
-        waitAndReconnect()
-    }
-
-    override fun onError(ex: Exception?) {
-        // nothing
-    }
-
-    private fun waitAndReconnect() {
-        reconnectJob = launch {
-            delay(2000)
-            reconnect()
-        }
-    }
-
     fun sendLog(logText: String) {
         if (!isClosed) {
             send("$HEADER_LOG:$logText")
@@ -83,6 +68,21 @@ internal class SocketClient(
         }
     }
 
+    override fun onError(ex: Exception?) {
+        // nothing
+    }
+
+    override fun onClose(code: Int, reason: String?, remote: Boolean) {
+        waitAndReconnect()
+    }
+
+    private fun waitAndReconnect() {
+        reconnectJob = launch {
+            delay(2000)
+            reconnect()
+        }
+    }
+
     interface Callback {
 
         fun startLog()

lib/src/main/java/com/omegar/libs/testconnect/SocketClient.kt

@@ -27,7 +27,7 @@ internal object TestConnector : Callback, CoroutineScope {
 
     private var socketClient: SocketClient? = null
     private var activityCatcher: ActivityCatcher? = null
-    private val logCatcher = LogCatcher()
+    private var logCatcher: LogCatcher? = null
 
     private var logJob: Job? = null
         set(value) {
@@ -62,21 +62,24 @@ internal object TestConnector : Callback, CoroutineScope {
         }
 
     fun init(context: Context) {
-        socketClient = SocketClient(
-            url = "ws://192.168.10.57:8080/ws",
-            deviceName = context.deviceName,
-            appName = context.appName,
-            appVersion = context.appVersion,
-            callback = this
-        ).apply {
-            connect()
+        if (BuildConfig.DEBUG) {
+            logCatcher = LogCatcher()
+            socketClient = SocketClient(
+                url = "ws://192.168.10.57:8080/ws",
+                deviceName = context.deviceName,
+                appName = context.appName,
+                appVersion = context.appVersion,
+                callback = this
+            ).apply {
+                connect()
+            }
+            activityCatcher = ActivityCatcher(context)
         }
-        activityCatcher = ActivityCatcher(context)
     }
 
     override fun startLog() {
         logJob = launch {
-            logCatcher.flow.collect {
+            logCatcher?.flow?.collect {
                 socketClient?.sendLog(it)
             }
         }