Merge pull request #28 from RnDAO/feature/discord-scheduled-job

Feature/discord scheduled job

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@togethercrew.dev/tc-messagebroker",
-  "version": "0.0.35",
+  "version": "0.0.36",
   "description": "a service that include common things that need in every microservies ",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

src/enums/event.enum.ts

@@ -8,6 +8,8 @@ enum BotEvent {
 // events that will be used in all ANALYTIC microservices
 enum AnalyzerEvent {
   RUN = 'RUN',
+  RUN_ONCE = 'RUN_ONCE',
+  SAVE = 'SAVE',
 }
 
 const ServerEvent = {

src/interfaces/choreography.interface.ts

@@ -3,8 +3,4 @@ import { ITransaction } from './transaction.interface';
 export interface IChoreography {
   name: string;
   transactions: ITransaction[];
-}
-
-export interface IChoreographyDict {
-  [key: string]: IChoreography;
-}
+}

src/saga/choreography.ts

@@ -1,13 +1,20 @@
-import { IChoreography, IChoreographyDict } from '../interfaces/choreography.interface';
-import { DISCORD_UPDATE_CHANNELS_TRANSACTIONS } from './transaction';
+import { IChoreography } from '../interfaces/choreography.interface';
+import { DISCORD_SCHEDULED_JOB_TRANSACTIONS, DISCORD_UPDATE_CHANNELS_TRANSACTIONS } from './transaction';
 
 /* define the DISCORD_UPDATE_CHANNELS choreography  */
 const DISCORD_UPDATE_CHANNELS: IChoreography = {
   name: 'DISCORD_UPDATE_CHANNELS',
   transactions: DISCORD_UPDATE_CHANNELS_TRANSACTIONS,
 };
 
+/* define the DISCORD_SCHEDULED_JOB choreography  */
+const DISCORD_SCHEDULED_JOB: IChoreography = {
+  name: 'DISCORD_SCHEDULED_JOB',
+  transactions: DISCORD_SCHEDULED_JOB_TRANSACTIONS,
+};
+
 /* all available Choreographies, will grow overtime */
-export const ChoreographyDict: IChoreographyDict = {
-  DISCORD_UPDATE_CHANNELS: DISCORD_UPDATE_CHANNELS,
+export const ChoreographyDict = {
+  DISCORD_UPDATE_CHANNELS,
+  DISCORD_SCHEDULED_JOB
 } as const;

src/saga/transaction.ts

@@ -32,3 +32,13 @@ export const DISCORD_UPDATE_CHANNELS_TRANSACTIONS: ITransaction[] = [
   //   ...DEFAULT_TRANSACTION_PROPERTY,
   // },
 ];
+
+export const DISCORD_SCHEDULED_JOB_TRANSACTIONS: ITransaction[] = [
+  {
+    queue: Queue.DISCORD_ANALYZER,
+    event: Event.DISCORD_ANALYZER.RUN_ONCE,
+    order: 1,
+    status: Status.NOT_STARTED,
+    ...DEFAULT_TRANSACTION_PROPERTY,
+  },
+];