Display Snackbar when message is received

app/build.gradle

@@ -6,7 +6,7 @@ android {
     compileSdk 31
 
     defaultConfig {
-        applicationId "com.example.mysecondapp"
+        applicationId "ch.luria.mq1"
         minSdk 29
         targetSdk 31
         versionCode 1

app/src/main/java/ch/luria/mq1/MainActivity.java

@@ -12,6 +12,8 @@ import android.util.Log;
 import android.view.View;
 import android.widget.ToggleButton;
 
+import com.google.android.material.snackbar.Snackbar;
+
 import androidx.appcompat.app.AppCompatActivity;
 
 public class MainActivity extends AppCompatActivity {
@@ -22,6 +24,9 @@ public class MainActivity extends AppCompatActivity {
         public void onReceive(Context context, Intent intent) {
             String msg = intent.getStringExtra("STATE");
             Log.i(TAG, "Received " + msg);
+            View contextView = findViewById(R.id.toggleButton);
+            Snackbar.make(contextView, "Received " + msg, Snackbar.LENGTH_LONG)
+                .show();
             stateButton.setChecked(!msg.equals("OFF"));
         }
     };
@@ -61,11 +66,7 @@ public class MainActivity extends AppCompatActivity {
     }
 
     public void toggleButtonState(View view) {
-        if (stateButton.isChecked()) {
-            mService.doToggle("{\"state\":\"ON\"}");
-        } else {
-            mService.doToggle("{\"state\":\"OFF\"}");
-        }
+        mService.doToggle(stateButton.isChecked());
     }
 
     private final ServiceConnection connection = new ServiceConnection() {

app/src/main/java/ch/luria/mq1/MqttService.java

@@ -6,6 +6,7 @@ import android.os.Binder;
 import android.os.IBinder;
 import android.util.Log;
 
+import com.hivemq.client.mqtt.MqttClientState;
 import com.hivemq.client.mqtt.mqtt5.Mqtt5AsyncClient;
 import com.hivemq.client.mqtt.mqtt5.Mqtt5Client;
 
@@ -18,6 +19,8 @@ public class MqttService extends Service {
     private Mqtt5AsyncClient client;
     private static final String TAG = "MQTT Service";
     private final IBinder binder = new LocalBinder();
+    private static final String mqttHost = "192.168.178.64";
+    private static final int mqttPort = 1883;
 
     public class LocalBinder extends Binder {
         public MqttService getService() {
@@ -30,52 +33,43 @@ public class MqttService extends Service {
     public void onCreate() {
         Log.i(TAG, "onCreate");
         if (client == null) {
-            Log.i(TAG, "connecting");
             client = Mqtt5Client.builder()
                     .identifier(UUID.randomUUID().toString())
-                    .serverHost("192.168.178.64")
-                    .serverPort(1883)
+                    .serverHost(mqttHost)
+                    .serverPort(mqttPort)
                     .buildAsync();
-            client.connectWith()
-                    .send()
-                    .whenComplete((connAck, throwable) -> {
-                        if (throwable != null) {
-                            // handle failure
-                            Log.i(TAG, "could not connect");
-                        } else {
-                            Log.i(TAG, "connect ok");
-                            subscribe();
-                        }
-                    });
         }
     }
 
     @Override
     public IBinder onBind(Intent intent) {
         Log.i(TAG, "onBind");
+        connect();
         return binder;
     }
 
-    public void doToggle(String what) {
-        publishMessage("zigbee2mqtt/Ampoule Chambre Isaac/set", what);
+    private void connect() {
+        if (client.getState() == MqttClientState.DISCONNECTED) {
+            Log.i(TAG, "connect()");
+            client.connectWith()
+                    .send()
+                    .whenComplete((connAck, throwable) -> {
+                        if (throwable != null) {
+                            // handle failure
+                            Log.i(TAG, "could not connect - " + connAck.getReasonString());
+                        } else {
+                            Log.i(TAG, "connect ok");
+                            subscribe();
                         }
-
-    private void sendMessage(String msg) {
-        Intent intent = new Intent();
-        intent.setAction("ch.luria.mq1");
-        try {
-            final JSONObject obj = new JSONObject(msg);
-            String state = obj.getString("state");
-            intent.putExtra("STATE", state);
-            sendBroadcast(intent);
-        } catch (JSONException e) {
-            e.printStackTrace();
+                    });
+        } else {
+            Log.i(TAG, "connect() in state " + client.getState());
         }
     }
 
     private void subscribe() {
         client.subscribeWith()
-                .topicFilter("zigbee2mqtt/Ampoule Chambre Isaac")
+                .topicFilter(getString(R.string.mqtt_base_topic) + "/" + getString(R.string.mqtt_room_address))
                 .callback(publish -> {
                     // Process the received message
                     String msg = new String(publish.getPayloadAsBytes()) + " from " + publish.getTopic();
@@ -90,45 +84,66 @@ public class MqttService extends Service {
                     } else {
                         // Handle successful subscription, e.g. logging or incrementing a metric
                         Log.i(TAG, "subscribe ok");
-                        getStatus();
                     }
                 });
-
     }
 
-    public void getStatus() {
-        if (client != null) {
-            client.publishWith()
-                    .topic("zigbee2mqtt/Ampoule Chambre Isaac/get")
-                    .payload("{\"state\":\"\"}".getBytes())
-                    .send()
-                    .whenComplete((mqtt3Publish, throwable) -> {
-                        if (throwable != null) {
-                            // handle failure to publish
-                            Log.i(TAG, "could not publish");
-                        } else {
-                            // handle successful publish, e.g. logging or incrementing a metric
-                            Log.i(TAG, "published");
-                        }
-                    });
+    private void sendMessage(String msg) {
+        Intent intent = new Intent();
+        intent.setAction("ch.luria.mq1");
+        try {
+            final JSONObject obj = new JSONObject(msg);
+            String state = obj.getString(getString(R.string.mqtt_state_field));
+            intent.putExtra("STATE", state);
+            sendBroadcast(intent);
+        } catch (JSONException e) {
+            e.printStackTrace();
         }
     }
 
     private void publishMessage(String topic, String message) {
+        if (client != null) {
+            if (client.getState() == MqttClientState.CONNECTED) {
                 client.publishWith()
                         .topic(topic)
                         .payload(message.getBytes())
                         .send()
-                .whenComplete((mqtt3Publish, throwable) -> {
+                        .whenComplete((mqttPublish, throwable) -> {
                             if (throwable != null) {
                                 // handle failure to publish
-                        Log.i(TAG, "could not publish");
+                                Log.i(TAG, "publishMessage(): could not publish: " + throwable);
                             } else {
                                 // handle successful publish, e.g. logging or incrementing a metric
                                 Log.i(TAG, "published " + message + " on " + topic);
-                        getStatus();
                             }
                         });
+            } else {
+                Log.i(TAG, "publishMessage(): not connected");
+            }
+        } else {
+            Log.i(TAG, "publishMessage(): null client");
+        }
     }
 
+    public void doToggle(boolean state) {
+        JSONObject obj = new JSONObject();
+        try {
+            obj.put(getString(R.string.mqtt_state_field), state ? "ON" : "OFF");
+            Log.i(TAG, "doToggle: " + obj);
+            publishMessage(getString(R.string.mqtt_base_topic) + "/" + getString(R.string.mqtt_room_address) + "/set", obj.toString());
+        } catch (JSONException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public void getStatus() {
+        JSONObject obj = new JSONObject();
+        try {
+            obj.put(getString(R.string.mqtt_state_field), "");
+            Log.i(TAG, "getStatus()");
+            publishMessage(getString(R.string.mqtt_base_topic) + "/" + getString(R.string.mqtt_room_address) + "/get", obj.toString());
+        } catch (JSONException e) {
+            e.printStackTrace();
+        }
+    }
 }

app/src/main/res/values-night/themes.xml

@@ -1,6 +1,6 @@
 <resources xmlns:tools="http://schemas.android.com/tools">
     <!-- Base application theme. -->
-    <style name="Theme.Mq1" parent="Theme.MaterialComponents.DayNight.DarkActionBar">
+    <style name="Theme.Mq1" parent="Theme.MaterialComponents.DayNight.NoActionBar">
         <!-- Primary brand color. -->
         <item name="colorPrimary">@color/purple_200</item>
         <item name="colorPrimaryVariant">@color/purple_700</item>

app/src/main/res/values/strings.xml

@@ -3,4 +3,7 @@
     <string name="button_on">ALLUMEE</string>
     <string name="button_off">ETEINTE</string>
     <string name="room_name">Chambre d\'Isaac</string>
+    <string name="mqtt_base_topic">zigbee2mqtt</string>
+    <string name="mqtt_room_address">Ampoule Chambre Isaac</string>
+    <string name="mqtt_state_field">state</string>
 </resources>

app/src/main/res/values/themes.xml

@@ -1,6 +1,6 @@
 <resources xmlns:tools="http://schemas.android.com/tools">
     <!-- Base application theme. -->
-    <style name="Theme.Mq1" parent="Theme.MaterialComponents.DayNight.DarkActionBar">
+    <style name="Theme.Mq1" parent="Theme.MaterialComponents.DayNight.NoActionBar">
         <!-- Primary brand color. -->
         <item name="colorPrimary">@color/purple_500</item>
         <item name="colorPrimaryVariant">@color/purple_700</item>