Skip to content

Commit 6e28bb2

Browse files
committed
fix: param mismatch after rebasing
1 parent 385a529 commit 6e28bb2

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

pkg/node/node.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -944,7 +944,7 @@ func NewBee(
944944
}
945945
}
946946

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

950950
// 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)