fix: topic flag

Author: arlac77

src/service-mqtt.mjs

@@ -81,7 +81,7 @@ export class ServiceMQTT extends Service {
   get topics() {
     return Object.values(this.endpoints)
       .filter(e => e.topic)
-      .map(e => e.name);
+      .map(e => e.topic);
   }
 
   /**

src/topic-endpoint.mjs

@@ -4,7 +4,7 @@ export class TopicEndpoint extends SendReceiveEndpoint {
   constructor(name, owner, options) {
     super(name, owner, options);
 
-    if (options.topic) {
+    if (typeof options.topic === "string") {
       this._topic = options.topic;
     }
   }

tests/mqtt-ava.mjs

@@ -13,11 +13,13 @@ test("endpoint factory", async t => {
   const mqtt = await sp.declareService({
     type: ServiceMQTT,
     endpoints: {
-      s1: { topic: "s1", connected: r1 }
+      s1: { topic: true, connected: r1 },
+      s2: { topic: "s2b", connected: r1 }
     }
   });
 
   t.is(mqtt.endpoints["s1"].name, "s1");
+  t.is(mqtt.endpoints["s2"].name, "s2");
   t.true(mqtt.endpoints["s1"] instanceof TopicEndpoint);
-  t.deepEqual(mqtt.topics, ["s1"]);
+  t.deepEqual(mqtt.topics, ["s1", "s2b"]);
 });