fix: update error logs to use %e token

packages/connection-encrypter-plaintext/src/index.ts

@@ -104,8 +104,8 @@ class Plaintext implements ConnectionEncrypter {
         throw new InvalidCryptoExchangeError('Public key did not match id')
       }
     } catch (err: any) {
-      log.error(err)
-      throw new InvalidCryptoExchangeError('Invalid public key - ' + err.message)
+      log.error('invalid public key - %e', err)
+      throw new InvalidCryptoExchangeError(`Invalid public key - ${err.message}`)
     }
 
     if (options?.remotePeer != null && !peerId.equals(options?.remotePeer)) {

packages/connection-encrypter-tls/src/tls.ts

@@ -179,7 +179,7 @@ export class TLS implements ConnectionEncrypter {
 
               if (streamMuxer == null) {
                 const err = new InvalidCryptoExchangeError(`Selected muxer ${socket.alpnProtocol} did not exist`)
-                log.error(`Selected muxer ${socket.alpnProtocol} did not exist - %e`, err)
+                log.error('selected muxer %s did not exist - %e', socket.alpnProtocol, err)
 
                 connection.abort(err)
                 reject(err)

packages/floodsub/src/floodsub.ts

@@ -341,7 +341,7 @@ export class FloodSub extends TypedEventEmitter<FloodSubEvents> implements Flood
 
           await this.processMessage(peerStream.peerId, msg)
         } catch (err: any) {
-          this.log.error(err)
+          this.log.error('failed to queue messages from %p - %e', peerStream.peerId, err)
         }
       }))
         .catch(err => { this.log(err) })
