🚨 Fix linter warnings

pvillaverde · May 16, 2024 · 08df6df · 08df6df
1 parent 81db992
commit 08df6df
Show file tree

Hide file tree

Showing 10 changed files with 36 additions and 53 deletions.
diff --git a/README.md b/README.md
@@ -2,7 +2,7 @@
 
 [![GitHub license][license-shield]][license-url]
 
-Esta aplicación encárgase de obter a información das canles rexistradas na [Asociación Cultural Obradoiro Dixital Galego](https://obradoirodixitalgalego.gal) e difundir o novo contido que xeran estes proxectos en galego pola rede, a través das canlees da asociación (Twitter, Mastodon e Discord).
+Esta aplicación encárgase de obter a información das canles rexistradas na [Asociación Cultural Obradoiro Dixital Galego](https://obradoirodixitalgalego.gal) e difundir o novo contido que xeran estes proxectos en galego pola rede, a través das canles da asociación (Twitter, Mastodon e Discord).
 
 # 🗂️ Índice
 
@@ -31,9 +31,9 @@ Esta aplicación encárgase de obter a información das canles rexistradas na [A
 - [ ] RefreshTwitch
 - [ ] RefreshTwitchClips
 - [ ] RefreshTwitchStreams
-- [ ] PublishTwitter
-- [ ] PublishMastodon
-- [ ] PublishDiscord
+- [x] PublishTwitter
+- [x] PublishMastodon
+- [x] PublishDiscord
 
 ## 🧩 Requerimentos
 

diff --git a/src/main.ts b/src/main.ts
@@ -19,6 +19,7 @@ logger.info(`
 `);
 let keepRuning = false;
 switch (task) {
+   // One-time tasks
    case "refreshBlogs":
       await refreshBlogs();
       break;
@@ -28,6 +29,7 @@ switch (task) {
    case "refreshYoutube":
       await refreshYoutube();
       break;
+   // Service Tasks
    case "publishTwitter":
       keepRuning = true;
       await publishTwitter();
@@ -44,24 +46,8 @@ switch (task) {
       logger.fatal("Especifica unha subtarefa para executar a RADIO Dixital.");
       break;
 }
+
 if (!keepRuning) {
    connection.end();
    mqttService.end();
 }
-
-// const food = Deno.args[1];
-// console.log(`Hello ${name}, I like ${food}!`);
-
-// import { parseArgs } from "jsr:@std/cli/parse-args";
-
-// const flags = parseArgs(Deno.args, {
-//    boolean: ["help", "color"],
-//    string: ["version"],
-//    default: { color: true },
-//    negatable: ["color"],
-// });
-// console.log("Wants help?", flags.help);
-// console.log("Version:", flags.version);
-// console.log("Wants color?:", flags.color);
-
-// console.log("Other:", flags._);
diff --git a/src/services/mqtt.service.ts b/src/services/mqtt.service.ts
@@ -4,4 +4,4 @@ export default connect(`mqtt://${mqttConfig.MQTT_HOST}`, {
    username: mqttConfig.MQTT_USER,
    password: mqttConfig.MQTT_PASS,
    manualConnect: true,
-});
+});
diff --git a/src/tasks/publishDiscord.ts b/src/tasks/publishDiscord.ts
@@ -12,11 +12,11 @@ export default function publishDiscord() {
          if (err) {
             logger.error(err.toString());
          } else {
-            logger.info("Listening MQTT Topic")
+            logger.info("Listening MQTT Topic");
          }
       });
-   })
-   mqttService.on("message", async (topic, message) => {
+   });
+   mqttService.on("message", async (_topic, message) => {
       try {
          const decodedMessage: PubSubMessage = JSON.parse(message.toString());
          logger.debug(decodedMessage);
@@ -25,7 +25,7 @@ export default function publishDiscord() {
             .replace(/{channelName}/g, decodedMessage.title)
             .replace(/{mentionUser}/g, ``)
             .replace(/{title}/g, decodedMessage.entryTitle)
-            .replace(/{url}/g, decodedMessage.entryLink)
+            .replace(/{url}/g, decodedMessage.entryLink);
 
          const webhook = new Webhook(discordConfig[decodedMessage.type].webhook);
          const result = await webhook.send(messageStatus);
@@ -34,10 +34,7 @@ export default function publishDiscord() {
          logger.error(error);
          logger.error(message.toString());
       }
-   })
-
-
-
+   });
 
    // // const hook = new Webhook("YOUR WEBHOOK URL");
 
