fix(Statement Forwards): Corrects payload parsing (#1591)

LearningLocker · Aug 3, 2021 · ac0803e · ac0803e
1 parent 7026a63
commit ac0803e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/worker/src/handlers/statement/listenForRedisPublish.js b/worker/src/handlers/statement/listenForRedisPublish.js
@@ -33,7 +33,7 @@ export default () => {
             latestResult = payload;
             if (payload) {
               logger.debug(`Popped '${pubKey}':`, payload);
-              Statement.findOne({ 'statement.id': payload }, (err, statement) => {
+              Statement.findOne({ 'statement.id': JSON.parse(payload).statementId }, (err, statement) => {
                 // get the statement so that we can find its database id
                 // push it straight into the correct queues
                 statementHandler({ statementId: statement._id });