feat: implement ai chatbot reaction response 🤖

apps/api/src/routers/slack.router.ts

@@ -123,7 +123,7 @@ slackEventRouter.post('/slack/events', async (req: RawBodyRequest, res) => {
         return;
       }
 
-      job('slack.reaction.add', {
+      job('slack.reaction.added', {
         channelId: event.item.channel,
         messageId: event.item.ts,
         reaction: event.reaction,

packages/core/src/infrastructure/bull/bull.types.ts

@@ -535,6 +535,14 @@ export const SlackBullJob = z.discriminatedUnion('name', [
   }),
   z.object({
     name: z.literal('slack.reaction.add'),
+    data: SlackReaction.pick({
+      channelId: true,
+      messageId: true,
+      reaction: true,
+    }),
+  }),
+  z.object({
+    name: z.literal('slack.reaction.added'),
     data: SlackReaction.pick({
       channelId: true,
       messageId: true,

packages/core/src/modules/slack/use-cases/add-slack-reaction.ts → packages/core/src/modules/slack/events/slack-reaction-added.ts

@@ -6,8 +6,8 @@ import { ErrorWithContext } from '@/shared/errors';
 import { retryWithBackoff } from '@/shared/utils/core.utils';
 import { getSlackMessage } from '../services/slack-message.service';
 
-export async function addSlackReaction(
-  data: GetBullJobData<'slack.reaction.add'>
+export async function onSlackReactionAdded(
+  data: GetBullJobData<'slack.reaction.added'>
 ) {
   await ensureMessageExists(data);
 
@@ -40,7 +40,9 @@ export async function addSlackReaction(
   }
 }
 
-async function ensureMessageExists(data: GetBullJobData<'slack.reaction.add'>) {
+async function ensureMessageExists(
+  data: GetBullJobData<'slack.reaction.added'>
+) {
   let waiting = false;
 
   await retryWithBackoff(

packages/core/src/modules/slack/slack.ts

@@ -277,7 +277,8 @@ type AnswerPublicQuestionInput = {
 
 /**
  * Answers a question asked in a public Slack message by linking to relevant
- * threads in our Slack workspace.
+ * threads in our Slack workspace. After the answer has been sent, the bot then
+ * reacts to the original message with the ColorStack logo.
  *
  * @param input - The message (public question) to answer.
  * @returns The result of the answer.
@@ -416,6 +417,12 @@ export async function answerPublicQuestion({
     workspace: 'regular',
   });
 
+  job('slack.reaction.add', {
+    channelId,
+    messageId: threadId,
+    reaction: 'goldicon',
+  });
+
   await db.transaction().execute(async (trx) => {
     await trx
       .updateTable('slackMessages')

packages/core/src/modules/slack/slack.worker.ts

@@ -3,6 +3,7 @@ import { match } from 'ts-pattern';
 import { SlackBullJob } from '@/infrastructure/bull/bull.types';
 import { registerWorker } from '@/infrastructure/bull/use-cases/register-worker';
 import { onSlackUserInvited } from '@/modules/slack/events/slack-user-invited';
+import { slack } from '@/modules/slack/instances';
 import {
   answerChatbotQuestion,
   answerPublicQuestion,
@@ -11,9 +12,9 @@ import {
 } from '@/modules/slack/slack';
 import { updateBirthdatesFromSlack } from '@/modules/slack/use-cases/update-birthdates-from-slack';
 import { onSlackProfilePictureChanged } from './events/slack-profile-picture-changed';
+import { onSlackReactionAdded } from './events/slack-reaction-added';
 import { onSlackWorkspaceJoined } from './events/slack-workspace-joined';
 import { addSlackMessage } from './use-cases/add-slack-message';
-import { addSlackReaction } from './use-cases/add-slack-reaction';
 import { archiveSlackChannel } from './use-cases/archive-slack-channel';
 import { changeSlackMessage } from './use-cases/change-slack-message';
 import { createSlackChannel } from './use-cases/create-slack-channel';
@@ -95,7 +96,14 @@ export const slackWorker = registerWorker(
         return result.data;
       })
       .with({ name: 'slack.reaction.add' }, async ({ data }) => {
-        return addSlackReaction(data);
+        return slack.reactions.add({
+          channel: data.channelId,
+          name: data.reaction,
+          timestamp: data.messageId,
+        });
+      })
+      .with({ name: 'slack.reaction.added' }, async ({ data }) => {
+        return onSlackReactionAdded(data);
       })
       .with({ name: 'slack.reaction.remove' }, async ({ data }) => {
         return removeSlackReaction(data);