@@ -13,7 +13,7 @@ import type {
13
13
Libp2p ,
14
14
PeerIdStr ,
15
15
ProtocolCreateOptions ,
16
- PubSubTopic ,
16
+ PubsubTopic ,
17
17
Unsubscribe
18
18
} from "@waku/interfaces" ;
19
19
import { WakuMessage } from "@waku/proto" ;
@@ -28,7 +28,7 @@ import * as lp from "it-length-prefixed";
28
28
import { pipe } from "it-pipe" ;
29
29
30
30
import { BaseProtocol } from "../base_protocol.js" ;
31
- import { DefaultPubSubTopic } from "../constants.js" ;
31
+ import { DefaultPubsubTopic } from "../constants.js" ;
32
32
33
33
import {
34
34
FilterPushRpc ,
@@ -50,7 +50,7 @@ export const FilterCodecs = {
50
50
51
51
class Subscription {
52
52
private readonly peer : Peer ;
53
- private readonly pubsubTopic : PubSubTopic ;
53
+ private readonly pubsubTopic : PubsubTopic ;
54
54
private newStream : ( peer : Peer ) => Promise < Stream > ;
55
55
56
56
private subscriptionCallbacks : Map <
@@ -59,7 +59,7 @@ class Subscription {
59
59
> ;
60
60
61
61
constructor (
62
- pubsubTopic : PubSubTopic ,
62
+ pubsubTopic : PubsubTopic ,
63
63
remotePeer : Peer ,
64
64
newStream : ( peer : Peer ) => Promise < Stream >
65
65
) {
@@ -256,19 +256,19 @@ class Subscription {
256
256
}
257
257
258
258
class Filter extends BaseProtocol implements IReceiver {
259
- private readonly pubsubTopics : PubSubTopic [ ] = [ ] ;
259
+ private readonly pubsubTopics : PubsubTopic [ ] = [ ] ;
260
260
private activeSubscriptions = new Map < string , Subscription > ( ) ;
261
261
private readonly NUM_PEERS_PROTOCOL = 1 ;
262
262
263
263
private getActiveSubscription (
264
- pubsubTopic : PubSubTopic ,
264
+ pubsubTopic : PubsubTopic ,
265
265
peerIdStr : PeerIdStr
266
266
) : Subscription | undefined {
267
267
return this . activeSubscriptions . get ( `${ pubsubTopic } _${ peerIdStr } ` ) ;
268
268
}
269
269
270
270
private setActiveSubscription (
271
- pubsubTopic : PubSubTopic ,
271
+ pubsubTopic : PubsubTopic ,
272
272
peerIdStr : PeerIdStr ,
273
273
subscription : Subscription
274
274
) : Subscription {
@@ -279,7 +279,7 @@ class Filter extends BaseProtocol implements IReceiver {
279
279
constructor ( libp2p : Libp2p , options ?: ProtocolCreateOptions ) {
280
280
super ( FilterCodecs . SUBSCRIBE , libp2p . components ) ;
281
281
282
- this . pubsubTopics = options ?. pubsubTopics || [ DefaultPubSubTopic ] ;
282
+ this . pubsubTopics = options ?. pubsubTopics || [ DefaultPubsubTopic ] ;
283
283
284
284
libp2p . handle ( FilterCodecs . PUSH , this . onRequest . bind ( this ) ) . catch ( ( e ) => {
285
285
log . error ( "Failed to register " , FilterCodecs . PUSH , e ) ;
@@ -289,7 +289,7 @@ class Filter extends BaseProtocol implements IReceiver {
289
289
}
290
290
291
291
async createSubscription (
292
- pubsubTopic : string = DefaultPubSubTopic
292
+ pubsubTopic : string = DefaultPubsubTopic
293
293
) : Promise < Subscription > {
294
294
ensurePubsubTopicIsConfigured ( pubsubTopic , this . pubsubTopics ) ;
295
295
@@ -367,7 +367,7 @@ class Filter extends BaseProtocol implements IReceiver {
367
367
}
368
368
369
369
if ( ! pubsubTopic ) {
370
- log . error ( "PubSub topic missing from push message" ) ;
370
+ log . error ( "Pubsub topic missing from push message" ) ;
371
371
return ;
372
372
}
373
373
@@ -408,7 +408,7 @@ export function wakuFilter(
408
408
409
409
async function pushMessage < T extends IDecodedMessage > (
410
410
subscriptionCallback : SubscriptionCallback < T > ,
411
- pubsubTopic : PubSubTopic ,
411
+ pubsubTopic : PubsubTopic ,
412
412
message : WakuMessage
413
413
) : Promise < void > {
414
414
const { decoders, callback } = subscriptionCallback ;
0 commit comments