Skip to content

Commit

Permalink
fix: remove log
Browse files Browse the repository at this point in the history
  • Loading branch information
marcus-pousette committed Oct 28, 2023
1 parent b6e92fe commit 7768e13
Showing 1 changed file with 0 additions and 22 deletions.
22 changes: 0 additions & 22 deletions packages/transport/stream/src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -1106,32 +1106,12 @@ export abstract class DirectStream<
}

const messageIdString = await sha256Base64(message.messageIdToAcknowledge);
/* if (message.header.to.includes(this.publicKeyHash)) {
console.log(
"GOT ACK",
this.publicKeyHash,
messageIdString,
!!this._ackCallbacks.get(messageIdString)
);
}
*/
const next = this.traces.get(messageIdString);

const nextStream = next ? this.peers.get(next) : undefined;

this._ackCallbacks
.get(messageIdString)
?.callback(message, peerStream, nextStream);

/* console.log("RECEIVED ACK", {
me: this.publicKeyHash, from: publicKey.hashcode(), signer: message.header.signatures?.publicKeys[0].hashcode(), msgAckId: messageIdString, acc: !!
this._ackCallbacks
.get(messageIdString),
next: nextStream,
last: message.header.to.includes(this.publicKeyHash)
},); */

// relay ACK ?
// send exactly backwards same route we got this message
if (!message.header.to.includes(this.publicKeyHash)) {
Expand Down Expand Up @@ -1327,7 +1307,6 @@ export abstract class DirectStream<
this.healthChecks.set(
to,
setTimeout(() => {
console.log("REMOVE TO", to);
this.removeRouteConnection(to, false);
}, SEEK_DELIVERY_TIMEOUT)
);
Expand Down Expand Up @@ -1515,7 +1494,6 @@ export abstract class DirectStream<
message.deliveryMode.redundancy
);

// console.log("FANOUT", from.equals(this.publicKey), fanout)
// update to's

if (fanout) {
Expand Down

0 comments on commit 7768e13

Please sign in to comment.