mirror of
https://github.com/logos-storage/logos-storage-nim.git
synced 2026-06-28 05:19:28 +00:00
Cleanup
This commit is contained in:
parent
b89fa72840
commit
8d8f19c6ad
@ -213,14 +213,6 @@ proc updateAnnounceRecord*(d: Discovery, addrs: openArray[MultiAddress]) =
|
||||
.init(d.key, PeerRecord.init(d.peerId, d.announceAddrs))
|
||||
.expect("Should construct signed record").some
|
||||
|
||||
proc updateDhtRecord*(
|
||||
d: Discovery, addrs: openArray[MultiAddress]
|
||||
) {.deprecated: "use updateRecordsAndSpr instead".} =
|
||||
info "Updating Dht record", addrs = addrs
|
||||
d.dhtRecord = SignedPeerRecord
|
||||
.init(d.key, PeerRecord.init(d.peerId, @addrs))
|
||||
.expect("Should construct signed record").some
|
||||
|
||||
proc start*(d: Discovery) {.async: (raises: []).} =
|
||||
try:
|
||||
d.protocol.open()
|
||||
|
||||
@ -39,12 +39,3 @@ suite "Discovery - SPR record logic":
|
||||
disc.updateAnnounceRecord(@[relayAddr])
|
||||
|
||||
check disc.getSpr() == sprBefore
|
||||
|
||||
test "updateDhtRecord deprecated does not update the SPR":
|
||||
disc.updateRecordsAndSpr(@[directAddr], udpPort)
|
||||
let sprBefore = disc.getSpr()
|
||||
|
||||
let otherUdpAddr = MultiAddress.init("/ip4/9.9.9.9/udp/9999").expect("valid")
|
||||
disc.updateDhtRecord(@[otherUdpAddr])
|
||||
|
||||
check disc.getSpr() == sprBefore
|
||||
|
||||
@ -55,7 +55,7 @@ asyncchecksuite "NatTransport - Address-Dependent Filtering":
|
||||
var bootstrap, thirdNode, natNode: Switch
|
||||
|
||||
setup:
|
||||
let router = NatRouter.new(AddressDependent, dropTimeout = 1.seconds)
|
||||
let router = NatRouter.new(AddressDependent)
|
||||
bootstrap = newSwitch(Rng.instance())
|
||||
thirdNode = newSwitch(Rng.instance())
|
||||
natNode = newNatSwitch(router, Rng.instance())
|
||||
@ -88,7 +88,7 @@ asyncchecksuite "NatTransport - Address-and-Port-Dependent Filtering":
|
||||
var bootstrap, thirdNode, natNode: Switch
|
||||
|
||||
setup:
|
||||
let router = NatRouter.new(AddressAndPortDependent, dropTimeout = 1.seconds)
|
||||
let router = NatRouter.new(AddressAndPortDependent)
|
||||
bootstrap = newSwitch(Rng.instance())
|
||||
thirdNode = newSwitch(Rng.instance())
|
||||
natNode = newNatSwitch(router, Rng.instance())
|
||||
@ -122,7 +122,7 @@ asyncchecksuite "NatTransport - Double NAT":
|
||||
var router: NatRouter
|
||||
|
||||
setup:
|
||||
router = NatRouter.new(DoubleNat, dropTimeout = 1.seconds)
|
||||
router = NatRouter.new(DoubleNat)
|
||||
bootstrap = newSwitch(Rng.instance())
|
||||
natNode = newNatSwitch(router, Rng.instance())
|
||||
await bootstrap.start()
|
||||
@ -146,7 +146,7 @@ asyncchecksuite "NatTransport - Port Mapping":
|
||||
var router: NatRouter
|
||||
|
||||
setup:
|
||||
router = NatRouter.new(AddressAndPortDependent, dropTimeout = 1.seconds)
|
||||
router = NatRouter.new(AddressAndPortDependent)
|
||||
bootstrap = newSwitch(Rng.instance())
|
||||
natNode = newNatSwitch(router, Rng.instance())
|
||||
await bootstrap.start()
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user