✨ Add redis queue prefix

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@staart/manager",
-  "version": "1.3.43",
+  "version": "1.3.44",
   "main": "index.js",
   "repository": "[email protected]:staart/api.git",
   "author": "Anand Chowdhary <[email protected]>",
@@ -125,5 +125,5 @@
     "setup"
   ],
   "snyk": true,
-  "staart-version": "1.3.43"
+  "staart-version": "1.3.44"
 }

src/config.ts

@@ -48,6 +48,10 @@ export const DB_PASSWORD = process.env.DB_PASSWORD || "";
 export const DB_DATABASE = process.env.DB_DATABASE || "database";
 export const DB_TABLE_PREFIX = process.env.DB_TABLE_PREFIX || "";
 
+// Redis
+export const REDIS_URL = process.env.REDIS_URL || "";
+export const REDIS_QUEUE_PREFIX = process.env.REDIS_QUEUE_PREFIX || "staart-";
+
 // Caching
 export const CACHE_TTL = process.env.CACHE_TTL
   ? parseInt(process.env.CACHE_TTL)

src/helpers/elasticsearch.ts

@@ -1,8 +1,9 @@
 import { elasticSearch } from "@staart/elasticsearch";
 import { redisQueue } from "@staart/redis";
 import { logError } from "@staart/errors";
+import { REDIS_QUEUE_PREFIX } from "../config";
 
-const ELASTIC_QUEUE = "es-records";
+const ELASTIC_QUEUE = `${REDIS_QUEUE_PREFIX}es-records`;
 
 let queueSetup = false;
 const setupQueue = async () => {

src/helpers/mail.ts

@@ -1,4 +1,4 @@
-import { FRONTEND_URL } from "../config";
+import { FRONTEND_URL, REDIS_QUEUE_PREFIX } from "../config";
 import { readFile } from "fs-extra";
 import { join } from "path";
 import i18n from "../i18n";
@@ -7,7 +7,7 @@ import { render } from "@staart/mustache-markdown";
 import { redisQueue } from "@staart/redis";
 import { logError } from "@staart/errors";
 
-const MAIL_QUEUE = "outbound-emails";
+const MAIL_QUEUE = `${REDIS_QUEUE_PREFIX}outbound-emails`;
 
 let queueSetup = false;
 const setupQueue = async () => {

src/helpers/webhooks.ts

@@ -6,11 +6,11 @@ import {
 import { Webhook } from "../interfaces/tables/organization";
 import { createHmac } from "crypto";
 import axios from "axios";
-import { JWT_ISSUER } from "../config";
+import { JWT_ISSUER, REDIS_QUEUE_PREFIX } from "../config";
 import { redisQueue } from "@staart/redis";
 import { logError } from "@staart/errors";
 
-const WEBHOOK_QUEUE = "webhooks";
+const WEBHOOK_QUEUE = `${REDIS_QUEUE_PREFIX}webhooks`;
 
 let queueSetup = false;
 const setupQueue = async () => {