Merge pull request #1515 from automatisch/queues-js

feat: Convert all queues folder to js files
automatisch · Jan 4, 2024 · b693c12 · b693c12
2 parents 7bccbc9 + cbe3db8
commit b693c12
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 6 deletions.
diff --git a/packages/backend/src/queues/action.ts → packages/backend/src/queues/action.js b/packages/backend/src/queues/action.ts → packages/backend/src/queues/action.js
@@ -16,7 +16,7 @@ process.on('SIGTERM', async () => {
 });
 
 actionQueue.on('error', (err) => {
-  if ((err as any).code === CONNECTION_REFUSED) {
+  if (err.code === CONNECTION_REFUSED) {
     logger.error('Make sure you have installed Redis and it is running.', err);
     process.exit();
   }

diff --git a/...ages/backend/src/queues/delete-user.ee.ts → ...ages/backend/src/queues/delete-user.ee.js b/...ages/backend/src/queues/delete-user.ee.ts → ...ages/backend/src/queues/delete-user.ee.js
@@ -16,7 +16,7 @@ process.on('SIGTERM', async () => {
 });
 
 deleteUserQueue.on('error', (err) => {
-  if ((err as any).code === CONNECTION_REFUSED) {
+  if (err.code === CONNECTION_REFUSED) {
     logger.error('Make sure you have installed Redis and it is running.', err);
     process.exit();
   }

diff --git a/packages/backend/src/queues/email.ts → packages/backend/src/queues/email.js b/packages/backend/src/queues/email.ts → packages/backend/src/queues/email.js
@@ -16,7 +16,7 @@ process.on('SIGTERM', async () => {
 });
 
 emailQueue.on('error', (err) => {
-  if ((err as any).code === CONNECTION_REFUSED) {
+  if (err.code === CONNECTION_REFUSED) {
     logger.error('Make sure you have installed Redis and it is running.', err);
     process.exit();
   }

diff --git a/packages/backend/src/queues/flow.ts → packages/backend/src/queues/flow.js b/packages/backend/src/queues/flow.ts → packages/backend/src/queues/flow.js
@@ -16,7 +16,7 @@ process.on('SIGTERM', async () => {
 });
 
 flowQueue.on('error', (err) => {
-  if ((err as any).code === CONNECTION_REFUSED) {
+  if (err.code === CONNECTION_REFUSED) {
     logger.error('Make sure you have installed Redis and it is running.', err);
     process.exit();
   }

diff --git a/...eues/remove-cancelled-subscriptions.ee.ts → ...eues/remove-cancelled-subscriptions.ee.js b/...eues/remove-cancelled-subscriptions.ee.ts → ...eues/remove-cancelled-subscriptions.ee.js
@@ -19,7 +19,7 @@ process.on('SIGTERM', async () => {
 });
 
 removeCancelledSubscriptionsQueue.on('error', (err) => {
-  if ((err as any).code === CONNECTION_REFUSED) {
+  if (err.code === CONNECTION_REFUSED) {
     logger.error('Make sure you have installed Redis and it is running.', err);
     process.exit();
   }

diff --git a/packages/backend/src/queues/trigger.ts → packages/backend/src/queues/trigger.js b/packages/backend/src/queues/trigger.ts → packages/backend/src/queues/trigger.js
@@ -16,7 +16,7 @@ process.on('SIGTERM', async () => {
 });
 
 triggerQueue.on('error', (err) => {
-  if ((err as any).code === CONNECTION_REFUSED) {
+  if (err.code === CONNECTION_REFUSED) {
     logger.error('Make sure you have installed Redis and it is running.', err);
     process.exit();
   }