[FEATURE]: integrate the events with queues

package.json

@@ -29,7 +29,7 @@
   "homepage": "https://github.com/Behzad-rabiei/tc-discordBot#readme",
   "dependencies": {
     "@sentry/node": "^7.51.2",
-    "@togethercrew.dev/db": "^3.0.24",
+    "@togethercrew.dev/db": "^3.0.28",
     "@togethercrew.dev/tc-messagebroker": "^0.0.44",
     "babel-jest": "^29.5.0",
     "bullmq": "^3.14.0",

src/index.ts

@@ -6,6 +6,7 @@ import { setupRabbitMQHandlers } from './rabbitmq/RabbitMQHandler';
 import { commandService, eventService } from './services';
 import './queue/workers/cronWorker';
 import './queue/workers/channelMessageWorker';
+import './queue/workers/directMessageWorker';
 
 async function app() {
   await connectToMongoDB();

src/rabbitmq/events/sendMessageEvent.ts

@@ -5,6 +5,7 @@ import { createPrivateThreadAndSendMessage } from '../../functions/thread';
 import parentLogger from '../../config/logger';
 import { platformService } from '../../database/services';
 import sendDirectMessage from '../../functions/sendDirectMessage';
+import { addDirectMessage } from '../../queue/queues/directMessage';
 
 const logger = parentLogger.child({ module: `${Event.DISCORD_BOT.SEND_MESSAGE}` });
 
@@ -29,7 +30,7 @@ const notifyUserAboutAnalysisFinish = async (
     const upperTextChannel = rawPositionBasedSortedTextChannels[0];
 
     try {
-        sendDirectMessage({ discordId, message });
+        addDirectMessage(discordId, message)
     } catch (error) {
         // can not send DM to the user
         // Will create a private thread and notify him/her about the status if useFallback is true

src/rabbitmq/events/sendMessageToChannel.ts

@@ -1,6 +1,7 @@
 import { Event, MBConnection } from '@togethercrew.dev/tc-messagebroker';
 import parentLogger from '../../config/logger';
 import { channelService } from '../../services';
+import { addChannelMessage } from '../../queue/queues/channelMessage'
 const logger = parentLogger.child({ module: `${Event.DISCORD_BOT.SEND_MESSAGE}` });
 
 export async function handleSendMessageToChannel(msg: any) {
@@ -13,9 +14,10 @@ export async function handleSendMessageToChannel(msg: any) {
         const channels = saga.data['channels'];
         const message = saga.data['message'];
 
+        // IS THIS CORRECT WAY?
         await saga.next(async () => {
             for await (const channel of channels) {
-                await channelService.sendChannelMessage(channel, message)
+                addChannelMessage(channel, message)
             }
         });