fix: update error logs to use %e token (#3261)

Ensure errors are logged using the %e token across the codebase to get stack traces printed correctly.

Fixes #3161 

---------

Co-authored-by: Alex Potsides <alex@achingbrain.net>

Author: gulshanpr

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)
         }
       }