From 4884f380f07c4598ed706c1006ae89a493e70154 Mon Sep 17 00:00:00 2001
From: danisharora099 <danisharora099@gmail.com>
Date: Wed, 23 Nov 2022 12:48:29 +0530
Subject: [PATCH] rm: unnecesary logs

---
 .../core/src/lib/waku_peer_exchange/index.ts  | 49 +++++++------------
 1 file changed, 19 insertions(+), 30 deletions(-)

diff --git a/packages/core/src/lib/waku_peer_exchange/index.ts b/packages/core/src/lib/waku_peer_exchange/index.ts
index 9bff8a7666..96d1749129 100644
--- a/packages/core/src/lib/waku_peer_exchange/index.ts
+++ b/packages/core/src/lib/waku_peer_exchange/index.ts
@@ -12,6 +12,7 @@ import all from "it-all";
 // import all from "it-all";
 import * as lp from "it-length-prefixed";
 import { pipe } from "it-pipe";
+import { Uint8ArrayList } from "uint8arraylist";
 
 import { selectConnection } from "../select_connection";
 import { getPeersForProtocol, selectPeerForProtocol } from "../select_peer";
@@ -49,38 +50,26 @@ class WakuPeerExchange implements PeerExchange {
 
       const stream = await this.newStream(peer);
 
-      try {
-        const pipeResponse = await pipe(
-          [rpcQuery.encode()],
-          lp.encode(),
-          stream,
-          lp.decode(),
-          async (source) => await all(source)
-        );
-        console.log({ pipeResponse });
-      } catch (error) {
-        console.error(error);
-        throw error;
+      const pipeResponse = await pipe(
+        [rpcQuery.encode()],
+        lp.encode(),
+        stream,
+        lp.decode(),
+        async (source) => await all(source)
+      );
+
+      const bytes = new Uint8ArrayList();
+      pipeResponse.forEach((chunk) => {
+        bytes.append(chunk);
+      });
+
+      const response = PeerExchangeRPC.decode(bytes).response;
+
+      if (!response) {
+        throw new Error("Failed to decode response");
       }
 
-      return { peerInfos: [] };
-
-      // const bytes = new Uint8ArrayList();
-      // // res.forEach((chunk) => {
-      // //   bytes.append(chunk);
-      // // });
-
-      // console.log("bytes");
-
-      // const response = PeerExchangeRPC.decode(bytes).response;
-
-      // console.log({ response });
-
-      // if (!response) {
-      //   throw new Error("Failed to decode response");
-      // }
-
-      // return response;
+      return response;
     } catch (error) {
       console.error({ error });
       throw error;