Add a publish method to Observer

Author: bcopy

dist/src/HomieObserver.d.ts

@@ -40,6 +40,7 @@ type HomieEvent = HomieDeviceEvent | HomieNodeEvent | HomiePropertyEvent;
 interface MqttMessageHandler {
     handleMessage(topic: string, message: Buffer): void;
     subscribe(topic: string): void;
+    publish(topic: string, message: string | Buffer): void;
 }
 declare class MqttClient implements MqttMessageHandler {
     private client;
@@ -49,6 +50,7 @@ declare class MqttClient implements MqttMessageHandler {
         homiePrefix?: string | undefined;
     } | undefined, messageCallback: (event: HomieEvent) => void);
     subscribe(pattern: string): void;
+    publish(topic: string, message: string | Buffer): void;
     private getSubscriptionTopic;
     handleMessage(topic: string, message: Buffer): void;
     private handleDeviceState;

src/HomieObserver.ts

@@ -50,6 +50,7 @@ type HomieEvent = HomieDeviceEvent | HomieNodeEvent | HomiePropertyEvent;
 interface MqttMessageHandler {
   handleMessage(topic: string, message: Buffer): void;
   subscribe(topic: string): void;
+  publish(topic: string, message: string | Buffer) : void;
 }
 
 // MQTT Client class
@@ -71,6 +72,10 @@ class MqttClient implements MqttMessageHandler {
     this.client.subscribe(subscriptionTopic);
   }
 
+  public publish(topic: string, message: string | Buffer) : void {
+    this.client.publish(this.homiePrefix+"/"+topic, message);
+  }
+
   private getSubscriptionTopic(pattern: string): string {
     return pattern.startsWith(this.homiePrefix) ? pattern : `${this.homiePrefix}/${pattern}`;
   }

test/HomieObserver.test.ts

@@ -36,6 +36,10 @@ class MockMqttClient implements MqttMessageHandler {
   subscribe(topic: string): void {
     // no-op - mock implementation
   }
+
+  publish(topic: string, message: string | Buffer): void {
+    // no-op - mock implementation
+  }
 }
 
 describe('HomieObserver', () => {

test/HomiePropertyBuffer.test.ts

@@ -19,6 +19,7 @@ class MockMqttClient implements MqttMessageHandler {
   }
 
   subscribe(topic: string): void {}
+  publish(topic: string, message: string | Buffer): void {}
 }
 
 describe('HomiePropertyBuffer', () => {