fix: param mismatch after rebasing

ethersphere · Sep 11, 2024 · 8d8157f · 8d8157f
1 parent 0dd9308
commit 8d8157f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/pkg/node/node.go b/pkg/node/node.go
@@ -937,7 +937,7 @@ func NewBee(
  }
  }
 
- pushSyncProtocol := pushsync.New(swarmAddress, nonce, p2ps, localStore, kad, o.FullNodeMode, pssService.TryUnwrap, gsocService.Handle, validStamp, logger, acc, pricer, signer, tracer, warmupTime)
+ pushSyncProtocol := pushsync.New(swarmAddress, networkID, nonce, p2ps, localStore, waitNetworkRFunc, kad, o.FullNodeMode, pssService.TryUnwrap, gsocService.Handle, validStamp, logger, acc, pricer, signer, tracer, warmupTime)
  b.pushSyncCloser = pushSyncProtocol
 
  // set the pushSyncer in the PSS

diff --git a/pkg/pushsync/pushsync_test.go b/pkg/pushsync/pushsync_test.go
@@ -115,6 +115,10 @@ func TestPushClosest(t *testing.T) {
 // and expects a receipt. The message is intercepted in the outgoing stream to check for correctness.
 func TestSocListener(t *testing.T) {
  t.Parallel()
+ defaultSigner := cryptomock.New(cryptomock.WithSignFunc(func([]byte) ([]byte, error) {
+ return nil, nil
+ }))
+
  // chunk data to upload
  privKey, err := crypto.DecodeSecp256k1PrivateKey(swarm.MustParseHexAddress("b0baf37700000000000000000000000000000000000000000000000000000000").Bytes())
  if err != nil {
@@ -870,7 +874,7 @@ func createPushSyncNodeWithRadius(
 
  radiusFunc := func() (uint8, error) { return radius, nil }
 
- ps := pushsync.New(addr, 1, blockHash.Bytes(), recorderDisconnecter, storer, radiusFunc, mockTopology, true, unwrap, validStamp, log.Noop, accountingmock.NewAccounting(), mockPricer, signer, nil, -1)
+ 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)
  t.Cleanup(func() { ps.Close() })
 
  return ps, storer