fix: add socket keepalive

src/index.ts

@@ -49,6 +49,7 @@ export class TCP implements Transport {
 
   async dial (ma: Multiaddr, options: DialOptions): Promise<Connection> {
     const socket = await this._connect(ma, options)
+    socket.setKeepAlive(true)
 
     // Avoid uncaught errors caused by unstable connections
     socket.on('error', err => {

src/listener.ts

@@ -48,6 +48,8 @@ export function createListener (context: Context) {
   let listeningAddr: Multiaddr
 
   const server: ServerWithMultiaddrConnections = Object.assign(net.createServer(socket => {
+    socket.setKeepAlive(true)
+
     // Avoid uncaught errors caused by unstable connections
     socket.on('error', err => {
       log('socket error', err)

src/socket-to-conn.ts

@@ -38,7 +38,20 @@ export const toMultiaddrConnection = (socket: Socket, options?: ToConnectionOpti
     options.localAddr = options.remoteAddr
   }
 
-  const remoteAddr = options.remoteAddr ?? toMultiaddr(socket.remoteAddress ?? '', socket.remotePort ?? '')
+  let remoteAddr: Multiaddr
+
+  if (options.remoteAddr != null) {
+    remoteAddr = options.remoteAddr
+  } else {
+    if (socket.remoteAddress == null || socket.remotePort == null) {
+      // this can be undefined if the socket is destroyed (for example, if the client disconnected)
+      // https://nodejs.org/dist/latest-v16.x/docs/api/net.html#socketremoteaddress
+      throw errCode(new Error('Could not determine remote address or port'), 'ERR_NO_REMOTE_ADDRESS')
+    }
+
+    remoteAddr = toMultiaddr(socket.remoteAddress, socket.remotePort)
+  }
+
   const { host, port } = remoteAddr.toOptions()
   const { sink, source } = toIterable.duplex(socket)