add logger for node

lib/api/fetch.ts

@@ -3,6 +3,7 @@ import type { NextApiRequest } from 'next';
 import type { RequestInit, Response } from 'node-fetch';
 import nodeFetch from 'node-fetch';
 
+import { httpLogger } from 'lib/api/logger';
 import * as cookies from 'lib/cookies';
 
 // first arg can be only a string
@@ -16,6 +17,12 @@ export default function fetchFactory(_req: NextApiRequest) {
     };
     const url = new URL(path, appConfig.apiUrl);
 
+    httpLogger.logger.info({
+      message: 'Trying to call API',
+      url,
+      req: _req,
+    });
+
     return nodeFetch(url.toString(), {
       headers,
       ...init,

lib/api/handler.ts

@@ -2,11 +2,14 @@ import type { NextApiRequest, NextApiResponse } from 'next';
 
 import fetchFactory from 'lib/api/fetch';
 import getUrlWithNetwork from 'lib/api/getUrlWithNetwork';
+import { httpLogger } from 'lib/api/logger';
 
 type Methods = 'GET' | 'POST' | 'PUT' | 'DELETE';
 
 export default function createHandler(getUrl: (_req: NextApiRequest) => string, allowedMethods: Array<Methods>) {
   const handler = async(_req: NextApiRequest, res: NextApiResponse) => {
+    httpLogger(_req, res);
+
     if (!_req.method || !allowedMethods.includes(_req.method as Methods)) {
       res.setHeader('Allow', allowedMethods);
       res.status(405).end(`Method ${ _req.method } Not Allowed`);
@@ -38,6 +41,8 @@ export default function createHandler(getUrl: (_req: NextApiRequest) => string,
       responseError = defaultError;
     }
 
+    httpLogger.logger.error({ err: responseError, url: _req.url });
+
     res.status(500).json(responseError);
   };
 

lib/api/logger.ts

+import pino from 'pino-http';
+
+export const httpLogger = pino();

package.json

@@ -9,7 +9,7 @@
   },
   "scripts": {
     "dev": "next dev",
-    "dev:poa_core": "./node_modules/.bin/dotenv -e ./configs/envs/.env.poa_core -e ./configs/envs/.env.common -e ./configs/envs/.env.secrets next dev",
+    "dev:poa_core": "./node_modules/.bin/dotenv -e ./configs/envs/.env.poa_core -e ./configs/envs/.env.common -e ./configs/envs/.env.secrets next dev | ./node_modules/.bin/pino-pretty",
     "build": "next build",
     "build:vercel": "./node_modules/.bin/dotenv -e ./configs/envs/.env.poa_core -e ./configs/envs/.env.common next build",
     "build:docker": "docker build --build-arg GIT_COMMIT_SHA=$(git rev-parse HEAD) -t blockscout ./",
@@ -41,6 +41,8 @@
     "next": "12.2.5",
     "next-react-svg": "1.1.3",
     "node-fetch": "^3.2.9",
+    "pino-http": "^8.2.1",
+    "pino-pretty": "^9.1.1",
     "react": "18.1.0",
     "react-dom": "18.1.0",
     "react-hook-form": "^7.33.1",

pages/api/account/csrf/index.ts

@@ -2,8 +2,11 @@ import type { NextApiRequest, NextApiResponse } from 'next';
 
 import fetchFactory from 'lib/api/fetch';
 import getUrlWithNetwork from 'lib/api/getUrlWithNetwork';
+import { httpLogger } from 'lib/api/logger';
 
 export default async function csrfHandler(_req: NextApiRequest, res: NextApiResponse) {
+  httpLogger(_req, res);
+
   const url = getUrlWithNetwork(_req, `api/account/v1/get_csrf`);
   const fetch = fetchFactory(_req);
   const response = await fetch(url);
@@ -14,5 +17,8 @@ export default async function csrfHandler(_req: NextApiRequest, res: NextApiResp
     return;
   }
 
-  res.status(500).json({ statusText: response.statusText, status: response.status });
+  const responseError = { statusText: response.statusText, status: response.status };
+  httpLogger.logger.error({ err: responseError, url: _req.url });
+
+  res.status(500).json(responseError);
 }

pages/api/account/watchlist/get-with-tokens.ts

@@ -6,8 +6,11 @@ import type { TWatchlistItem } from 'types/client/account';
 
 import fetchFactory from 'lib/api/fetch';
 import getUrlWithNetwork from 'lib/api/getUrlWithNetwork';
+import { httpLogger } from 'lib/api/logger';
 
 const watchlistWithTokensHandler = async(_req: NextApiRequest, res: NextApiResponse<Array<TWatchlistItem>>) => {
+  httpLogger(_req, res);
+
   const fetch = fetchFactory(_req);
   const url = getUrlWithNetwork(_req, 'api/account/v1/user/watchlist');
   const watchlistResponse = await fetch(url, { method: 'GET' });
@@ -15,6 +18,7 @@ const watchlistWithTokensHandler = async(_req: NextApiRequest, res: NextApiRespo
   const watchlistData = await watchlistResponse.json() as WatchlistAddresses;
 
   if (watchlistResponse.status !== 200) {
+    httpLogger.logger.error({ err: { statusText: 'Watchlist token error', status: 500 }, url: _req.url });
     res.status(500).end(watchlistData || 'Unknown error');
     return;
   }