feat: Add support of ENABLE_QUEUE_PRIORITY env variable to events repo

Author: crazy-grizzly

src/apps/statements/repo/eventsRepo/FactoryConfig.ts

@@ -3,4 +3,5 @@ import RedisFactoryConfig from './utils/redisEvents/FactoryConfig';
 export default interface FactoryConfig {
   readonly facade?: string;
   readonly redis?: RedisFactoryConfig;
+  readonly isQueuePriorityEnabled?: boolean;
 }

src/apps/statements/repo/eventsRepo/clearRepo/redis.ts

@@ -12,6 +12,7 @@ export default (config: FacadeConfig) => {
         const listName = `${getPrefixWithProcessingPriority(
           config.prefix,
           statementProcessingPriority,
+          config.isQueuePriorityEnabled,
         )}:${EVENT_NAME}`;
 
         return client.del(listName);

src/apps/statements/repo/eventsRepo/emitNewStatements/redis.ts

@@ -7,7 +7,11 @@ export default (config: FacadeConfig): Signature => {
   return async ({ statementProperties, priority }) => {
     const client = await config.client();
 
-    const prefixWithPriority = getPrefixWithProcessingPriority(config.prefix, priority);
+    const prefixWithPriority = getPrefixWithProcessingPriority(
+      config.prefix,
+      priority,
+      config.isQueuePriorityEnabled,
+    );
     const listName = `${prefixWithPriority}:${EVENT_NAME}`;
     const channelName = `${prefixWithPriority}:${CHANNEL_NAME}`;
 

src/apps/statements/repo/eventsRepo/utils/redisEvents/FacadeConfig.ts

@@ -3,4 +3,5 @@ import { Redis } from 'ioredis';
 export default interface FacadeConfig {
   readonly client: () => Promise<Redis>;
   readonly prefix: string;
+  readonly isQueuePriorityEnabled: boolean;
 }

src/apps/statements/repo/eventsRepo/utils/redisEvents/FactoryConfig.ts

@@ -3,4 +3,5 @@ import { Redis } from 'ioredis';
 export default interface FactoryConfig {
   readonly client?: () => Promise<Redis>;
   readonly prefix?: string;
+  readonly isQueuePriorityEnabled?: boolean;
 }

src/apps/statements/repo/eventsRepo/utils/redisEvents/factory.ts

@@ -10,6 +10,7 @@ export default (factoryConfig: FactoryConfig = {}): Facade => {
   const facadeConfig: FacadeConfig = {
     client: defaultTo(factoryConfig.client, connectToRedis()),
     prefix: defaultTo(factoryConfig.prefix, 'xapistatements'),
+    isQueuePriorityEnabled: defaultTo(factoryConfig.isQueuePriorityEnabled, false),
   };
   return {
     emitNewStatements: emitNewStatements(facadeConfig),

src/apps/statements/repo/index.ts

@@ -18,6 +18,7 @@ const repo: Repo = factory({
       client: connectToRedis(),
       prefix: config.redis.prefix,
     },
+    isQueuePriorityEnabled: config.isQueuePriorityEnabled,
   },
   models: {
     facade: config.repoFactory.modelsRepoName,

src/config.ts

@@ -27,6 +27,7 @@ const mongoUrl = getStringOption(process.env.MONGO_URL, defaultMongoUrl);
 
 export default {
   defaultTimeout: getNumberOption(process.env.DEFAULT_TIMEOUT_MS, DEFAULT_TIMEOUT_MS),
+  isQueuePriorityEnabled: process.env.ENABLE_QUEUE_PRIORITY === 'true',
   express: {
     allowFormBody: getBooleanOption(process.env.EXPRESS_ALLOW_FORM_BODY, false),
     allowUndefinedMethod: getBooleanOption(process.env.EXPRESS_ALLOW_UNDEFINED_METHOD, false),