Add logs on the scrape clients (#9)

index.js

@@ -115,7 +115,7 @@ class PrometheusDhtBridge extends ReadyResource {
     )
 
     this.aliases.set(alias, entry)
-    this.emit('set-alias', { alias, publicKey: targetPubKey })
+    this.emit('set-alias', { alias, publicKey: targetPubKey, scrapeClient: entry.scrapeClient })
     const updated = true
 
     if (write === true) {

package.json

@@ -41,7 +41,7 @@
   "dependencies": {
     "b4a": "^1.6.6",
     "debounceify": "^1.1.0",
-    "dht-prom-client": "^0.0.1-alpha.3",
+    "dht-prom-client": "^0.0.1-alpha.6",
     "fastify": "^4.28.0",
     "graceful-goodbye": "^1.3.0",
     "hypercore-id-encoding": "^1.3.0",

run.js

@@ -81,8 +81,23 @@ async function main () {
 }
 
 function setupLogging (bridge, logger) {
-  bridge.on('set-alias', ({ alias, publicKey }) => {
+  bridge.on('set-alias', ({ alias, publicKey, scrapeClient }) => {
     logger.info(`Registered alias: ${alias} -> ${idEnc.normalize(publicKey)}`)
+
+    scrapeClient.on('connection-open', ({ uid, targetKey, peerInfo }) => {
+      logger.info(`Scraper for ${alias}->${idEnc.normalize(targetKey)} opened connection from ${idEnc.normalize(peerInfo.publicKey)} (uid: ${uid})`)
+    })
+    scrapeClient.on('connection-ignore', ({ uid }) => {
+      logger.info(`Scraper for ${alias} ignored connection (uid: ${uid})`)
+    })
+    scrapeClient.on('connection-close', ({ uid }) => {
+      logger.info(`Scraper for ${alias} closed connection (uid: ${uid})`)
+    })
+
+    scrapeClient.on('connection-error', ({ error, uid }) => {
+      logger.info(`Scraper for ${alias} connection error (uid: ${uid})`)
+      logger.info(error)
+    })
   })
 
   bridge.on('aliases-updated', (loc) => {

test/integration.js

@@ -17,6 +17,7 @@ const BRIDGE_EXECUTABLE = path.join(path.dirname(__dirname), 'run.js')
 const PROMETHEUS_EXECUTABLE = path.join(path.dirname(__dirname), 'prometheus', 'prometheus')
 
 const DEBUG = false
+const DEBUG_PROMETHEUS = false
 
 // Note: move this inside the test if we ever have >1 integration test
 promClient.collectDefaultMetrics() // So we have something to scrape
@@ -183,7 +184,7 @@ test('Integration test, happy path', async t => {
     let confirmedBridgeOffline = false
 
     promProc.stderr.on('data', d => {
-      if (DEBUG) console.log('PROMETHEUS', d.toString())
+      if (DEBUG_PROMETHEUS) console.log('PROMETHEUS', d.toString())
 
       for (const line of stdoutDec.push(d)) {
         if (line.includes('Server is ready to receive web requests')) {