fix: add rpc endpoint for logging active resources (#160)

Adds an temporary endpoint to print out all active handles so we
can see what's not being reclaimed.

Dockerfile

@@ -9,7 +9,6 @@ RUN apt-get update && \
 WORKDIR /app
 
 COPY package*.json ./
-COPY patches ./patches
 RUN npm ci --quiet
 
 ENV NODE_ENV production

docker-compose.yaml

@@ -15,12 +15,12 @@ services:
       - 4102:4102
       - 4001:4001
       - 4003:4003
+      - 9229:9229
     environment:
-      - CONFIG_FLAGS=""
+      - NODE_OPTIONS="--inspect=0.0.0.0"
     volumes:
       - ./config.json:/config.json
-    command: node dist/src/index.js --config /config.json --enable-kademlia --enable-autonat
-    network_mode: host
+    command: node --config /config.json --enable-kademlia --enable-autonat --api-host=0.0.0.0
 
   prometheus:
     restart: unless-stopped

package.json

@@ -159,7 +159,8 @@
     "datastore-level": "^11.0.1",
     "libp2p": "^2.1.3",
     "prom-client": "^15.1.3",
-    "uint8arrays": "^5.1.0"
+    "uint8arrays": "^5.1.0",
+    "why-is-node-running": "^2.3.0"
   },
   "devDependencies": {
     "aegir": "^44.1.1",

src/create-rpc-server.ts

@@ -4,6 +4,8 @@ import { createServer } from 'node:http'
 import { decode } from 'node:querystring'
 import { getHeapSnapshot } from 'node:v8'
 import { enable } from '@libp2p/logger'
+// @ts-expect-error no types
+import log from 'why-is-node-running'
 
 export interface RpcServerOptions {
   apiPort?: number
@@ -70,9 +72,17 @@ const resources: Record<string, Record<string, Parameters<typeof createServer>[1
         console.info('Enable logging with namespace', query.namespace)
       }
 
+      // change the logging settings
       enable(query.namespace)
 
-      // change the logging settings
+      res.writeHead(200, { 'Content-Type': 'text/plain' })
+      res.end('OK')
+    }
+  },
+  '/api/v0/nodejs/handles': {
+    GET: (req, res) => {
+      log()
+
       res.writeHead(200, { 'Content-Type': 'text/plain' })
       res.end('OK')
     }

src/index.ts

@@ -232,14 +232,3 @@ await new Promise<void>((resolve) => metricsServer.listen(metricsPort, '0.0.0.0'
 console.info('Metrics server listening', `0.0.0.0:${argMetricsPort}${argMetricsPath}`)
 
 await createRpcServer({ apiPort: parseInt(argApiPort ?? options['api-port'].default, 10), apiHost: argApiHost })
-
-setInterval(() => {
-  // set a breakpoint on the next line if you want to inspect the running node
-  node.peerId.toString()
-
-  for (const conn of node.getConnections()) {
-    if (conn.status === 'closed') {
-      console.info('how did this happen?!')
-    }
-  }
-}, 5000).unref()