Merge pull request #52 from TogetherCrew/51-announcement-v2

add ANNOUNCEMENT_SAFETY_MESSAGE
TogetherCrew · Feb 22, 2024 · f881036 · f881036
2 parents 0a2abf3 + 41901b0
commit f881036
Show file tree

Hide file tree

Showing 5 changed files with 19 additions and 6 deletions.
diff --git a/__tests__/unit/choreography.test.ts b/__tests__/unit/choreography.test.ts
@@ -42,7 +42,7 @@ describe('choreography exists', () => {
   describe('ANNOUNCEMENT_SEND_MESSAGE_TO_USER', () => {
     checkChoreography(ChoreographyDict.ANNOUNCEMENT_SEND_MESSAGE_TO_USER, {
       choreographyName: 'ANNOUNCEMENT_SEND_MESSAGE_TO_USER',
-      transactionsLength: 1,
+      transactionsLength: 3,
     });
   });
 

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@togethercrew.dev/tc-messagebroker",
-  "version": "0.0.44",
+  "version": "0.0.45",
   "description": "a service that include common things that need in every microservies ",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

diff --git a/src/enums/event.enum.ts b/src/enums/event.enum.ts
@@ -14,6 +14,7 @@ enum AnalyzerEvent {
 
 const ServerEvent = {
   UPDATE_GUILD: 'UPDATE_GUILD',
+  ANNOUNCEMENT_SAFETY_MESSAGE: 'ANNOUNCEMENT_SAFETY_MESSAGE'
 };
 
 const DiscordBotEvent = {

diff --git a/src/saga/choreography.ts b/src/saga/choreography.ts
@@ -5,7 +5,7 @@ import {
   DISCORD_UPDATE_CHANNELS_TRANSACTIONS,
   TWITTER_REFRESH_TRANSACTIONS,
   ANNOUNCEMENT_SEND_MESSAGE_TO_USER_TRANSACTIONS,
-  ANNOUNCEMENT_SEND_MESSAGE_TO_CHANNEL_TRANSACTIONS
+  ANNOUNCEMENT_SEND_MESSAGE_TO_CHANNEL_TRANSACTIONS,
 } from './transaction';
 
 /* define the DISCORD_UPDATE_CHANNELS choreography  */
@@ -51,6 +51,6 @@ export const ChoreographyDict = {
 
   // Announcement
   ANNOUNCEMENT_SEND_MESSAGE_TO_USER,
-  ANNOUNCEMENT_SEND_MESSAGE_TO_CHANNEL
+  ANNOUNCEMENT_SEND_MESSAGE_TO_CHANNEL,
 
 } as const;
diff --git a/src/saga/transaction.ts b/src/saga/transaction.ts
@@ -86,9 +86,21 @@ export const TWITTER_REFRESH_TRANSACTIONS: ITransaction[] = [
 export const ANNOUNCEMENT_SEND_MESSAGE_TO_USER_TRANSACTIONS: ITransaction[] = [
   {
     queue: Queue.DISCORD_BOT,
-    event: Event.DISCORD_BOT.SEND_MESSAGE,
+    event: Event.DISCORD_BOT.SEND_MESSAGE_TO_CHANNEL,
     order: 1,
     ...DEFAULT_TRANSACTION_PROPERTY,
+  },
+  {
+    queue: Queue.SERVER_API,
+    event: Event.SERVER_API.ANNOUNCEMENT_SAFETY_MESSAGE,
+    order: 2,
+    ...DEFAULT_TRANSACTION_PROPERTY,
+  },
+  {
+    queue: Queue.DISCORD_BOT,
+    event: Event.DISCORD_BOT.SEND_MESSAGE,
+    order: 3,
+    ...DEFAULT_TRANSACTION_PROPERTY,
   }
 ]
 
@@ -99,4 +111,4 @@ export const ANNOUNCEMENT_SEND_MESSAGE_TO_CHANNEL_TRANSACTIONS: ITransaction[] =
     order: 1,
     ...DEFAULT_TRANSACTION_PROPERTY,
   }
-]
+]