refactor: rm like when not necessary

src/main.ts

@@ -9,6 +9,7 @@ import { Record } from "./interfaces/notifications";
 import cron from "node-cron";
 import { initServer } from "./server";
 import "dotenv/config";
+import { shouldProcessMention } from "./shouldProcessMention";
 
 connectRedis();
 
@@ -31,13 +32,17 @@ export async function main() {
       console.log("Processing another mention");
       const record = mention.record as Record;
       const taggedPost = mention.uri;
+      const shouldProcess = await shouldProcessMention(taggedPost)
+      if (shouldProcess) {
+        console.log(`Already sended ${taggedPost}`);
+        continue;
+      }
+
       const convo = await listConvo(mention.author.did, agent);
       const url = getUrlFromUri(record.reply.root.uri);
       const message = await messageBuilder(url, record.text);
       await message.detectFacets(agent);
       await sendMessage(convo.id, message, agent, taggedPost);
-      await saveWrongMessage(mention.uri);
-      await agent.like(mention.uri, mention.cid);
       console.log("Process ended");
     } catch (error) {
       console.error("Error:", error);

src/sendMessage.ts

@@ -1,31 +1,19 @@
 import AtpAgent, { RichText } from "@atproto/api";
-import { messageExists, saveMessage, messageWrongExists } from "./redis";
+import { saveMessage } from "./redis";
 
 export const sendMessage = async (
   convoId: string,
   message: RichText,
   agent: AtpAgent,
   taggedPost: string
 ) => {
-  try {
-    const [sended, wrongMessage] = await Promise.all([
-      messageExists(taggedPost),
-      messageWrongExists(taggedPost),
-    ]);
-    if (sended || wrongMessage) {
-      console.log(`Already sended ${taggedPost}`);
-      return;
-    }
-    const proxy = agent.withProxy("bsky_chat", "did:web:api.bsky.chat");
-    await proxy.chat.bsky.convo.sendMessage({
-      convoId: convoId,
-      message: {
-        text: message.text,
-        facets: message.facets,
-      },
-    });
-    await saveMessage(taggedPost);
-  } catch (error) {
-    console.log("Error on send message:", error);
-  }
+  const proxy = agent.withProxy("bsky_chat", "did:web:api.bsky.chat");
+  await proxy.chat.bsky.convo.sendMessage({
+    convoId: convoId,
+    message: {
+      text: message.text,
+      facets: message.facets,
+    },
+  });
+  await saveMessage(taggedPost);
 };

src/shouldProcessMention.ts

@@ -0,0 +1,9 @@
+import { messageExists, messageWrongExists } from "./redis";
+
+export const shouldProcessMention = async (taggedPost: string) => {
+  const [sended, wrongMessage] = await Promise.all([
+    messageExists(taggedPost),
+    messageWrongExists(taggedPost),
+  ]);
+  return sended || wrongMessage;
+};