@@ -466,15 +466,15 @@ export class FloodSub extends TypedEventEmitter<FloodSubEvents> implements Flood
    * Send an rpc object to a peer
    */
   sendRpc (peer: PeerId, rpc: PubSubRPC): void {
-    const peerStream = this.peers.get(peer)
+    const peerStreams = this.peers.get(peer)
 
-    if (peerStream == null) {
-      this.log.error('Cannot send RPC to %p as there are no streams to it available', peer)
+    if (peerStreams == null) {
+      this.log.error('cannot send RPC to %p as there are no streams to it available', peer)
 
       return
     }
 
-    peerStream.write(rpc)
+    peerStreams.write(rpc)
   }
 
   /**

packages/kad-dht/src/content-fetching/index.ts

@@ -106,7 +106,7 @@ export class ContentFetching {
           this.log(`Storing corrected record for key ${dsKey.toString()}`)
           await this.components.datastore.put(dsKey, fixupRec.subarray(), options)
         } catch (err: any) {
-          this.log.error('Failed error correcting self', err)
+          this.log.error('failed error correcting self - %e', err)
         }
 
         continue
@@ -132,7 +132,7 @@ export class ContentFetching {
         throw new QueryError('Could not send correction')
       }
 
-      this.log.error('Failed error correcting entry')
+      this.log.error('failed error correcting entry')
     }
   }
 

packages/kad-dht/src/content-routing/index.ts

@@ -115,7 +115,7 @@ export class ContentRouting {
           yield addProviderEvent
         }
       } catch (err: any) {
-        self.log.error('error sending provide record to peer %p', event.peer.id, err)
+        self.log.error('error sending provide record to peer %p - %e', event.peer.id, err)
         yield queryErrorEvent({
           from: event.peer.id,
           error: err,

packages/kad-dht/src/kad-dht.ts

@@ -298,7 +298,7 @@ export class KadDHT extends TypedEventEmitter<PeerDiscoveryEvents> implements Ka
       const peerData = evt.detail
 
       this.onPeerConnect(peerData).catch(err => {
-        this.log.error('could not add %p to routing table', peerData.id, err)
+        this.log.error('could not add %p to routing table - %e', peerData.id, err)
       })
 
       this.dispatchEvent(new CustomEvent('peer', {
@@ -321,7 +321,7 @@ export class KadDHT extends TypedEventEmitter<PeerDiscoveryEvents> implements Ka
 
         await this.onPeerConnect(peerData)
       }).catch(err => {
-        this.log.error('could not add %p to routing table - %e - %e', peerId, err)
+        this.log.error('could not add %p to routing table - %e', peerId, err)
       })
     })
 
@@ -350,7 +350,7 @@ export class KadDHT extends TypedEventEmitter<PeerDiscoveryEvents> implements Ka
           }
         })
           .catch(err => {
-            this.log.error('error setting dht server mode', err)
+            this.log.error('error setting dht server mode - %e', err)
           })
       })
     }
@@ -407,7 +407,7 @@ export class KadDHT extends TypedEventEmitter<PeerDiscoveryEvents> implements Ka
         signal
       })
     } catch (err: any) {
-      this.log.error('could not add %p to routing table', peerData.id, err)
+      this.log.error('could not add %p to routing table - %e', peerData.id, err)
     }
   }
 

packages/kad-dht/src/network.ts

@@ -186,7 +186,7 @@ export class Network extends TypedEventEmitter<NetworkEvents> implements Startab
 
       stream.close(options)
         .catch(err => {
-          this.log.error('error closing stream to %p', to, err)
+          this.log.error('error closing stream to %p - %e', to, err)
           stream?.abort(err)
         })
 
@@ -252,7 +252,7 @@ export class Network extends TypedEventEmitter<NetworkEvents> implements Startab
 
       stream.close(options)
         .catch(err => {
-          this.log.error('error closing stream to %p', to, err)
+          this.log.error('error closing stream to %p - %e', to, err)
           stream?.abort(err)
         })
 

packages/kad-dht/src/query-self.ts

@@ -76,7 +76,7 @@ export class QuerySelf implements Startable {
     this.timeoutId = setTimeout(() => {
       this.querySelf()
         .catch(err => {
-          this.log.error('error running self-query', err)
+          this.log.error('error running self-query - %e', err)
         })
     }, this.initialInterval)
   }
@@ -146,7 +146,7 @@ export class QuerySelf implements Startable {
           }
         }))
       } catch (err: any) {
-        this.log.error('self-query error', err)
+        this.log.error('self-query error - %e', err)
       } finally {
         signal.clear()
 
@@ -167,7 +167,7 @@ export class QuerySelf implements Startable {
     this.timeoutId = setTimeout(() => {
       this.querySelf()
         .catch(err => {
-          this.log.error('error running self-query', err)
+          this.log.error('error running self-query - %e', err)
         })
     }, this.interval)
   }

packages/kad-dht/src/query/manager.ts

@@ -217,7 +217,7 @@ export class QueryManager implements Startable {
       // Execute the query along each disjoint path and yield their results as they become available
       for await (const event of merge(...paths)) {
         if (event.name === 'QUERY_ERROR') {
-          log.error('query error', event.error)
+          log.error('query error - %e', event.error)
         }
 
         if (event.name === 'PEER_RESPONSE') {

packages/kad-dht/src/reprovider.ts

@@ -152,7 +152,7 @@ export class Reprovider extends TypedEventEmitter<ReprovideEvents> {
               })
           }
         } catch (err: any) {
-          this.log.error('error processing datastore key %s - %e', entry.key, err.message)
+          this.log.error('error processing datastore key %s - %s', entry.key, err.message)
         }
       }
 

packages/kad-dht/src/routing-table/refresh.ts

@@ -107,24 +107,24 @@ export class RoutingTableRefresh {
               try {
                 await this._refreshCommonPrefixLength(n, lastRefresh, force, options)
               } catch (err: any) {
-                this.log.error(err)
+                this.log.error('failed to refresh entries with common prefix length %d - %e', n, err)
               }
             }
           }
         } catch (err: any) {
-          this.log.error(err)
+          this.log.error('failed to refresh entries with common prefix length - %e', err)
         }
       })
     ).catch(err => {
-      this.log.error(err)
+      this.log.error('failed to refresh table - %e', err)
     }).then(() => {
       this.refreshTimeoutId = setTimeout(this.refreshTable, this.refreshInterval)
 
       if (this.refreshTimeoutId.unref != null) {
         this.refreshTimeoutId.unref()
       }
     }).catch(err => {
-      this.log.error(err)
+      this.log.error('failed to set refresh timeout - %e', err)
     })
   }
 

packages/kad-dht/src/rpc/handlers/put-value.ts

@@ -39,10 +39,8 @@ export class PutValueHandler implements DHTMessageHandler {
     this.log('%p asked us to store value for key %b', peerId, key)
 
     if (msg.record == null) {
-      const errMsg = `Empty record from: ${peerId.toString()}`
-
-      this.log.error(errMsg)
-      throw new InvalidMessageError(errMsg)
+      this.log.error('empty record from %p', peerId)
+      throw new InvalidMessageError(`Empty record from: ${peerId}`)
     }
 
     try {

packages/keychain/src/keychain.ts

@@ -175,7 +175,7 @@ export class Keychain implements KeychainInterface {
       return JSON.parse(uint8ArrayToString(res))
     } catch (err: any) {
       await randomDelay()
-      this.log.error(err)
+      this.log.error('could not read key from datastore - %e', err)
       throw new NotFoundError(`Key '${name}' does not exist.`)
     }
   }

packages/libp2p-daemon-client/src/index.ts

@@ -256,11 +256,11 @@ class Client implements DaemonClient {
       .finally(() => {
         connection.close()
           .catch(err => {
-            log.error(err)
+            log.error('error closing connection - %e', err)
           })
         listener.close()
           .catch(err => {
-            log.error(err)
+            log.error('error closing listener - %e', err)
           })
       })
   }

packages/libp2p-daemon-server/src/dht.ts

@@ -30,7 +30,7 @@ export class DHTOperations {
       await drain(this.dht.provide(cid))
       yield OkResponse()
     } catch (err: any) {
-      log.error(err)
+      log.error('failed to provide CID %s - %e', cid, err)
       yield ErrorResponse(err)
     }
   }
@@ -73,7 +73,7 @@ export class DHTOperations {
         }
       }
     } catch (err: any) {
-      log.error(err)
+      log.error('error getting value for key %b - %e', key, err)
       yield ErrorResponse(err)
     }
   }
@@ -84,7 +84,7 @@ export class DHTOperations {
 
       yield OkResponse()
     } catch (err: any) {
-      log.error(err)
+      log.error('error putting value %b for key %b - %e', value, key, err)
       yield ErrorResponse(err)
     }
   }
@@ -107,7 +107,7 @@ export class DHTOperations {
 
       throw new Error('Peer not found')
     } catch (err: any) {
-      log.error(err)
+      log.error('peer not found %p - %e', peerId, err)
       yield ErrorResponse(err)
     }
   }

packages/libp2p-daemon-server/src/index.ts

@@ -179,7 +179,7 @@ export class Server implements Libp2pServer {
           stream
         )
       } catch (err: any) {
-        log.error(err)
+        log.error('error handling stream handler - %e', err)
 
         conn?.abort(err)
       } finally {
@@ -206,7 +206,7 @@ export class Server implements Libp2pServer {
 
   _onExit (): void {
     void this.stop({ exit: true }).catch(err => {
-      log.error(err)
+      log.error('failed to stop daemon during exit - %e', err)
     })
   }
 
@@ -262,7 +262,7 @@ export class Server implements Libp2pServer {
           throw new Error('ERR_INVALID_REQUEST_TYPE')
       }
     } catch (err: any) {
-      log.error(err)
+      log.error('error handling peerstore request - %e', err)
       yield ErrorResponse(err)
     }
   }
@@ -305,7 +305,7 @@ export class Server implements Libp2pServer {
           throw new Error('ERR_INVALID_REQUEST_TYPE')
       }
     } catch (err: any) {
-      log.error(err)
+      log.error('error handling pubsub request - %e', err)
       yield ErrorResponse(err)
     }
   }
@@ -373,7 +373,7 @@ export class Server implements Libp2pServer {
           throw new Error('ERR_INVALID_REQUEST_TYPE')
       }
     } catch (err: any) {
-      log.error(err)
+      log.error('error handling DHT request - %e', err)
       yield ErrorResponse(err)
     }
   }
@@ -521,7 +521,7 @@ export class Server implements Libp2pServer {
             throw new Error('ERR_INVALID_REQUEST_TYPE')
         }
       } catch (err: any) {
-        log.error(err)
+        log.error('error handling incoming connection - %e', err)
 
         // recreate pb stream in case the original was unwrapped already
         const conn = pb.unwrap()
@@ -547,7 +547,7 @@ export class Server implements Libp2pServer {
       }
     })
       .catch(err => {
-        log.error('error handling incoming connection', err)
+        log.error('error handling incoming connection - %e', err)
       })
   }
 }

packages/libp2p-daemon-server/src/pubsub.ts

@@ -34,7 +34,7 @@ export class PubSubOperations {
         }
       })
     } catch (err: any) {
-      log.error(err)
+      log.error('failed to get pubsub topics - %e', err)
       yield ErrorResponse(err)
     }
   }
@@ -71,7 +71,7 @@ export class PubSubOperations {
       yield OkResponse()
       yield * onMessage
     } catch (err: any) {
-      log.error(err)
+      log.error('failed to subscribe to topic %s - %e', topic, err)
       yield ErrorResponse(err)
     }
   }
@@ -81,7 +81,7 @@ export class PubSubOperations {
       await this.pubsub.publish(topic, data)
       yield OkResponse()
     } catch (err: any) {
-      log.error(err)
+      log.error('failed to publish message to topic %s - %e', topic, err)
       yield ErrorResponse(err)
     }
   }
@@ -95,7 +95,7 @@ export class PubSubOperations {
         }
       })
     } catch (err: any) {
-      log.error(err)
+      log.error('failed to list peers for topic %s - %e', topic, err)
       yield ErrorResponse(err)
     }
   }

packages/libp2p/src/address-manager/index.ts

@@ -186,7 +186,7 @@ export class AddressManager implements AddressManagerInterface {
       multiaddrs: addrs
     })
       .catch(err => {
-        this.log.error('error updating addresses', err)
+        this.log.error('error updating addresses - %e', err)
       })
   }