More logs on alias server (#10)

lib/alias-rpc.js

@@ -32,12 +32,18 @@ class AliasRpcServer extends ReadyResource {
     await this.swarm.destroy()
   }
 
-  _onconnection (socket, info) {
+  _onconnection (socket, peerInfo) {
     const uid = crypto.randomUUID()
     const remotePublicKey = socket.remotePublicKey
 
+    this.emit('connection-open', { uid, peerInfo })
+
     socket.on('error', (error) => {
-      this.emit('socket-error', { error, uid, remotePublicKey })
+      this.emit('connection-error', { error, uid, peerInfo })
+    })
+
+    socket.on('close', () => {
+      this.emit('connection-close', { uid, peerInfo })
     })
 
     const rpc = new RPC(socket, { protocol: PROTOCOL_NAME })

package.json

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

run.js

@@ -148,6 +148,28 @@ function setupLogging (bridge, logger) {
       logger.info(`Alias error: ${error} (${uid})`)
     }
   )
+
+  bridge.aliasRpcServer.on(
+    'connection-open',
+    ({ uid, peerInfo }) => {
+      const remotePublicKey = idEnc.normalize(peerInfo.publicKey)
+      logger.info(`Alias server opened connection to ${idEnc.normalize(remotePublicKey)} (uid ${uid})`)
+    }
+  )
+  bridge.aliasRpcServer.on(
+    'connection-close',
+    ({ uid, peerInfo }) => {
+      const remotePublicKey = idEnc.normalize(peerInfo.publicKey)
+      logger.info(`Alias server closed connection to ${idEnc.normalize(remotePublicKey)} (uid ${uid})`)
+    }
+  )
+  bridge.aliasRpcServer.on(
+    'connection-error',
+    ({ uid, error, peerInfo }) => {
+      const remotePublicKey = idEnc.normalize(peerInfo.publicKey)
+      logger.info(`Alias server socket error: ${error.stack} on connection to ${idEnc.normalize(remotePublicKey)} (uid ${uid})`)
+    }
+  )
 }
 
 main()