feat(API): Add organisation ID to queue jobs that only contain the statement ID (LLC-592) (#716)

Author: PrinceWaune

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

@@ -1,7 +1,7 @@
 import Member from 'jscommons/dist/utils/Member';
 
 export interface Opts {
-  readonly ids: string[];
+  readonly statementProperties: string[];
 }
 
 type Signature = Member<Opts, void>;

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

@@ -5,11 +5,11 @@ const EVENT_NAME = 'statement.new';
 const CHANNEL_NAME = 'statement.notify';
 
 export default (config: FacadeConfig): Signature => {
-  return async ({ ids }) => {
+  return async ({ statementProperties }) => {
     const client = await config.client();
     const listName = `${config.prefix}:${EVENT_NAME}`;
     const channelName = `${config.prefix}:${CHANNEL_NAME}`;
-    await client.rpush(listName, ...ids);
+    await client.rpush(listName, ...statementProperties);
     client.publish(channelName, '');
   };
 };

src/apps/statements/service/storeStatements/index.ts

@@ -54,9 +54,12 @@ export default (config: Config) => {
       return postValidatedModel.statement.id;
     });
 
-    const unstoredStatementIds = unstoredModels.map((unstoredModel) => {
-      return unstoredModel.statement.id;
-    });
+    const unstoredStatementProperties = unstoredModels.map(
+      (unstoredModel) => JSON.stringify({
+        statementId: unstoredModel.statement.id,
+        organisationId: unstoredModel.organisation,
+      }),
+    );
 
     // Completes actions that do not need to be awaited.
     const unawaitedUpdates: Promise<any> = Promise.all([
@@ -71,11 +74,12 @@ export default (config: Config) => {
     });
 
     await awaitUpdates(config, unawaitedUpdates);
-    if (unstoredStatementIds.length !== 0) {
-      config.repo.emitNewStatements({ ids: unstoredStatementIds }).catch((err) => {
-        /* istanbul ignore next */
-        console.error(err); // tslint:disable-line:no-console
-      });
+    if (unstoredStatementProperties.length !== 0) {
+      config.repo.emitNewStatements({ statementProperties: unstoredStatementProperties })
+        .catch((err) => {
+          /* istanbul ignore next */
+          console.error(err); // tslint:disable-line:no-console
+        });
     }
 
     const tracker = await config.tracker;