feat(backgroundmode): app-93 MQTT Client reconnect Android

Author: alessioemireni

android/src/main/java/com/github/emotokcak/reactnative/mqtt/RNMqttClient.kt

@@ -252,6 +252,7 @@ class RNMqttClient(reactContext: ReactApplicationContext)
      * - `clientId`: {`String`} Client ID of the device.
      * - `host`: {`String`} Host name of the MQTT broker.
      * - `port`: {`int`} Port of the MQTT broker.
+     * - `reconnect`: {`Boolean`} Reconnect if connection is lost.
      *
      * @param params
      *
@@ -304,7 +305,9 @@ class RNMqttClient(reactContext: ReactApplicationContext)
                 override fun connectionLost(cause: Throwable?) {
                     Log.d(NAME, "connectionLost", cause)
                     this@RNMqttClient.notifyError("ERROR_CONNECTION", cause)
-                    this@RNMqttClient.notifyEvent("disconnected", null)
+                    if(!parsedParams.reconnect) {
+                      this@RNMqttClient.notifyEvent("disconnected", null)
+                    }
                 }
 
                 override fun deliveryComplete(token: IMqttDeliveryToken) {
@@ -340,8 +343,9 @@ class RNMqttClient(reactContext: ReactApplicationContext)
                 }
             })
             val connectOptions = MqttConnectOptions()
-            connectOptions.setSocketFactory(socketFactory)
-            connectOptions.setCleanSession(true)
+            connectOptions.socketFactory = socketFactory
+            connectOptions.isCleanSession = true
+            connectOptions.isAutomaticReconnect = parsedParams.reconnect
             Log.d(NAME, "connecting to the broker")
             val token = client.connect(connectOptions)
             token.setActionCallback(object: IMqttActionListener {
@@ -549,15 +553,17 @@ class RNMqttClient(reactContext: ReactApplicationContext)
     private class ConnectionParameters(
         val host: String,
         val port: Int,
-        val clientId: String
+        val clientId: String,
+        val reconnect: Boolean
     ) {
         companion object {
             // Parses a given object from JavaScript.
             fun parseReadableMap(params: ReadableMap): ConnectionParameters {
                 return ConnectionParameters(
                     host=params.getRequiredString("host"),
                     port=params.getRequiredInt("port"),
-                    clientId=params.getRequiredString("clientId")
+                    clientId=params.getRequiredString("clientId"),
+                    reconnect=params.getRequiredBoolean("reconnect")
                 )
             }
         }

android/src/main/java/com/github/emotokcak/reactnative/mqtt/package.kt

@@ -118,3 +118,32 @@ fun ReadableMap.getOptionalMap(key: String): ReadableMap? {
     }
     return this.getMap(key)
 }
+
+/**
+* Obtains an optional Boolean value from a given `ReadableMap`.
+*
+* @param key
+*
+*   Key associated with the value to be obtained.
+*
+* @return
+*
+*   Boolean value associated with `key`.
+*   `false` if no value is associated with `key`.
+*
+* @throws IllegalArgumentException
+*
+*   If the value associated with `key` is not a Boolean.
+*/
+fun ReadableMap.getRequiredBoolean(key: String): Boolean {
+  if (!this.hasKey(key)) {
+    return false
+  }
+  if (this.getType(key) != ReadableType.Boolean) {
+    throw IllegalArgumentException(
+      "$key must be associated with a Boolean" +
+        " but ${this.getType(key)} was given"
+    )
+  }
+  return this.getBoolean(key)
+}

react-native-mqtt-client.podspec

@@ -18,5 +18,5 @@ Pod::Spec.new do |s|
 
 
   s.dependency "React"
-  s.dependency "CocoaMQTT"
+  s.dependency "CocoaMQTT", "~> 2.1.1"
 end

src/index.tsx

@@ -287,6 +287,7 @@ export type ConnectionParameters = {
   host: string;
   port: string;
   clientId: string;
+  reconnect: boolean;
 };
 
 const defaultInstance = new MqttClient();