@@ -9,10 +9,7 @@ import { SignaturePolicy } from "@chainsafe/libp2p-gossipsub/types";
9
9
import type { Libp2p } from "@libp2p/interface-libp2p" ;
10
10
import type { PubSub } from "@libp2p/interface-pubsub" ;
11
11
import { sha256 } from "@noble/hashes/sha256" ;
12
- import {
13
- DefaultPubSubTopic ,
14
- Relay as RelayConstants ,
15
- } from "@waku/core/constants" ;
12
+ import { DefaultPubSubTopic } from "@waku/core/constants" ;
16
13
import type {
17
14
ActiveSubscriptions ,
18
15
Callback ,
@@ -27,6 +24,7 @@ import type {
27
24
import { groupByContentTopic } from "@waku/utils" ;
28
25
import debug from "debug" ;
29
26
27
+ import { RelayCodecs } from "./constants.js" ;
30
28
import { messageValidator } from "./message_validator.js" ;
31
29
import { TopicOnlyDecoder } from "./topic_only_message.js" ;
32
30
@@ -48,7 +46,7 @@ class Relay implements IRelay {
48
46
private readonly pubSubTopic : string ;
49
47
private defaultDecoder : IDecoder < IDecodedMessage > ;
50
48
51
- public static multicodec : string = RelayConstants . RelayCodecs [ 0 ] ;
49
+ public static multicodec : string = RelayCodecs [ 0 ] ;
52
50
public readonly gossipSub : GossipSub ;
53
51
54
52
/**
@@ -236,7 +234,7 @@ export function wakuGossipSub(
236
234
fallbackToFloodsub : false ,
237
235
} ;
238
236
const pubsub = new GossipSub ( components , init ) ;
239
- pubsub . multicodecs = RelayConstants . RelayCodecs ;
237
+ pubsub . multicodecs = RelayCodecs ;
240
238
return pubsub ;
241
239
} ;
242
240
}
0 commit comments