fix: reply in thread and don't run morning greeting if no new messages

Author: cirex-web

app.ts

@@ -22,15 +22,34 @@ registerListeners(app);
 (async () => {
   try {
     await app.start(process.env.PORT || 3000);
+    const appUserId = (await app.client.auth.test()).bot_id;
+    if (appUserId === undefined) throw new Error("Failed to get bot id!");
+
     app.logger.info("⚡️ Bolt app is running! ⚡️");
-    setUpDailyGreeting((msg) =>
-      app.client.chat
-        .postMessage({
-          text: msg,
-          channel: CMUEATS_CHANNEL_ID,
-        })
-        .catch(app.logger.error)
-    );
+    app.logger.info(`Bot user id: ${appUserId}`);
+    setUpDailyGreeting(async (msg) => {
+      // make sure latest message was not by mem-cho
+      const latestMessage = (
+        await app.client.conversations
+          .history({
+            limit: 1,
+            channel: CMUEATS_CHANNEL_ID,
+          })
+          .catch(app.logger.error)
+      )?.messages?.[0];
+
+      if (latestMessage?.bot_profile?.id !== appUserId) {
+        app.logger.info("Sending morning greeting :3");
+        app.client.chat
+          .postMessage({
+            text: msg,
+            channel: CMUEATS_CHANNEL_ID,
+          })
+          .catch(app.logger.error);
+      } else {
+        app.logger.info("Skipping morning greeting. Dead chat");
+      }
+    });
     setUpUptimeChecker((msg) =>
       app.client.chat
         .postMessage({

intervals/morning.ts

@@ -38,7 +38,9 @@ export const setUpDailyGreeting = (
 ) => {
   const currentTime = DateTime.local({ zone: "America/New_York" });
   const nextMorningTime =
-    currentTime.hour < greetingTime.hour
+    currentTime.hour < greetingTime.hour ||
+    (currentTime.hour === greetingTime.hour &&
+      currentTime.minute < greetingTime.minute)
       ? currentTime.set(greetingTime)
       : currentTime.set(greetingTime).plus({ days: 1 });
   scheduleNextGreeting(sendMessage, nextMorningTime);

listeners/events/index.ts

@@ -4,7 +4,10 @@ import appHomeOpenedCallback from "./app-home-opened";
 const register = (app: App) => {
   app.event("app_home_opened", appHomeOpenedCallback);
   app.event("app_mention", async ({ payload, say }) => {
-    await say("hai! I'm here to let you know when cmueats goes down :3");
+    await say({
+      text: "hai! I'm here to let you know when cmueats goes down :3",
+      thread_ts: payload.ts,
+    });
   });
 };
 

listeners/messages/index.ts

@@ -40,11 +40,12 @@ class GabeSenpaiMessages {
 
 const register = (app: App) => {
   const gabeMessages = new GabeSenpaiMessages();
-
-  app.message("gabe-senpai", async ({ say }) => {
+  app.message("gabe-senpai", async ({ say, message }) => {
     const nextMessage = gabeMessages.getNextMessage();
     if (nextMessage !== "") {
-      await say(nextMessage);
+      await say({ text: nextMessage, thread_ts: message.ts }).catch(
+        console.error
+      );
     }
   });
 };