fix with prettier: added trailing comma

waku-org · Aug 7, 2023 · 222ba04 · 222ba04
1 parent 3a6a35f
commit 222ba04
Show file tree

Hide file tree

Showing 86 changed files with 548 additions and 532 deletions.
diff --git a/packages/core/src/lib/base_protocol.ts b/packages/core/src/lib/base_protocol.ts
@@ -17,12 +17,15 @@ export class BaseProtocol implements IBaseProtocol {
   public readonly addLibp2pEventListener: Libp2p["addEventListener"];
   public readonly removeLibp2pEventListener: Libp2p["removeEventListener"];
 
-  constructor(public multicodec: string, private components: Libp2pComponents) {
+  constructor(
+    public multicodec: string,
+    private components: Libp2pComponents,
+  ) {
     this.addLibp2pEventListener = components.events.addEventListener.bind(
-      components.events
+      components.events,
     );
     this.removeLibp2pEventListener = components.events.removeEventListener.bind(
-      components.events
+      components.events,
     );
   }
 
@@ -43,13 +46,13 @@ export class BaseProtocol implements IBaseProtocol {
     const { peer } = await selectPeerForProtocol(
       this.peerStore,
       [this.multicodec],
-      peerId
+      peerId,
     );
     return peer;
   }
   protected async newStream(peer: Peer): Promise<Stream> {
     const connections = this.components.connectionManager.getConnections(
-      peer.id
+      peer.id,
     );
     const connection = selectConnection(connections);
     if (!connection) {

diff --git a/packages/core/src/lib/connection_manager.ts b/packages/core/src/lib/connection_manager.ts
@@ -41,15 +41,15 @@ export class ConnectionManager
     libp2p: Libp2p,
     keepAliveOptions: KeepAliveOptions,
     relay?: IRelay,
-    options?: ConnectionManagerOptions
+    options?: ConnectionManagerOptions,
   ): ConnectionManager {
     let instance = ConnectionManager.instances.get(peerId);
     if (!instance) {
       instance = new ConnectionManager(
         libp2p,
         keepAliveOptions,
         relay,
-        options
+        options,
       );
       ConnectionManager.instances.set(peerId, instance);
     }
@@ -105,7 +105,7 @@ export class ConnectionManager
     libp2p: Libp2p,
     keepAliveOptions: KeepAliveOptions,
     relay?: IRelay,
-    options?: Partial<ConnectionManagerOptions>
+    options?: Partial<ConnectionManagerOptions>,
   ) {
     super();
     this.libp2p = libp2p;
@@ -126,7 +126,7 @@ export class ConnectionManager
     // which means that before the ConnectionManager is initialized, some peers may have been discovered
     // we will dial the peers in peerStore ONCE before we start to listen to the `peer:discovery` events within the ConnectionManager
     this.dialPeerStorePeers().catch((error) =>
-      log(`Unexpected error while dialing peer store peers`, error)
+      log(`Unexpected error while dialing peer store peers`, error),
     );
   }
 
@@ -159,15 +159,15 @@ export class ConnectionManager
     this.keepAliveManager.stopAll();
     this.libp2p.removeEventListener(
       "peer:connect",
-      this.onEventHandlers["peer:connect"]
+      this.onEventHandlers["peer:connect"],
     );
     this.libp2p.removeEventListener(
       "peer:disconnect",
-      this.onEventHandlers["peer:disconnect"]
+      this.onEventHandlers["peer:disconnect"],
     );
     this.libp2p.removeEventListener(
       "peer:discovery",
-      this.onEventHandlers["peer:discovery"]
+      this.onEventHandlers["peer:discovery"],
     );
   }
 
@@ -198,7 +198,7 @@ export class ConnectionManager
           log(
             `Error dialing peer ${peerId.toString()} - ${
               (error as any).message
-            }`
+            }`,
           );
         }
         this.dialErrorsForPeer.set(peerId.toString(), error);
@@ -225,14 +225,14 @@ export class ConnectionManager
         }
 
         log(
-          `Deleting undialable peer ${peerId.toString()} from peer store. Error: ${errorMessage}`
+          `Deleting undialable peer ${peerId.toString()} from peer store. Error: ${errorMessage}`,
         );
 
         this.dialErrorsForPeer.delete(peerId.toString());
         await this.libp2p.peerStore.delete(peerId);
       } catch (error) {
         throw new Error(
-          `Error deleting undialable peer ${peerId.toString()} from peer store - ${error}`
+          `Error deleting undialable peer ${peerId.toString()} from peer store - ${error}`,
         );
       }
     }
@@ -245,7 +245,7 @@ export class ConnectionManager
       log(`Dropped connection with peer ${peerId.toString()}`);
     } catch (error) {
       log(
-        `Error dropping connection with peer ${peerId.toString()} - ${error}`
+        `Error dropping connection with peer ${peerId.toString()} - ${error}`,
       );
     }
   }
@@ -266,14 +266,14 @@ export class ConnectionManager
   private startPeerDiscoveryListener(): void {
     this.libp2p.addEventListener(
       "peer:discovery",
-      this.onEventHandlers["peer:discovery"]
+      this.onEventHandlers["peer:discovery"],
     );
   }
 
   private startPeerConnectionListener(): void {
     this.libp2p.addEventListener(
       "peer:connect",
-      this.onEventHandlers["peer:connect"]
+      this.onEventHandlers["peer:connect"],
     );
   }
 
@@ -292,7 +292,7 @@ export class ConnectionManager
      */
     this.libp2p.addEventListener(
       "peer:disconnect",
-      this.onEventHandlers["peer:disconnect"]
+      this.onEventHandlers["peer:disconnect"],
     );
   }
 
@@ -315,7 +315,7 @@ export class ConnectionManager
         const { id: peerId } = evt.detail;
 
         const isBootstrap = (await this.getTagNamesForPeer(peerId)).includes(
-          Tags.BOOTSTRAP
+          Tags.BOOTSTRAP,
         );
 
         this.dispatchEvent(
@@ -325,8 +325,8 @@ export class ConnectionManager
               : EPeersByDiscoveryEvents.PEER_DISCOVERY_PEER_EXCHANGE,
             {
               detail: peerId,
-            }
-          )
+            },
+          ),
         );
 
         try {
@@ -343,7 +343,7 @@ export class ConnectionManager
         this.keepAliveManager.start(peerId, this.libp2p.services.ping);
 
         const isBootstrap = (await this.getTagNamesForPeer(peerId)).includes(
-          Tags.BOOTSTRAP
+          Tags.BOOTSTRAP,
         );
 
         if (isBootstrap) {
@@ -362,8 +362,8 @@ export class ConnectionManager
                 EPeersByDiscoveryEvents.PEER_CONNECT_BOOTSTRAP,
                 {
                   detail: peerId,
-                }
-              )
+                },
+              ),
             );
           }
         } else {
@@ -372,8 +372,8 @@ export class ConnectionManager
               EPeersByDiscoveryEvents.PEER_CONNECT_PEER_EXCHANGE,
               {
                 detail: peerId,
-              }
-            )
+              },
+            ),
           );
         }
       })();

diff --git a/packages/core/src/lib/filter/filter_rpc.ts b/packages/core/src/lib/filter/filter_rpc.ts
@@ -35,7 +35,7 @@ export class FilterSubscribeRpc {
 
   static createSubscribeRequest(
     pubsubTopic: string,
-    contentTopics: string[]
+    contentTopics: string[],
   ): FilterSubscribeRpc {
     return new FilterSubscribeRpc({
       requestId: uuid(),
@@ -48,7 +48,7 @@ export class FilterSubscribeRpc {
 
   static createUnsubscribeRequest(
     pubsubTopic: string,
-    contentTopics: string[]
+    contentTopics: string[],
   ): FilterSubscribeRpc {
     return new FilterSubscribeRpc({
       requestId: uuid(),