redis host and api key

.gitignore

@@ -1,4 +1,5 @@
 .env
 node_modules/
 package-lock.json
-cert/
+cert/
+dist/

src/app.ts

@@ -21,10 +21,6 @@ app
   .use(bodyParser.json({ limit: "100mb" }))
   .use(queueRoute);
 
-app.get("/", (req: Request, res: Response) => {
-  res.send("Logstash Server Reading");
-});
-
 app.use((err: Error, req: Request, res: Response, next: NextFunction) => {
   handleError(err, res);
 });

src/routes/queue-route.ts

@@ -22,6 +22,10 @@ setInterval(async () => {
 
 router.post("/log", async (req: Request, res: Response) => {
   try {
+    let apiKey = req.headers["x-api-key"];
+    if (apiKey != process.env.API_KEY) {
+      throw new Error("Invalid Api Key");
+    }
     const { logs } = req.body;
     await queue.addBulk(
       logs.map((log: logType) => ({

src/utils/queue-client.ts

@@ -1,2 +1,13 @@
 import { Queue } from "bullmq";
-export default new Queue("logs");
+export default new Queue("logs", {
+  connection: {
+    host: process.env.REDIS_HOST,
+    username: process.env.REDIS_USERNAME,
+    password: process.env.REDIS_PASSWORD,
+    port: process.env.REDIS_PORT ? parseInt(process.env.REDIS_PORT) : undefined,
+    db: process.env.REDIS_DB_INDEX
+      ? parseInt(process.env.REDIS_DB_INDEX)
+      : undefined,
+  },
+  prefix: process.env.QUEUE_PREFIX,
+});