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 8dd2dac commit b6e92fe
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 46 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -251,43 +251,8 @@ describe("index", () => {
})
);
});
/* it("xxxx", async () => {
console.log("----------------------------------------");
const l0axx = await session.peers[0].open(
new TestStore({
publicKey: session.peers[0].peerId
})
);
await TestStore.open(l0axx.address!, session.peers[1]);
await TestStore.open(l0axx.address!, session.peers[2]);
console.log(l0axx.getTopics?.());
console.log("B");
const l0a = await session.peers[0].open(
new TestStore({
publicKey: session.peers[1].peerId
})
);
console.log(l0a.getTopics?.());
const l0b = await TestStore.open(l0a.address!, session.peers[1], {
args: { role: new Observer() }
});
await l0b.store.log.waitForReplicator(
session.peers[0].identity.publicKey
);
}); */

/*
*/

it("any access", async () => {
console.log("A");

const l0a = await session.peers[0].open(
new TestStore({
publicKey: session.peers[0].peerId
Expand Down Expand Up @@ -329,9 +294,6 @@ describe("index", () => {
});

it("read access", async () => {
//
console.log("B");

const l0a = await session.peers[0].open(
new TestStore({
publicKey: session.peers[0].peerId
Expand Down
8 changes: 0 additions & 8 deletions packages/transport/stream/src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -1120,14 +1120,6 @@ export abstract class DirectStream<

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

if (!next && !message.header.to.includes(this.publicKeyHash)) {
console.error(
"????",
message.header.to,
!!this._ackCallbacks.get(messageIdString)
);
}

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

0 comments on commit b6e92fe

Please sign in to comment.