waku-org/js-waku
1
0
Fork 0
mirror of https://github.com/waku-org/js-waku.git synced 2025-02-21 08:38:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

rm: unnecesary logs

Browse Source
This commit is contained in:
danisharora099 2022-11-23 12:48:29 +05:30
parent fa1418c565
commit 4884f380f0
No known key found for this signature in database
GPG Key ID: FBD2BF500037F135
1 changed files with 19 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
packages/core/src/lib/waku_peer_exchange/index.ts
View File

@ -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;