Skip to content

Commit 8d8157f

Browse files
committed
fix: param mismatch after rebasing
1 parent 0dd9308 commit 8d8157f

2 files changed

Lines changed: 6 additions & 2 deletions

File tree

pkg/node/node.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -937,7 +937,7 @@ func NewBee(
937937
}
938938
}
939939

940-
pushSyncProtocol := pushsync.New(swarmAddress, nonce, p2ps, localStore, kad, o.FullNodeMode, pssService.TryUnwrap, gsocService.Handle, validStamp, logger, acc, pricer, signer, tracer, warmupTime)
940+
pushSyncProtocol := pushsync.New(swarmAddress, networkID, nonce, p2ps, localStore, waitNetworkRFunc, kad, o.FullNodeMode, pssService.TryUnwrap, gsocService.Handle, validStamp, logger, acc, pricer, signer, tracer, warmupTime)
941941
b.pushSyncCloser = pushSyncProtocol
942942

943943
// set the pushSyncer in the PSS

pkg/pushsync/pushsync_test.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,6 +115,10 @@ func TestPushClosest(t *testing.T) {
115115
// and expects a receipt. The message is intercepted in the outgoing stream to check for correctness.
116116
func TestSocListener(t *testing.T) {
117117
t.Parallel()
118+
defaultSigner := cryptomock.New(cryptomock.WithSignFunc(func([]byte) ([]byte, error) {
119+
return nil, nil
120+
}))
121+
118122
// chunk data to upload
119123
privKey, err := crypto.DecodeSecp256k1PrivateKey(swarm.MustParseHexAddress("b0baf37700000000000000000000000000000000000000000000000000000000").Bytes())
120124
if err != nil {
@@ -870,7 +874,7 @@ func createPushSyncNodeWithRadius(
870874

871875
radiusFunc := func() (uint8, error) { return radius, nil }
872876

873-
ps := pushsync.New(addr, 1, blockHash.Bytes(), recorderDisconnecter, storer, radiusFunc, mockTopology, true, unwrap, validStamp, log.Noop, accountingmock.NewAccounting(), mockPricer, signer, nil, -1)
877+
ps := pushsync.New(addr, 1, blockHash.Bytes(), recorderDisconnecter, storer, radiusFunc, mockTopology, true, unwrap, func(soc.SOC) {}, validStamp, log.Noop, accountingmock.NewAccounting(), mockPricer, signer, nil, -1)
874878
t.Cleanup(func() { ps.Close() })
875879

876880
return ps, storer

0 commit comments

Comments
 (0)