WIP - Correctly set merkle schema version key

AndrewSisley · Nov 20, 2024 · df0a6c3 · df0a6c3
1 parent 593e947
commit df0a6c3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/db/fetcher/versioned.go b/internal/db/fetcher/versioned.go
@@ -328,7 +328,7 @@ func (vf *VersionedFetcher) merge(c cid.Cid) error {
 	if !exists {
 		mcrdt = merklecrdt.NewMerkleCompositeDAG(
 			vf.store,
-			keys.CollectionSchemaVersionKey{},
+			keys.NewCollectionSchemaVersionKey(block.Delta.GetSchemaVersionID(), vf.col.Description().RootID),
 			vf.dsKey.WithFieldID(core.COMPOSITE_NAMESPACE),
 		)
 		vf.mCRDTs[0] = mcrdt
@@ -355,7 +355,7 @@ func (vf *VersionedFetcher) merge(c cid.Cid) error {
 		if !exists {
 			mcrdt, err = merklecrdt.FieldLevelCRDTWithStore(
 				vf.store,
-				keys.CollectionSchemaVersionKey{},
+				keys.NewCollectionSchemaVersionKey(block.Delta.GetSchemaVersionID(), vf.col.Description().RootID),
 				field.Typ,
 				field.Kind,
 				vf.dsKey.WithFieldID(fmt.Sprint(field.ID)),