Skip to content

Commit e4f74ab

Browse files
authored
refactor: Bump sqs-consumer from 3.8.0 to 12.0.0 (#160)
1 parent 777efc5 commit e4f74ab

File tree

7 files changed

+2310
-390
lines changed

7 files changed

+2310
-390
lines changed

eslint.config.js

Lines changed: 0 additions & 41 deletions
This file was deleted.

eslint.config.mjs

Lines changed: 45 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,45 @@
1+
import js from '@eslint/js';
2+
import globals from 'globals';
3+
4+
export default [
5+
js.configs.recommended,
6+
{
7+
files: ['**/*.js'],
8+
ignores: ['node_modules/**'],
9+
languageOptions: {
10+
ecmaVersion: 2022,
11+
sourceType: 'module',
12+
globals: {
13+
...globals.node,
14+
Parse: 'readonly'
15+
}
16+
},
17+
rules: {
18+
indent: ["error", 2, { SwitchCase: 1 }],
19+
"linebreak-style": ["error", "unix"],
20+
"no-trailing-spaces": "error",
21+
"eol-last": "error",
22+
"space-in-parens": ["error", "never"],
23+
"no-multiple-empty-lines": "warn",
24+
"prefer-const": "error",
25+
"space-infix-ops": "error",
26+
"no-useless-escape": "off",
27+
"require-atomic-updates": "off",
28+
"object-curly-spacing": ["error", "always"],
29+
curly: ["error", "all"],
30+
"block-spacing": ["error", "always"],
31+
"no-unused-vars": "off",
32+
"no-console": "warn"
33+
},
34+
},
35+
{
36+
files: ['spec/**/*.js'],
37+
languageOptions: {
38+
globals: {
39+
...globals.node,
40+
...globals.jasmine,
41+
Parse: 'readonly'
42+
}
43+
}
44+
}
45+
];

lib/SQSEventEmitterMQ.js

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
const events = require('events');
22
const { logger } = require('parse-server');
33
const SQSProducer = require('sqs-producer');
4-
const SQSConsumer = require('sqs-consumer');
4+
const { Consumer: SQSConsumer } = require('sqs-consumer');
55

66
class Publisher {
77
constructor(config) {
@@ -19,7 +19,9 @@ class Publisher {
1919
}
2020

2121
this.emitter.send(payload, (err) => {
22-
if (err) logger.error(err);
22+
if (err) {
23+
logger.error(err);
24+
}
2325
});
2426
}
2527
}
@@ -36,9 +38,8 @@ class Consumer extends events.EventEmitter {
3638
subscribe(channel) {
3739
this.unsubscribe(channel);
3840

39-
const handleMessage = (message, done) => {
41+
const handleMessage = async (message) => {
4042
this.emit('message', channel, message.Body);
41-
done();
4243
};
4344

4445
const createOptions = Object.assign(this.config, { handleMessage });

0 commit comments

Comments
 (0)