refactor: centralize configuration using envConfig for port and server URL

Author: JC-Coder

src/index.ts

@@ -1,9 +1,7 @@
 import app from "./app";
-import axios from "axios"
 import "./services/zeromqService";
+import { ENV_CONFIG } from "./utils/envConfig";
 
-const PORT = process.env.PORT || 4000;
-
-app.listen(PORT, () => {
-  console.log(`Microservice running on port ${PORT}`);
+app.listen(ENV_CONFIG.PORT, () => {
+  console.log(`Microservice running on port ${ENV_CONFIG.PORT}`);
 });

src/routes/integrations.ts

@@ -1,8 +1,9 @@
-import { Router, Request, Response } from "express"; 
+import { Router, Request, Response } from "express";
+import { ENV_CONFIG } from "../utils/envConfig";
 
 const router = Router();
 
-router.get("/integration.json", (req: Request, res: Response) => {
+router.get("/integration-json", (req: Request, res: Response) => {
   const integrationData = {
     data: {
       date: {
@@ -12,9 +13,9 @@ router.get("/integration.json", (req: Request, res: Response) => {
       descriptions: {
         app_description:
           "Analyzes your codebase for static errors and reports them to Telex channels with prioritized error classification.",
-        app_logo: "https://example.com/path-to-code-error-agent-logo.png", 
+        app_logo: "https://example.com/path-to-code-error-agent-logo.png",
         app_name: "Code Error Agent",
-        app_url: "https://code-error-agent-production.up.railway.app/",
+        app_url: ENV_CONFIG.SERVER_URL,
         background_color: "#FF4444",
       },
       integration_category: "AI & Machine Learning",
@@ -53,14 +54,12 @@ router.get("/integration.json", (req: Request, res: Response) => {
           default: "*/15 * * * *",
         },
       ],
-      tick_url:
-        "https://code-error-agent-production.up.railway.app/tick",
-      target_url:
-        "https://code-error-agent-production.up.railway.app/webhook",
+      tick_url: `${ENV_CONFIG.SERVER_URL}/tick`,
+      target_url: `${ENV_CONFIG.SERVER_URL}/webhook`,
     },
   };
 
   res.json(integrationData);
 });
 
-export default router;
+export default router;

src/services/zeromqService.ts

@@ -1,8 +1,7 @@
 import * as zmq from "zeromq";
-import {
-  ProcessedError,
-} from "../controllers/errorController";
+import { ProcessedError } from "../controllers/errorController";
 import axios from "axios";
+import { ENV_CONFIG } from "../utils/envConfig";
 
 const webhookUrl = "https://ping.telex.im/v1/webhooks";
 
@@ -11,9 +10,16 @@ async function initializeServer() {
   const publishSocket = new zmq.Publisher();
 
   try {
-    await replySocket.bind("tcp://code-error-microservice.onrender.com:3030");
-    await publishSocket.bind("tcp://code-error-microservice.onrender.com:3031");
-    console.log("ZeroMQ server bound to ports 3030 (Reply) and 3031 (Publish)");
+    const zeroMqBindHost = "0.0.0.0";
+    const zeroMqBindPortPublish = ENV_CONFIG.PORT + 1;
+    const zeroMqBindPortReply = zeroMqBindPortPublish + 1;
+    await replySocket.bind(`tcp://${zeroMqBindHost}:${zeroMqBindPortReply}`);
+    await publishSocket.bind(
+      `tcp://${zeroMqBindHost}:${zeroMqBindPortPublish}`
+    );
+    console.log(
+      `ZeroMQ server bound to ports ${zeroMqBindPortReply} (Reply) and ${zeroMqBindPortPublish} (Publish)`
+    );
 
     const serverPublish = async (message: string) => {
       await publishSocket.send(["update", message]);
@@ -29,27 +35,35 @@ async function initializeServer() {
       } catch (error) {
         parsedMessage = msg.toString() as unknown as ProcessedError;
         console.error("Failed to parse message:", error);
-        await replySocket.send(JSON.stringify({ status: "error", message: "Invalid message format" }));
+        await replySocket.send(
+          JSON.stringify({ status: "error", message: "Invalid message format" })
+        );
         continue;
       }
       if (!parsedMessage || !parsedMessage.channelId || !parsedMessage.errors) {
         console.warn("Invalid message format");
-        await replySocket.send(JSON.stringify({ status: "error", message: "Invalid message format" }));
+        await replySocket.send(
+          JSON.stringify({ status: "error", message: "Invalid message format" })
+        );
         continue;
       }
 
-      const errorSummary = parsedMessage.errors.map(err => ({
+      const errorSummary = parsedMessage.errors.map((err) => ({
         message: err.message,
-        stack: err.stack
+        stack: err.stack,
       }));
 
       const message = `      
       Errors:
-        ${errorSummary.map((err, index) => `
+        ${errorSummary
+          .map(
+            (err, index) => `
         Error ${index + 1}:
         Message: ${err.message}
         Stack: ${err.stack}
-        `).join('\n')}
+        `
+          )
+          .join("\n")}
         `.trim();
 
       const telexPayload = {
@@ -74,16 +88,20 @@ async function initializeServer() {
         await replySocket.send(JSON.stringify({ status: "success" }));
       } catch (error) {
         console.error("Failed to send to webhook:", error);
-        await replySocket.send(JSON.stringify({ status: "error", message: "Failed to send to webhook" }));
+        await replySocket.send(
+          JSON.stringify({
+            status: "error",
+            message: "Failed to send to webhook",
+          })
+        );
       }
     }
 
     return { serverPublish };
   } catch (error) {
     console.error("ZeroMQ server error:", error);
     throw error;
-  }      
-
+  }
 }
 
-export const zeromqClient = initializeServer();
+export const zeromqClient = initializeServer();

src/utils/envConfig.ts

@@ -0,0 +1,8 @@
+import { config } from "dotenv";
+
+config();
+
+export const ENV_CONFIG = {
+  PORT: Number(process.env.PORT || 4000),
+  SERVER_URL: process.env.SERVER_URL || "http://localhost:4000",
+};