Revert "Add nitro wallet to BitswapNetwork"

This reverts commit e55ac4e9de.
This commit is contained in:
Mark Spanbroek 2021-04-08 14:51:06 +02:00 committed by markspanbroek
parent 6fbe37eb55
commit 22f4c277dd
4 changed files with 7 additions and 18 deletions

View File

@ -13,7 +13,6 @@ import pkg/chronicles
import pkg/chronos import pkg/chronos
import pkg/libp2p import pkg/libp2p
import pkg/nitro
import ../blocktype as bt import ../blocktype as bt
import ./protobuf/bitswap as pb import ./protobuf/bitswap as pb
@ -21,7 +20,6 @@ import ./protobuf/payments
import ./networkpeer import ./networkpeer
export pb, networkpeer export pb, networkpeer
export nitro
export payments export payments
logScope: logScope:
@ -65,7 +63,6 @@ type
BitswapNetwork* = ref object of LPProtocol BitswapNetwork* = ref object of LPProtocol
peers*: Table[PeerID, NetworkPeer] peers*: Table[PeerID, NetworkPeer]
switch*: Switch switch*: Switch
wallet*: Wallet
handlers*: BitswapHandlers handlers*: BitswapHandlers
request*: BitswapRequest request*: BitswapRequest
getConn: ConnProvider getConn: ConnProvider
@ -322,14 +319,12 @@ method init*(b: BitswapNetwork) =
proc new*( proc new*(
T: type BitswapNetwork, T: type BitswapNetwork,
switch: Switch, switch: Switch,
wallet: Wallet,
connProvider: ConnProvider = nil): T = connProvider: ConnProvider = nil): T =
## Create a new BitswapNetwork instance ## Create a new BitswapNetwork instance
## ##
let b = BitswapNetwork( let b = BitswapNetwork(
switch: switch, switch: switch,
wallet: wallet,
getConn: connProvider) getConn: connProvider)
proc sendWantList( proc sendWantList(

View File

@ -28,7 +28,6 @@ suite "Bitswap engine - 2 nodes":
var var
switch1, switch2: Switch switch1, switch2: Switch
wallet1, wallet2: Wallet
pricing1, pricing2: Pricing pricing1, pricing2: Pricing
network1, network2: BitswapNetwork network1, network2: BitswapNetwork
bitswap1, bitswap2: Bitswap bitswap1, bitswap2: Bitswap
@ -42,8 +41,6 @@ suite "Bitswap engine - 2 nodes":
switch1 = newStandardSwitch() switch1 = newStandardSwitch()
switch2 = newStandardSwitch() switch2 = newStandardSwitch()
wallet1 = Wallet.init(EthPrivateKey.random())
wallet2 = Wallet.init(EthPrivateKey.random())
pricing1 = Pricing.example pricing1 = Pricing.example
pricing2 = Pricing.example pricing2 = Pricing.example
awaiters.add(await switch1.start()) awaiters.add(await switch1.start())
@ -52,11 +49,11 @@ suite "Bitswap engine - 2 nodes":
peerId1 = switch1.peerInfo.peerId peerId1 = switch1.peerInfo.peerId
peerId2 = switch2.peerInfo.peerId peerId2 = switch2.peerInfo.peerId
network1 = BitswapNetwork.new(switch1, wallet1) network1 = BitswapNetwork.new(switch = switch1)
bitswap1 = Bitswap.new(MemoryStore.new(blocks1), network1) bitswap1 = Bitswap.new(MemoryStore.new(blocks1), network1)
switch1.mount(network1) switch1.mount(network1)
network2 = BitswapNetwork.new(switch2, wallet2) network2 = BitswapNetwork.new(switch = switch2)
bitswap2 = Bitswap.new(MemoryStore.new(blocks2), network2) bitswap2 = Bitswap.new(MemoryStore.new(blocks2), network2)
switch2.mount(network2) switch2.mount(network2)

View File

@ -39,7 +39,6 @@ suite "Bitswap network":
buffer = newBufferStream() buffer = newBufferStream()
network = BitswapNetwork.new( network = BitswapNetwork.new(
switch = newStandardSwitch(), switch = newStandardSwitch(),
wallet = Wallet.init(EthPrivateKey.random()),
connProvider = getConn) connProvider = getConn)
network.setupPeer(peerId) network.setupPeer(peerId)
networkPeer = network.peers[peerId] networkPeer = network.peers[peerId]
@ -139,7 +138,6 @@ suite "Bitswap Network - e2e":
var var
switch1, switch2: Switch switch1, switch2: Switch
wallet1, wallet2: Wallet
network1, network2: BitswapNetwork network1, network2: BitswapNetwork
awaiters: seq[Future[void]] awaiters: seq[Future[void]]
done: Future[void] done: Future[void]
@ -148,15 +146,15 @@ suite "Bitswap Network - e2e":
done = newFuture[void]() done = newFuture[void]()
switch1 = newStandardSwitch() switch1 = newStandardSwitch()
switch2 = newStandardSwitch() switch2 = newStandardSwitch()
wallet1 = Wallet.init(EthPrivateKey.random())
wallet2 = Wallet.init(EthPrivateKey.random())
awaiters.add(await switch1.start()) awaiters.add(await switch1.start())
awaiters.add(await switch2.start()) awaiters.add(await switch2.start())
network1 = BitswapNetwork.new(switch1, wallet1) network1 = BitswapNetwork.new(
switch = switch1)
switch1.mount(network1) switch1.mount(network1)
network2 = BitswapNetwork.new(switch2, wallet2) network2 = BitswapNetwork.new(
switch = switch2)
switch2.mount(network2) switch2.mount(network2)
await switch1.connect( await switch1.connect(

View File

@ -17,8 +17,7 @@ proc generateNodes*(
for i in 0..<num: for i in 0..<num:
let let
switch = newStandardSwitch(transportFlags = {ServerFlags.ReuseAddr}) switch = newStandardSwitch(transportFlags = {ServerFlags.ReuseAddr})
wallet = Wallet.init(EthPrivateKey.random()) network = BitswapNetwork.new(switch = switch)
network = BitswapNetwork.new(switch, wallet)
bitswap = Bitswap.new(MemoryStore.new(blocks), network) bitswap = Bitswap.new(MemoryStore.new(blocks), network)
switch.mount(network) switch.mount(network)