groot/automatisch
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #1647 from automatisch/error-logger-for-queues

Browse Source 
feat: Add logger for errors happened in queues
This commit is contained in:
Ömer Faruk Aydın
2024-02-23 23:57:00 +01:00
committed by GitHub
parent fcf345abab 00f5964aa4
commit 72d68c4377
6 changed files with 57 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
packages/backend/src/queues/action.js
View File

@@ -15,11 +15,17 @@ process.on('SIGTERM', async () => {
await actionQueue.close(); await actionQueue.close();
}); });
actionQueue.on('error', (err) => { actionQueue.on('error', (error) => {
if (err.code === CONNECTION_REFUSED) { if (error.code === CONNECTION_REFUSED) {
logger.error('Make sure you have installed Redis and it is running.', err); logger.error(
'Make sure you have installed Redis and it is running.',
error
);
process.exit(); process.exit();
} }
logger.error('Error happened in action queue!', error);
}); });
export default actionQueue; export default actionQueue;

12
packages/backend/src/queues/delete-user.ee.js
View File

@@ -15,11 +15,17 @@ process.on('SIGTERM', async () => {
await deleteUserQueue.close(); await deleteUserQueue.close();
}); });
deleteUserQueue.on('error', (err) => { deleteUserQueue.on('error', (error) => {
if (err.code === CONNECTION_REFUSED) { if (error.code === CONNECTION_REFUSED) {
logger.error('Make sure you have installed Redis and it is running.', err); logger.error(
'Make sure you have installed Redis and it is running.',
error
);
process.exit(); process.exit();
} }
logger.error('Error happened in delete user queue!', error);
}); });
export default deleteUserQueue; export default deleteUserQueue;

12
packages/backend/src/queues/email.js
View File

@@ -15,11 +15,17 @@ process.on('SIGTERM', async () => {
await emailQueue.close(); await emailQueue.close();
}); });
emailQueue.on('error', (err) => { emailQueue.on('error', (error) => {
if (err.code === CONNECTION_REFUSED) { if (error.code === CONNECTION_REFUSED) {
logger.error('Make sure you have installed Redis and it is running.', err); logger.error(
'Make sure you have installed Redis and it is running.',
error
);
process.exit(); process.exit();
} }
logger.error('Error happened in email queue!', error);
}); });
export default emailQueue; export default emailQueue;

12
packages/backend/src/queues/flow.js
View File

@@ -15,11 +15,17 @@ process.on('SIGTERM', async () => {
await flowQueue.close(); await flowQueue.close();
}); });
flowQueue.on('error', (err) => { flowQueue.on('error', (error) => {
if (err.code === CONNECTION_REFUSED) { if (error.code === CONNECTION_REFUSED) {
logger.error('Make sure you have installed Redis and it is running.', err); logger.error(
'Make sure you have installed Redis and it is running.',
error
);
process.exit(); process.exit();
} }
logger.error('Error happened in flow queue!', error);
}); });
export default flowQueue; export default flowQueue;

15
packages/backend/src/queues/remove-cancelled-subscriptions.ee.js
View File

@@ -18,11 +18,20 @@ process.on('SIGTERM', async () => {
await removeCancelledSubscriptionsQueue.close(); await removeCancelledSubscriptionsQueue.close();
}); });
removeCancelledSubscriptionsQueue.on('error', (err) => { removeCancelledSubscriptionsQueue.on('error', (error) => {
if (err.code === CONNECTION_REFUSED) { if (error.code === CONNECTION_REFUSED) {
logger.error('Make sure you have installed Redis and it is running.', err); logger.error(
'Make sure you have installed Redis and it is running.',
error
);
process.exit(); process.exit();
} }
logger.error(
'Error happened in remove cancelled subscriptions queue!',
error
);
}); });
removeCancelledSubscriptionsQueue.add('remove-cancelled-subscriptions', null, { removeCancelledSubscriptionsQueue.add('remove-cancelled-subscriptions', null, {

12
packages/backend/src/queues/trigger.js
View File

@@ -15,11 +15,17 @@ process.on('SIGTERM', async () => {
await triggerQueue.close(); await triggerQueue.close();
}); });
triggerQueue.on('error', (err) => { triggerQueue.on('error', (error) => {
if (err.code === CONNECTION_REFUSED) { if (error.code === CONNECTION_REFUSED) {
logger.error('Make sure you have installed Redis and it is running.', err); logger.error(
'Make sure you have installed Redis and it is running.',
error
);
process.exit(); process.exit();
} }
logger.error('Error happened in trigger queue!', error);
}); });
export default triggerQueue; export default triggerQueue;