refactor: Move getPrefixWithProcessingPriority to separate function and fix clearRepo

Author: crazy-grizzly

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

@@ -1,11 +1,21 @@
+import { StatementProcessingPriority } from '../../../enums/statementProcessingPriority.enum';
+import { EVENT_NAME } from '../utils/constants';
+import { getPrefixWithProcessingPriority } from '../utils/getPrefixWithProcessingPriority';
 import FacadeConfig from '../utils/redisEvents/FacadeConfig';
 
-const EVENT_NAME = 'statement.new';
-
 export default (config: FacadeConfig) => {
   return async (): Promise<void> => {
     const client = await config.client();
-    const listName = `${config.prefix}:${EVENT_NAME}`;
-    await client.del(listName);
+
+    await Promise.all(
+      Object.values(StatementProcessingPriority).map((statementProcessingPriority) => {
+        const listName = `${getPrefixWithProcessingPriority(
+          config.prefix,
+          statementProcessingPriority,
+        )}:${EVENT_NAME}`;
+
+        return client.del(listName);
+      }),
+    );
   };
 };

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

@@ -1,23 +1,8 @@
-import { StatementProcessingPriority } from '../../../enums/statementProcessingPriority.enum';
+import { CHANNEL_NAME, EVENT_NAME } from '../utils/constants';
+import { getPrefixWithProcessingPriority } from '../utils/getPrefixWithProcessingPriority';
 import FacadeConfig from '../utils/redisEvents/FacadeConfig';
 import Signature from './Signature';
 
-const EVENT_NAME = 'statement.new';
-const CHANNEL_NAME = 'statement.notify';
-
-const getPrefixWithProcessingPriority = (
-  originalPrefix: string,
-  priority: StatementProcessingPriority,
-): string => {
-  switch (priority) {
-    case StatementProcessingPriority.LOW:
-      return `${originalPrefix}_${StatementProcessingPriority.LOW}`;
-    case StatementProcessingPriority.MEDIUM:
-    default:
-      return originalPrefix;
-  }
-};
-
 export default (config: FacadeConfig): Signature => {
   return async ({ statementProperties, priority }) => {
     const client = await config.client();

src/apps/statements/repo/eventsRepo/utils/constants.ts

@@ -0,0 +1,2 @@
+export const EVENT_NAME = 'statement.new';
+export const CHANNEL_NAME = 'statement.notify';

src/apps/statements/repo/eventsRepo/utils/getPrefixWithProcessingPriority.ts

@@ -0,0 +1,14 @@
+import { StatementProcessingPriority } from '../../../enums/statementProcessingPriority.enum';
+
+export const getPrefixWithProcessingPriority = (
+  originalPrefix: string,
+  priority: StatementProcessingPriority,
+): string => {
+  switch (priority) {
+    case StatementProcessingPriority.LOW:
+      return `${originalPrefix}_${StatementProcessingPriority.LOW}`;
+    case StatementProcessingPriority.MEDIUM:
+    default:
+      return originalPrefix;
+  }
+};