fix: tests

Author: alarso16

x/merkledb/proof_test.go

@@ -1193,7 +1193,7 @@ func Test_ChangeProof_Syntactic_Verify(t *testing.T) {
 
 			db, err := getBasicDB()
 			require.NoError(err)
-			err = db.VerifyChangeProof(context.Background(), tt.proof, tt.start, tt.end, ids.Empty, len(tt.proof.KeyChanges))
+			err = db.VerifyChangeProof(context.Background(), tt.proof, tt.start, tt.end, ids.Empty, 10)
 			require.ErrorIs(err, tt.expectedErr)
 		})
 	}

x/sync/manager.go

@@ -147,7 +147,10 @@ type ManagerConfig struct {
 	SimultaneousWorkLimit int
 	Log                   logging.Logger
 	TargetRoot            ids.ID
+	BranchFactor          merkledb.BranchFactor
 	StateSyncNodes        []ids.NodeID
+	// If not specified, [merkledb.DefaultHasher] will be used.
+	Hasher merkledb.Hasher
 }
 
 func NewManager(config ManagerConfig, registerer prometheus.Registerer) (*Manager, error) {
@@ -163,6 +166,13 @@ func NewManager(config ManagerConfig, registerer prometheus.Registerer) (*Manage
 	case config.SimultaneousWorkLimit == 0:
 		return nil, ErrZeroWorkLimit
 	}
+	if err := config.BranchFactor.Valid(); err != nil {
+		return nil, err
+	}
+
+	if config.Hasher == nil {
+		config.Hasher = merkledb.DefaultHasher
+	}
 
 	metrics, err := NewMetrics("sync", registerer)
 	if err != nil {
@@ -174,6 +184,7 @@ func NewManager(config ManagerConfig, registerer prometheus.Registerer) (*Manage
 		doneChan:        make(chan struct{}),
 		unprocessedWork: newWorkHeap(),
 		processedWork:   newWorkHeap(),
+		tokenSize:       merkledb.BranchFactorToTokenSize[config.BranchFactor],
 		metrics:         metrics,
 	}
 	m.unprocessedWorkCond.L = &m.workLock