feat: add profiler server

package.json

@@ -56,7 +56,7 @@
     "@fastify/multipart": "^7.1.0",
     "@fastify/swagger": "^8.3.1",
     "@fastify/type-provider-typebox": "^3.2.0",
-    "@hirosystems/api-toolkit": "^1.4.0",
+    "@hirosystems/api-toolkit": "^1.7.0",
     "@hirosystems/chainhook-client": "^1.8.0",
     "@semantic-release/changelog": "^6.0.3",
     "@semantic-release/commit-analyzer": "^10.0.4",

src/env.ts

@@ -26,6 +26,8 @@ const schema = Type.Object({
   EVENT_SERVER_BODY_LIMIT: Type.Integer({ default: 20971520 }),
   /** Hostname that will be reported to the ordhook node so it can call us back with events */
   EXTERNAL_HOSTNAME: Type.String({ default: '127.0.0.1' }),
+  /** Port in which to serve the profiler */
+  PROFILER_PORT: Type.Number({ default: 9119 }),
 
   /** Hostname of the ordhook node we'll use to register predicates */
   ORDHOOK_NODE_RPC_HOST: Type.String({ default: '127.0.0.1' }),

src/index.ts

@@ -1,4 +1,9 @@
-import { isProdEnv, logger, registerShutdownConfig } from '@hirosystems/api-toolkit';
+import {
+  buildProfilerServer,
+  isProdEnv,
+  logger,
+  registerShutdownConfig,
+} from '@hirosystems/api-toolkit';
 import { buildApiServer, buildPromServer } from './api/init';
 import { startOrdhookServer } from './ordhook/server';
 import { ENV } from './env';
@@ -56,6 +61,16 @@ async function initApp() {
     await initApiService(db);
   }
 
+  const profilerServer = await buildProfilerServer();
+  registerShutdownConfig({
+    name: 'Profiler Server',
+    forceKillable: false,
+    handler: async () => {
+      await profilerServer.close();
+    },
+  });
+  await profilerServer.listen({ host: ENV.API_HOST, port: ENV.PROFILER_PORT });
+
   registerShutdownConfig({
     name: 'DB',
     forceKillable: false,