Add http logger (#32)

* add http logger * fix type
gateweaver · Mar 18, 2024 · 26f5b43 · 26f5b43
1 parent 4bee000
commit 26f5b43
Show file tree

Hide file tree

Showing 4 changed files with 19 additions and 9 deletions.
diff --git a/packages/server/src/middleware/http-logger.middleware.ts b/packages/server/src/middleware/http-logger.middleware.ts
@@ -0,0 +1,7 @@
+import { Request, Response, NextFunction } from "express";
+import { logger } from "../utils";
+
+export const httpLogger = (req: Request, res: Response, next: NextFunction) => {
+ logger.info(`[${req.method}] ${req.originalUrl} - ${res.statusCode}`);
+ next();
+};
diff --git a/packages/server/src/middleware/index.ts b/packages/server/src/middleware/index.ts
@@ -1 +1,2 @@
 export { errorHandler } from "./error-handler.middleware";
+export { httpLogger } from "./http-logger.middleware";
diff --git a/packages/server/src/router/setup/setup-proxy.ts b/packages/server/src/router/setup/setup-proxy.ts
@@ -24,28 +24,28 @@ export const setupProxy = (router: Router, endpoint: Endpoint) => {
  return url;
  };
 
- const onProxyRes = (res: IncomingMessage) => {
- res.headers = {
- ...res.headers,
+ const onProxyRes = (proxyRes: IncomingMessage) => {
+ proxyRes.headers = {
+ ...proxyRes.headers,
  ...endpoint.transformedResponse?.headers,
  };
 
- Object.keys(res.headers).forEach((key) => {
- if (!res.headers[key]) {
- delete res.headers[key];
+ Object.keys(proxyRes.headers).forEach((key) => {
+ if (!proxyRes.headers[key]) {
+ delete proxyRes.headers[key];
  }
  });
 
  if (endpoint.policies?.includes(PolicyOption.RateLimit)) {
- deleteHeaders(res, [
+ deleteHeaders(proxyRes, [
  "X-Ratelimit-Limit",
  "X-Ratelimit-Remaining",
  "X-Ratelimit-Reset",
  ]);
  }
 
  if (endpoint.policies?.includes(PolicyOption.Cors)) {
- deleteHeaders(res, [
+ deleteHeaders(proxyRes, [
  "Access-Control-Allow-Origin",
  "Access-Control-Allow-Credentials",
  "Access-Control-Allow-Methods",

diff --git a/packages/server/src/utils/start-server.ts b/packages/server/src/utils/start-server.ts
@@ -2,7 +2,7 @@ import express from "express";
 import helmet from "helmet";
 import { parseConfig } from "../config/parse-config";
 import { createRouter } from "../router";
-import { errorHandler } from "../middleware";
+import { errorHandler, httpLogger } from "../middleware";
 import { logger } from "./logger";
 
 export const startServer = (filePath: string = "gateweaver") => {
@@ -16,6 +16,8 @@ export const startServer = (filePath: string = "gateweaver") => {
 
  app.use(express.json());
 
+ app.use(httpLogger);
+
  const router = createRouter(config);
  app.use(router);