From b11781efcf21ab41e9278117e2bf7c88b6089431 Mon Sep 17 00:00:00 2001 From: Faruk AYDIN Date: Thu, 28 Dec 2023 13:55:28 +0100 Subject: [PATCH] feat: Convert all queues folder to js files --- packages/backend/src/queues/{action.ts => action.js} | 2 +- .../backend/src/queues/{delete-user.ee.ts => delete-user.ee.js} | 2 +- packages/backend/src/queues/{email.ts => email.js} | 2 +- packages/backend/src/queues/{flow.ts => flow.js} | 2 +- ...subscriptions.ee.ts => remove-cancelled-subscriptions.ee.js} | 2 +- packages/backend/src/queues/{trigger.ts => trigger.js} | 2 +- 6 files changed, 6 insertions(+), 6 deletions(-) rename packages/backend/src/queues/{action.ts => action.js} (91%) rename packages/backend/src/queues/{delete-user.ee.ts => delete-user.ee.js} (91%) rename packages/backend/src/queues/{email.ts => email.js} (91%) rename packages/backend/src/queues/{flow.ts => flow.js} (91%) rename packages/backend/src/queues/{remove-cancelled-subscriptions.ee.ts => remove-cancelled-subscriptions.ee.js} (94%) rename packages/backend/src/queues/{trigger.ts => trigger.js} (91%) diff --git a/packages/backend/src/queues/action.ts b/packages/backend/src/queues/action.js similarity index 91% rename from packages/backend/src/queues/action.ts rename to packages/backend/src/queues/action.js index 44d8b023..48173bf9 100644 --- a/packages/backend/src/queues/action.ts +++ b/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/packages/backend/src/queues/delete-user.ee.ts b/packages/backend/src/queues/delete-user.ee.js similarity index 91% rename from packages/backend/src/queues/delete-user.ee.ts rename to packages/backend/src/queues/delete-user.ee.js index d67a59b3..e01c340f 100644 --- a/packages/backend/src/queues/delete-user.ee.ts +++ b/packages/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 b/packages/backend/src/queues/email.js similarity index 91% rename from packages/backend/src/queues/email.ts rename to packages/backend/src/queues/email.js index e8ae8b45..223a97e7 100644 --- a/packages/backend/src/queues/email.ts +++ b/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 b/packages/backend/src/queues/flow.js similarity index 91% rename from packages/backend/src/queues/flow.ts rename to packages/backend/src/queues/flow.js index 92c53e9b..bd977955 100644 --- a/packages/backend/src/queues/flow.ts +++ b/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/packages/backend/src/queues/remove-cancelled-subscriptions.ee.ts b/packages/backend/src/queues/remove-cancelled-subscriptions.ee.js similarity index 94% rename from packages/backend/src/queues/remove-cancelled-subscriptions.ee.ts rename to packages/backend/src/queues/remove-cancelled-subscriptions.ee.js index ec7983b3..d444fd5e 100644 --- a/packages/backend/src/queues/remove-cancelled-subscriptions.ee.ts +++ b/packages/backend/src/queues/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 b/packages/backend/src/queues/trigger.js similarity index 91% rename from packages/backend/src/queues/trigger.ts rename to packages/backend/src/queues/trigger.js index 4535deb1..522c0946 100644 --- a/packages/backend/src/queues/trigger.ts +++ b/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(); }