refactor: Bump sqs-producer to 7.0.0 (#161)

Author: mtrezza

lib/SQSEventEmitterMQ.js

@@ -1,6 +1,6 @@
 const events = require('events');
 const { logger } = require('parse-server');
-const SQSProducer = require('sqs-producer');
+const { Producer: SQSProducer } = require('sqs-producer');
 const { Consumer: SQSConsumer } = require('sqs-consumer');
 
 class Publisher {
@@ -18,11 +18,21 @@ class Publisher {
       payload = Object.assign({ id: '0', body: message }, channel ? { groupId: channel } : {});
     }
 
-    this.emitter.send(payload, (err) => {
-      if (err) {
-        logger.error(err);
+    // basic validation to keep error logging synchronous for invalid payloads
+    if (typeof payload === 'object' && !Array.isArray(payload) && payload.body === undefined) {
+      logger.error(new Error("Object messages must have 'body' prop"));
+      return;
+    }
+    try {
+      const result = this.emitter.send(payload);
+      if (result && typeof result.catch === 'function') {
+        result.catch((err) => {
+          logger.error(err);
+        });
       }
-    });
+    } catch (err) {
+      logger.error(err);
+    }
   }
 }