init

Author: simbayippy

api-gateway/.env

@@ -0,0 +1,8 @@
+PORT=8001
+FRONTEND_URL=http://localhost:3000
+
+QUESTION_SERVICE_URL=http://localhost:4001
+AUTH_SERVICE_URL=http://localhost:3001/api/v1
+MATCHING_SERVICE_URL=http://localhost:5001/api/v1
+
+JWT_SECRET="01zWaHku91RQPaP0s68s7Xd1J1hGOn"

api-gateway/combined.log

@@ -0,0 +1,34 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const express_1 = __importDefault(require("express"));
+const cors_1 = __importDefault(require("cors"));
+const routes_1 = __importDefault(require("./routes"));
+const errorHandler_1 = require("./middleware/errorHandler");
+const config_1 = __importDefault(require("./config"));
+const logger_1 = __importDefault(require("./utils/logger"));
+const app = (0, express_1.default)();
+// Middleware
+app.use((0, cors_1.default)(config_1.default.corsOptions));
+app.use(express_1.default.json());
+// Logging middleware
+app.use((req, res, next) => {
+    logger_1.default.info(`Incoming request: ${req.method} ${req.originalUrl}`);
+    next();
+});
+// Routes
+app.use('/api', routes_1.default);
+// Error handling
+app.use(errorHandler_1.errorHandler);
+// Start server
+const startServer = () => {
+    app.listen(config_1.default.port, () => {
+        logger_1.default.info(`API Gateway running on port ${config_1.default.port}`);
+    });
+};
+if (require.main === module) {
+    startServer();
+}
+exports.default = app;

api-gateway/dist/app.js

@@ -0,0 +1,20 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const dotenv_1 = __importDefault(require("dotenv"));
+dotenv_1.default.config();
+exports.default = {
+    port: process.env.PORT || 8001,
+    corsOptions: {
+        origin: process.env.FRONTEND_URL || 'http://localhost:3000',
+        credentials: true,
+    },
+    services: {
+        question: process.env.QUESTION_SERVICE_URL || 'http://localhost:4001',
+        auth: process.env.AUTH_SERVICE_URL || 'http://localhost:3001',
+        matching: process.env.MATCHING_SERVICE_URL || 'http://localhost:5001',
+    },
+    jwtSecret: process.env.JWT_SECRET || 'your-secret-key',
+};

api-gateway/dist/config/index.js

@@ -0,0 +1,24 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.authMiddleware = void 0;
+const jsonwebtoken_1 = __importDefault(require("jsonwebtoken"));
+const config_1 = __importDefault(require("../config"));
+const authMiddleware = (req, res, next) => {
+    var _a;
+    const token = (_a = req.headers.authorization) === null || _a === void 0 ? void 0 : _a.split(' ')[1];
+    if (!token) {
+        return res.status(401).json({ message: 'No token provided' });
+    }
+    try {
+        const decoded = jsonwebtoken_1.default.verify(token, config_1.default.jwtSecret);
+        req.user = decoded;
+        next();
+    }
+    catch (error) {
+        return res.status(401).json({ message: 'Invalid token' });
+    }
+};
+exports.authMiddleware = authMiddleware;

api-gateway/dist/middleware/authMiddleware.js

@@ -0,0 +1,15 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.errorHandler = void 0;
+const logger_1 = __importDefault(require("../utils/logger"));
+const errorHandler = (err, req, res, next) => {
+    logger_1.default.error(err.stack);
+    res.status(500).json({
+        message: 'Internal Server Error',
+        error: process.env.NODE_ENV === 'production' ? {} : err,
+    });
+};
+exports.errorHandler = errorHandler;

api-gateway/dist/middleware/errorHandler.js

@@ -0,0 +1,18 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const express_1 = __importDefault(require("express"));
+const http_proxy_middleware_1 = require("http-proxy-middleware");
+const config_1 = __importDefault(require("../config"));
+const router = express_1.default.Router();
+const authServiceProxy = (0, http_proxy_middleware_1.createProxyMiddleware)({
+    target: config_1.default.services.auth,
+    changeOrigin: true,
+    pathRewrite: {
+        '^/api/auth': '',
+    },
+});
+router.use('/', authServiceProxy);
+exports.default = router;

api-gateway/dist/routes/authRoutes.js

@@ -0,0 +1,14 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const express_1 = __importDefault(require("express"));
+const questionRoutes_1 = __importDefault(require("./questionRoutes"));
+const authRoutes_1 = __importDefault(require("./authRoutes"));
+const matchingRoutes_1 = __importDefault(require("./matchingRoutes"));
+const router = express_1.default.Router();
+router.use('/questions', questionRoutes_1.default);
+router.use('/auth', authRoutes_1.default);
+router.use('/matching', matchingRoutes_1.default);
+exports.default = router;

api-gateway/dist/routes/index.js

@@ -0,0 +1,20 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const express_1 = __importDefault(require("express"));
+const http_proxy_middleware_1 = require("http-proxy-middleware");
+const config_1 = __importDefault(require("../config"));
+const authMiddleware_1 = require("../middleware/authMiddleware");
+const router = express_1.default.Router();
+const matchingServiceProxy = (0, http_proxy_middleware_1.createProxyMiddleware)({
+    target: config_1.default.services.matching,
+    changeOrigin: true,
+    pathRewrite: {
+        '^/api/matching': '',
+    },
+});
+router.use(authMiddleware_1.authMiddleware);
+router.use('/', matchingServiceProxy);
+exports.default = router;

api-gateway/dist/routes/matchingRoutes.js

@@ -0,0 +1,29 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const express_1 = __importDefault(require("express"));
+const http_proxy_middleware_1 = require("http-proxy-middleware");
+const config_1 = __importDefault(require("../config"));
+const logger_1 = __importDefault(require("../utils/logger"));
+const router = express_1.default.Router();
+const questionServiceProxy = (0, http_proxy_middleware_1.createProxyMiddleware)({
+    target: config_1.default.services.question,
+    changeOrigin: true,
+    pathRewrite: {
+        '^/api/questions': '/api/v1/questions',
+    },
+});
+router.use((req, res, next) => {
+    logger_1.default.info(`Question route accessed: ${req.method} ${req.originalUrl}`);
+    next();
+});
+// Log the proxied request path
+router.use((req, res, next) => {
+    logger_1.default.info(`Proxying request to: ${req.url}`);
+    next();
+});
+// router.use(authMiddleware as express.RequestHandler);
+router.use('/api/questions', questionServiceProxy);
+exports.default = router;