2020-05-10 14:53:48 +08:00
|
|
|
# compile time options here
|
|
|
|
const
|
|
|
|
libp2p_secure {.strdefine.} = ""
|
|
|
|
|
|
|
|
import
|
2020-05-15 11:35:32 +08:00
|
|
|
options, tables, chronicles,
|
2020-05-10 14:53:48 +08:00
|
|
|
libp2p/[switch, peer, peerinfo, connection, multiaddress, crypto/crypto],
|
|
|
|
libp2p/transports/[transport, tcptransport],
|
|
|
|
libp2p/muxers/[muxer, mplex/mplex, mplex/types],
|
|
|
|
libp2p/protocols/[identify, secure/secure],
|
2020-05-14 10:42:04 +08:00
|
|
|
libp2p/protocols/pubsub/[pubsub, gossipsub, floodsub],
|
|
|
|
../../waku/protocol/v2/waku_protocol
|
2020-05-10 14:53:48 +08:00
|
|
|
|
|
|
|
when libp2p_secure == "noise":
|
|
|
|
import libp2p/protocols/secure/noise
|
|
|
|
else:
|
|
|
|
import libp2p/protocols/secure/secio
|
|
|
|
|
|
|
|
export
|
|
|
|
switch, peer, peerinfo, connection, multiaddress, crypto
|
|
|
|
|
|
|
|
proc newStandardSwitch*(privKey = none(PrivateKey),
|
|
|
|
address = MultiAddress.init("/ip4/127.0.0.1/tcp/0"),
|
|
|
|
triggerSelf = false,
|
|
|
|
gossip = false): Switch =
|
|
|
|
proc createMplex(conn: Connection): Muxer =
|
|
|
|
result = newMplex(conn)
|
|
|
|
|
|
|
|
let
|
|
|
|
seckey = privKey.get(otherwise = PrivateKey.random(ECDSA))
|
|
|
|
peerInfo = PeerInfo.init(seckey, [address])
|
|
|
|
mplexProvider = newMuxerProvider(createMplex, MplexCodec)
|
|
|
|
transports = @[Transport(newTransport(TcpTransport))]
|
|
|
|
muxers = {MplexCodec: mplexProvider}.toTable
|
|
|
|
identify = newIdentify(peerInfo)
|
|
|
|
when libp2p_secure == "noise":
|
|
|
|
let secureManagers = {NoiseCodec: newNoise(seckey).Secure}.toTable
|
|
|
|
else:
|
|
|
|
let secureManagers = {SecioCodec: newSecio(seckey).Secure}.toTable
|
|
|
|
let pubSub = if gossip:
|
|
|
|
PubSub newPubSub(GossipSub, peerInfo, triggerSelf)
|
|
|
|
else:
|
|
|
|
# Creating switch from generate node
|
2020-05-11 12:05:28 +08:00
|
|
|
# XXX: Hacky test, hijacking WakuSub here
|
2020-05-15 11:35:32 +08:00
|
|
|
debug "Using WakuSub here"
|
2020-05-14 11:18:20 +08:00
|
|
|
#PubSub newPubSub(FloodSub, peerInfo, triggerSelf)
|
|
|
|
PubSub newPubSub(WakuSub, peerInfo, triggerSelf)
|
2020-05-10 14:53:48 +08:00
|
|
|
|
|
|
|
result = newSwitch(peerInfo,
|
|
|
|
transports,
|
|
|
|
identify,
|
|
|
|
muxers,
|
|
|
|
secureManagers = secureManagers,
|
|
|
|
pubSub = some(pubSub))
|