Add local logging to all microservices; auto-create error_log table on startup

auth_api/index.js

@@ -4,6 +4,11 @@ const jwt = require("jsonwebtoken");
 const db = require("./db");
 require("dotenv").config();
 
+function log(level, message, meta = {}) {
+  const timestamp = new Date().toISOString();
+  console.log(JSON.stringify({ timestamp, level, service: "auth_api", message, ...meta }));
+}
+
 const app = express();
 app.use(express.json());
 

employee_api/index.js

@@ -3,6 +3,11 @@ const bcrypt = require("bcryptjs");
 const db = require("./db");
 require("dotenv").config();
 
+function log(level, message, meta = {}) {
+  const timestamp = new Date().toISOString();
+  console.log(JSON.stringify({ timestamp, level, service: "employee_api", message, ...meta }));
+}
+
 const app = express();
 app.use(express.json());
 

error_log_api/index.js

@@ -5,6 +5,29 @@ require("dotenv").config();
 
 const db = require("./db");
 
+function log(level, message, meta = {}) {
+  const timestamp = new Date().toISOString();
+  console.log(JSON.stringify({ timestamp, level, service: "error_log_api", message, ...meta }));
+}
+
+async function ensureErrorLogTable() {
+  try {
+    await db.query(`CREATE SCHEMA IF NOT EXISTS data`);
+    await db.query(`
+      CREATE TABLE IF NOT EXISTS data.errors (
+        id BIGSERIAL PRIMARY KEY,
+        "date" TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+        "service" TEXT NOT NULL,
+        partofservice TEXT,
+        error TEXT NOT NULL
+      )
+    `);
+    console.log("Error log table ready");
+  } catch (err) {
+    console.error("Failed to create error log table:", err);
+  }
+}
+
 const app = express();
 app.use(express.json({ limit: "64kb" }));
 app.use(cors());
@@ -186,6 +209,9 @@ app.use(async (err, req, res, _next) => {
   return res.status(500).json({ error: toFriendlyError(500) });
 });
 
-app.listen(PORT, () => console.log(`Error Log API listening on ${PORT}`));
+app.listen(PORT, async () => {
+  await ensureErrorLogTable();
+  console.log(`Error Log API listening on ${PORT}`);
+});
 
 module.exports = app;

transit_api/index.js

@@ -5,6 +5,11 @@ require("dotenv").config();
 const db = require("./db");
 const { authMiddleware } = require("./middleware");
 
+function log(level, message, meta = {}) {
+  const timestamp = new Date().toISOString();
+  console.log(JSON.stringify({ timestamp, level, service: "transit_api", message, ...meta }));
+}
+
 const app = express();
 app.use(express.json());
 app.use(cors());