feat: Implement StateManipulator with cleaner, more efficient conflic…

…t resolution
ceramicnetwork · Sep 11, 2023 · e340e38 · e340e38
1 parent 19d8f41
commit e340e38
Show file tree

Hide file tree

Showing 6 changed files with 905 additions and 12 deletions.
diff --git a/packages/core/src/__tests__/conflict-resolution.test.ts b/packages/core/src/__tests__/conflict-resolution.test.ts
@@ -155,7 +155,7 @@ describe('pickLogToAccept', () => {
       log: [{ cid: cids[4] }, { cid: cids[0], timestamp: 10 }],
     } as unknown as StreamState
 
-    // When anchored in the same blockchain, same block, and with same log lengths, we should choose the one with
+    // When anchored in the same blockchain, same block, and with different log lengths, we should choose the one with
     // longer log length
     expect(await pickLogToAccept(state1, state2)).toEqual(state1)
     expect(await pickLogToAccept(state2, state1)).toEqual(state1)

diff --git a/packages/core/src/ceramic.ts b/packages/core/src/ceramic.ts
@@ -265,7 +265,12 @@ export class Ceramic implements CeramicApi {
     )
     const tipFetcher = new TipFetcher(this.dispatcher.messageBus)
     const logSyncer = new LogSyncer(this.dispatcher)
-    const stateManipulator = new StateManipulator()
+    const stateManipulator = new StateManipulator(
+      this._logger,
+      this._streamHandlers,
+      this.context,
+      logSyncer
+    )
     const streamLoader = new StreamLoader(
       this._logger,
       tipFetcher,