🐛 Fix exiting before publishing

pvillaverde · May 22, 2024 · 7eea170 · 7eea170
1 parent f13415f
commit 7eea170
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/src/dev/pubsub.ts b/src/dev/pubsub.ts
@@ -32,7 +32,7 @@ async function sendMessage() {
    const message = {
       id: id
    }
-   mqttService.publish("test", JSON.stringify(message), { qos: 2 });
+   await mqttService.publishAsync("test", JSON.stringify(message), { qos: 2 });
    /* logger.info(`Publishing to MQTT topic "test"`, JSON.stringify(message)); */
    sendMessage();
 }

diff --git a/src/tasks/refreshBlogs.ts b/src/tasks/refreshBlogs.ts
@@ -57,7 +57,7 @@ export default async function refreshBlogs() {
                   entryLink: entry.link,
                };
                logger.debug(`Publishing to MQTT topic "${mqttConfig.MQTT_TOPIC}"`, JSON.stringify(message));
-               mqttService.publish(mqttConfig.MQTT_TOPIC, JSON.stringify(message), { qos: 2 });
+               await mqttService.publishAsync(mqttConfig.MQTT_TOPIC, JSON.stringify(message), { qos: 2 });
             }
          }
          logger.info(`${index + 1}/${blogs.length}`, `Recuperadas ${entries.length} entradas de ${item.title}.`);

diff --git a/src/tasks/refreshPodcasts.ts b/src/tasks/refreshPodcasts.ts
@@ -57,7 +57,7 @@ export default async function refreshPodcasts() {
                   entryLink: entry.link,
                };
                logger.debug(`Publishing to MQTT topic "${mqttConfig.MQTT_TOPIC}"`, JSON.stringify(message));
-               mqttService.publish(mqttConfig.MQTT_TOPIC, JSON.stringify(message), { qos: 2 });
+               await mqttService.publishAsync(mqttConfig.MQTT_TOPIC, JSON.stringify(message), { qos: 2 });
             }
          }
          logger.info(`${index + 1}/${podcasts.length}`, `Recuperados ${entries.length} episodios de ${item.title}.`);

diff --git a/src/tasks/refreshTwitchStreams.ts b/src/tasks/refreshTwitchStreams.ts
@@ -43,7 +43,7 @@ export default async function refreshTwitchStreams() {
          channel: channel,
          game: game,
       };
-      mqttService.publish(mqttConfig.MQTT_TOPIC, JSON.stringify(message), { qos: 2 });
+      await mqttService.publishAsync(mqttConfig.MQTT_TOPIC, JSON.stringify(message), { qos: 2 });
    }
    mqttService.end();
    Deno.exit(0);

diff --git a/src/tasks/refreshYoutube.ts b/src/tasks/refreshYoutube.ts
@@ -61,7 +61,7 @@ export default async function refreshYoutube() {
                   entryLink: entry.link,
                };
                logger.debug(`Publishing to MQTT topic "${mqttConfig.MQTT_TOPIC}"`, JSON.stringify(message));
-               mqttService.publish(mqttConfig.MQTT_TOPIC, JSON.stringify(message), { qos: 2 });
+               await mqttService.publishAsync(mqttConfig.MQTT_TOPIC, JSON.stringify(message), { qos: 2 });
             }
          }
          logger.info(