@@ -86,4 +83,4 @@ export default function publishDiscord() {
    // // window.sessionStorage.getItem('K2'); //{"a":1,"b":"2"}window.sessionStorage.length; //1
    // // window.sessionStorage.clear();
    // // window.sessionStorage.length; //0
-}
+}
diff --git a/src/tasks/publishMastodon.ts b/src/tasks/publishMastodon.ts
@@ -1,4 +1,4 @@
-import { createRestAPIClient } from 'npm:[email protected]';
+import { createRestAPIClient } from "npm:[email protected]";
 import mastodonConfig from "../config/mastodon.config.ts";
 import logger from "../services/logger.service.ts";
 import mqttService from "../services/mqtt.service.ts";
@@ -12,11 +12,11 @@ export default function publishMastodon() {
          if (err) {
             logger.error(err.toString());
          } else {
-            logger.info("Listening MQTT Topic")
+            logger.info("Listening MQTT Topic");
          }
       });
-   })
-   mqttService.on("message", async (topic, message) => {
+   });
+   mqttService.on("message", async (_topic, message) => {
       try {
          const decodedMessage: PubSubMessage = JSON.parse(message.toString());
          logger.debug(decodedMessage);
@@ -25,14 +25,14 @@ export default function publishMastodon() {
             .replace(/{channelName}/g, decodedMessage.title)
             .replace(/{mentionUser}/g, decodedMessage.mastodon ? ` (${decodedMessage.mastodon})` : ``)
             .replace(/{title}/g, decodedMessage.entryTitle)
-            .replace(/{url}/g, decodedMessage.entryLink)
+            .replace(/{url}/g, decodedMessage.entryLink);
 
          const mastodon = await createRestAPIClient(mastodonConfig[decodedMessage.type]);
-         const status = await mastodon.v1.statuses.create({ status: messageStatus, visibility: 'public', });
+         const status = await mastodon.v1.statuses.create({ status: messageStatus, visibility: "public" });
          logger.info(messageStatus, status.url);
       } catch (error) {
          logger.error(error);
          logger.error(message.toString());
       }
-   })
-}
+   });
+}
diff --git a/src/tasks/publishTwitter.ts b/src/tasks/publishTwitter.ts
@@ -1,4 +1,4 @@
-import { TwitterApi } from 'npm:[email protected]';
+import { TwitterApi } from "npm:[email protected]";
 import twitterConfig from "../config/twitter.config.ts";
 import logger from "../services/logger.service.ts";
 import mqttService from "../services/mqtt.service.ts";
@@ -12,11 +12,11 @@ export default function publishTwitter() {
          if (err) {
             logger.error(err.toString());
          } else {
-            logger.info("Listening MQTT Topic")
+            logger.info("Listening MQTT Topic");
          }
       });
-   })
-   mqttService.on("message", async (topic, message) => {
+   });
+   mqttService.on("message", async (_topic, message) => {
       try {
          const decodedMessage: PubSubMessage = JSON.parse(message.toString());
          logger.debug(decodedMessage);
@@ -25,7 +25,7 @@ export default function publishTwitter() {
             .replace(/{channelName}/g, decodedMessage.title)
             .replace(/{mentionUser}/g, decodedMessage.twitter ? ` (${decodedMessage.twitter})` : ``)
             .replace(/{title}/g, decodedMessage.entryTitle)
-            .replace(/{url}/g, decodedMessage.entryLink)
+            .replace(/{url}/g, decodedMessage.entryLink);
 
          const twitter = new TwitterApi(twitterConfig[decodedMessage.type]);
          const status = await twitter.v2.tweet(messageStatus);
@@ -34,5 +34,5 @@ export default function publishTwitter() {
          logger.error(error);
          logger.error(message.toString());
       }
-   })
-}
+   });
+}
diff --git a/src/tasks/refreshBlogs.ts b/src/tasks/refreshBlogs.ts
@@ -57,10 +57,10 @@ export default async function refreshBlogs() {
                      twitter: item.twitter,
                      entryTitle: entry.title,
                      entryLink: entry.link,
-                  }
+                  };
                   logger.debug(`Publishing to MQTT topic "${mqttConfig.MQTT_TOPIC}"`, JSON.stringify(message));
                   mqttService.publish(mqttConfig.MQTT_TOPIC, JSON.stringify(message));
-               })
+               });
             }
          }
          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,10 +57,10 @@ export default async function refreshPodcasts() {
                      twitter: item.twitter,
                      entryTitle: entry.title,
                      entryLink: entry.link,
-                  }
+                  };
                   logger.debug(`Publishing to MQTT topic "${mqttConfig.MQTT_TOPIC}"`, JSON.stringify(message));
                   mqttService.publish(mqttConfig.MQTT_TOPIC, JSON.stringify(message));
-               })
+               });
             }
          }
          logger.info(`${index + 1}/${podcasts.length}`, `Recuperados ${entries.length} episodios de ${item.title}.`);

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

diff --git a/src/types/pubsub.message.ts b/src/types/pubsub.message.ts
@@ -5,4 +5,4 @@ export default interface PubSubMessage {
    entryLink: string;
    twitter?: string;
    mastodon?: string;
-}
+}