From 9fd167c0f87dd515e58e3d00dcb48cfc63bcbf9c Mon Sep 17 00:00:00 2001
From: rdkartono <rdkartono@galva.co.id>
Date: Sat, 14 Jun 2025 14:28:50 +0700
Subject: [PATCH] first commit

---
 src/Main.java | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/src/Main.java b/src/Main.java
index e2b98cd..842c155 100644
--- a/src/Main.java
+++ b/src/Main.java
@@ -26,6 +26,17 @@ public class Main {
         }, pinStatus -> {
             // TODO Handle pin status updates here
             Logger.info("Gpio {}, Description {},  status updated to {}", pinStatus.getGpioNumber(), pinStatus.getDescription(), pinStatus.getStatus());
+            // MQTT publish pin status update
+            if (mqttClient != null && mqttClient.isConnected()) mqttClient.Publish(config.getMQTT_Topic(), config.getMQTT_ClientID(),
+                    String.format("Gpio %d, Description %s, Status %d", pinStatus.getGpioNumber(), pinStatus.getDescription(), pinStatus.getStatus()),
+                    published -> {
+                        if (published) {
+                            Logger.info("Pin status update published successfully.");
+                        } else {
+                            Logger.error("Failed to publish pin status update.");
+                        }
+                    });
+            // Email notification can be added here
 
 
             },
@@ -57,6 +68,7 @@ public class Main {
 
         // Add a shutdown hook to disconnect all services
         Runtime.getRuntime().addShutdownHook(new Thread(() -> {
+            if (gpio!=null && gpio.IsOpened()) gpio.Close();
             if (mqttClient!=null && mqttClient.isConnected()) mqttClient.Disconnect();
         }));
     }