Skip to content

Commit

Permalink
fix eslint error
Browse files Browse the repository at this point in the history
  • Loading branch information
danisharora099 committed Aug 17, 2023
1 parent efef7a2 commit 6a17cc3
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 10 deletions.
2 changes: 1 addition & 1 deletion packages/core/src/lib/filter/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ const log = debug("waku:filter:v2");

const FilterCodec = {
SUBSCRIBE: "/vac/waku/filter-subscribe/2.0.0-beta1",
PUSH: "/vac/waku/filter-push/2.0.0-beta1",
PUSH: "/vac/waku/filter-push/2.0.0-beta1"
};

type SubscriptionCallback<T extends IDecodedMessage> = {
Expand Down
12 changes: 6 additions & 6 deletions packages/core/src/lib/light_push/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ class LightPush extends BaseProtocol implements ILightPush {
log("Failed to send waku light push: message is bigger than 1MB");
return {
recipients,
errors: [SendError.SIZE_TOO_BIG],
errors: [SendError.SIZE_TOO_BIG]
};
}

Expand All @@ -61,7 +61,7 @@ class LightPush extends BaseProtocol implements ILightPush {
log("Failed to encode to protoMessage, aborting push");
return {
recipients,
errors: [SendError.ENCODE_FAILED],
errors: [SendError.ENCODE_FAILED]
};
}

Expand All @@ -73,14 +73,14 @@ class LightPush extends BaseProtocol implements ILightPush {
let error: SendError | undefined;

const stream = await this.newStream(peer);

try {
const res = await pipe(
[query.encode()],
lp.encode,
stream,
lp.decode,
async (source) => await all(source),
async (source) => await all(source)
);
try {
const bytes = new Uint8ArrayList();
Expand Down Expand Up @@ -111,7 +111,7 @@ class LightPush extends BaseProtocol implements ILightPush {

const results = await Promise.allSettled(promises);
const successfulResults = results.filter(
(result) => result.status === "fulfilled",
(result) => result.status === "fulfilled"
) as PromiseFulfilledResult<{
recipients: PeerId[];
error: SendError | undefined;
Expand All @@ -123,7 +123,7 @@ class LightPush extends BaseProtocol implements ILightPush {

return {
recipients,
errors,
errors
};
}
}
Expand Down
4 changes: 2 additions & 2 deletions packages/relay/src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ class Relay implements IRelay {
log("Failed to send waku relay: message is bigger that 1MB");
return {
recipients,
errors: [SendError.SIZE_TOO_BIG],
errors: [SendError.SIZE_TOO_BIG]
};
}

Expand All @@ -114,7 +114,7 @@ class Relay implements IRelay {
log("Failed to encode message, aborting publish");
return {
recipients,
errors: [SendError.ENCODE_FAILED],
errors: [SendError.ENCODE_FAILED]
};
}

Expand Down
2 changes: 1 addition & 1 deletion packages/sdk/src/create.ts
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,7 @@ export function defaultPeerDiscoveries(): ((
) => PeerDiscovery)[] {
const discoveries = [
wakuDnsDiscovery([enrTree["PROD"]], DEFAULT_NODE_REQUIREMENTS),
wakuPeerExchangeDiscovery(),
wakuPeerExchangeDiscovery()
];
return discoveries;
}
Expand Down

0 comments on commit 6a17cc3

Please sign in to comment.