mirror of https://github.com/waku-org/js-waku.git
chore: remove additional arg
This commit is contained in:
parent
92b506dd86
commit
017e90184f
|
@ -37,7 +37,6 @@ export class FilterCore extends BaseProtocol implements IBaseProtocolCore {
|
|||
wakuMessage: WakuMessage,
|
||||
peerIdStr: string
|
||||
) => Promise<void>,
|
||||
private handleError: (error: Error) => Promise<void>,
|
||||
public readonly pubsubTopics: PubsubTopic[],
|
||||
libp2p: Libp2p
|
||||
) {
|
||||
|
@ -313,7 +312,6 @@ export class FilterCore extends BaseProtocol implements IBaseProtocolCore {
|
|||
"stream ",
|
||||
stream
|
||||
);
|
||||
await this.handleError(e);
|
||||
}
|
||||
);
|
||||
} catch (e) {
|
||||
|
|
|
@ -51,12 +51,9 @@ class Filter extends BaseProtocolSDK implements IFilter {
|
|||
);
|
||||
return;
|
||||
}
|
||||
|
||||
await subscription.processIncomingMessage(wakuMessage, peerIdStr);
|
||||
},
|
||||
async (error: Error) => {
|
||||
log.error("Error with receiving pipe", error);
|
||||
},
|
||||
|
||||
connectionManager.configuredPubsubTopics,
|
||||
libp2p
|
||||
),
|
||||
|
|
|
@ -17,7 +17,7 @@ import {
|
|||
TestShardInfo
|
||||
} from "./utils.js";
|
||||
|
||||
describe("Node Health Status Matrix Tests", function () {
|
||||
describe.only("Node Health Status Matrix Tests", function () {
|
||||
let waku: LightNode;
|
||||
let serviceNodes: ServiceNode[];
|
||||
|
||||
|
|
|
@ -47,7 +47,8 @@ describe("Waku Light Push: Connection Management: E2E", function () {
|
|||
expect(failures?.length || 0).to.equal(0);
|
||||
});
|
||||
|
||||
it("Failed peers are renewed", async function () {
|
||||
// skipped because of https://github.com/waku-org/js-waku/pull/2155#discussion_r1787452696
|
||||
it.skip("Failed peers are renewed", async function () {
|
||||
// send a lightpush request -- should have all successes
|
||||
const response1 = await waku.lightPush.send(
|
||||
encoder,
|
||||
|
|
Loading…
Reference in New Issue