chore: enable anchoring on recon mode

packages/core/src/anchor/__tests__/anchor-processing-loop.test.ts

@@ -152,7 +152,7 @@ test('Dont process the same entry multiple times concurrently', async () => {
   async function* overEntries(): AsyncGenerator<number> {
     do {
       // Need this sleep or else the Node runtime might never switch back to the "process" function.
-      await CommonTestUtils.delay(1)
+      await CommonTestUtils.delay(5)
       for (const e of entries) yield e
     } while (true)
   }

packages/core/src/index.ts

@@ -4,5 +4,6 @@ export * from './store/ikv-store.js'
 export * from './ceramic.js'
 export * from './pubsub/pubsub-message.js'
 export * from './utils.js'
+export * from './recon.js'
 
 export { ProvidersCache } from './providers-cache.js'

packages/core/src/recon.ts

@@ -124,7 +124,6 @@ export class ReconApi extends Observable<ReconEventFeedResponse> implements IRec
     if (!this.enabled) {
       throw new Error(`Recon: disabled, not registering interest in model ${model.toString()}`)
     }
-
     try {
       await this.#sendRequest(this.#url + `/ceramic/interests/model/${model.toString()}`, {
         method: 'POST',
@@ -195,7 +194,7 @@ export class ReconApi extends Observable<ReconEventFeedResponse> implements IRec
     return of({ events: [], cursor: initialCursor, first: true }).pipe(
       // projects the starting event to an Observable that emits the next events. Then it recursively projects each event to an Observable that emits the next event
       expand((prev) => {
-        // creates an observable that emits the next event after a ceratin delay (pollInterval) unless this is the first event
+        // creates an observable that emits the next event after a certain delay (pollInterval) unless this is the first event
         return timer(prev.first ? 0 : this.#pollInterval).pipe(
           // concat map is used to ensure that the next event is only emitted after the previous event has been processed
           concatMap(() =>

packages/core/src/state-management/repository.ts

@@ -647,11 +647,6 @@ export class Repository {
       return
     }
 
-    if (process.env.CERAMIC_RECON_MODE) {
-      // TODO(WS1-1471): Enable anchoring when in Recon (Prime) mode.
-      return
-    }
-
     const carFile = await this.#deps.anchorRequestCarBuilder.build(state$.id, state$.tip)
     const anchorEvent = await this.anchorService.requestAnchor(carFile)
     // Don't wait on handling the anchor event, let that happen in the background.

packages/stream-tests/src/__tests__/deterministic-model-instance-document.test.ts

@@ -125,10 +125,7 @@ describe('ModelInstanceDocument API http-client tests', () => {
     expect(doc.state.log.length).toEqual(2)
     expect(doc.state.log[0].type).toEqual(EventType.INIT)
     expect(doc.state.log[1].type).toEqual(EventType.DATA)
-    if (!process.env.CERAMIC_RECON_MODE) {
-      // TODO (WS1-1471): Re-enable this check even in Recon mode
-      expect(doc.state.anchorStatus).toEqual(AnchorStatus.PENDING)
-    }
+    expect(doc.state.anchorStatus).toEqual(AnchorStatus.PENDING)
   })
 
   test(`Can create deterministic doc with create method`, async () => {
@@ -141,10 +138,7 @@ describe('ModelInstanceDocument API http-client tests', () => {
     expect(doc.state.log.length).toEqual(2)
     expect(doc.state.log[0].type).toEqual(EventType.INIT)
     expect(doc.state.log[1].type).toEqual(EventType.DATA)
-    if (!process.env.CERAMIC_RECON_MODE) {
-      // TODO (WS1-1471): Re-enable this check even in Recon mode
-      expect(doc.state.anchorStatus).toEqual(AnchorStatus.PENDING)
-    }
+    expect(doc.state.anchorStatus).toEqual(AnchorStatus.PENDING)
   })
 
   test(`Creating doc with SINGLE accountRelation non-deterministically should fail `, async () => {
@@ -260,10 +254,8 @@ describe('ModelInstanceDocument API multi-node tests', () => {
 
     const docState = doc.state
     const loadedState = loaded.state
-    // TODO(WS1-1471): Enable anchoring when in Recon (Prime) mode.
-    expect(docState.anchorStatus).toEqual(
-      process.env.CERAMIC_RECON_MODE ? AnchorStatus.NOT_REQUESTED : AnchorStatus.PENDING
-    )
+
+    expect(docState.anchorStatus).toEqual(AnchorStatus.PENDING)
     expect(loadedState.anchorStatus).toEqual(AnchorStatus.NOT_REQUESTED)
     delete docState.anchorStatus
     delete loadedState.anchorStatus
@@ -281,10 +273,8 @@ describe('ModelInstanceDocument API multi-node tests', () => {
 
     const docState = doc.state
     const loadedState = loaded.state
-    // TODO(WS1-1471): Enable anchoring when in Recon (Prime) mode.
-    expect(docState.anchorStatus).toEqual(
-      process.env.CERAMIC_RECON_MODE ? AnchorStatus.NOT_REQUESTED : AnchorStatus.PENDING
-    )
+
+    expect(docState.anchorStatus).toEqual(AnchorStatus.PENDING)
     expect(loadedState.anchorStatus).toEqual(AnchorStatus.NOT_REQUESTED)
     delete docState.anchorStatus
     delete loadedState.anchorStatus

packages/stream-tests/src/__tests__/model-instance-document.test.ts

@@ -1,6 +1,6 @@
 import { jest, test, expect, describe, beforeAll, afterAll } from '@jest/globals'
 import getPort from 'get-port'
-import { AnchorStatus, EventType, IpfsApi } from '@ceramicnetwork/common'
+import { AnchorStatus, EventType, IpfsApi, Networks } from '@ceramicnetwork/common'
 import { Utils as CoreUtils } from '@ceramicnetwork/core'
 import { createIPFS, swarmConnect } from '@ceramicnetwork/ipfs-daemon'
 import {
@@ -81,9 +81,6 @@ const MODEL_WITH_RELATION_DEFINITION: ModelDefinition = {
   },
 }
 
-// TODO(WS1-1471): These tests should be enabled once anchoring works in Recon mode
-const testIfV3ShouldPassWithAnchoring = process.env.CERAMIC_RECON_MODE ? test.skip : test
-
 describe('ModelInstanceDocument API http-client tests', () => {
   jest.setTimeout(1000 * 30)
 
@@ -166,10 +163,8 @@ describe('ModelInstanceDocument API http-client tests', () => {
     expect(doc.metadata.unique).toBeInstanceOf(Uint8Array)
     expect(doc.state.log.length).toEqual(1)
     expect(doc.state.log[0].type).toEqual(EventType.INIT)
-    if (!process.env.CERAMIC_RECON_MODE) {
-      // TODO (WS1-1471): Re-enable this check even in Recon mode
-      expect(doc.state.anchorStatus).toEqual(AnchorStatus.PENDING)
-    }
+    expect(doc.state.anchorStatus).toEqual(AnchorStatus.PENDING)
+
     expect(doc.metadata.model.toString()).toEqual(model.id.toString())
     await expect(TestUtils.isPinned(ceramic.admin, doc.id)).resolves.toBeTruthy()
     await expect(TestUtils.isPinned(ceramic.admin, doc.metadata.model)).resolves.toBeTruthy()
@@ -187,10 +182,8 @@ describe('ModelInstanceDocument API http-client tests', () => {
     expect(docWithRelation.metadata.unique).toBeInstanceOf(Uint8Array)
     expect(docWithRelation.state.log.length).toEqual(1)
     expect(docWithRelation.state.log[0].type).toEqual(EventType.INIT)
-    if (!process.env.CERAMIC_RECON_MODE) {
-      // TODO (WS1-1471): Re-enable this check even in Recon mode
-      expect(docWithRelation.state.anchorStatus).toEqual(AnchorStatus.PENDING)
-    }
+    expect(docWithRelation.state.anchorStatus).toEqual(AnchorStatus.PENDING)
+
     expect(docWithRelation.metadata.model.toString()).toEqual(modelWithRelation.id.toString())
     await expect(TestUtils.isPinned(ceramic.admin, docWithRelation.id)).resolves.toBeTruthy()
     await expect(
@@ -272,7 +265,7 @@ describe('ModelInstanceDocument API http-client tests', () => {
     expect(docWithRelation.content.optionalLinkedDoc).toBe(docID)
   })
 
-  testIfV3ShouldPassWithAnchoring('Anchor genesis', async () => {
+  test('Anchor genesis', async () => {
     const doc = await ModelInstanceDocument.create(ceramic, CONTENT0, midMetadata)
     expect(doc.state.anchorStatus).toEqual(AnchorStatus.PENDING)
 
@@ -286,7 +279,7 @@ describe('ModelInstanceDocument API http-client tests', () => {
     expect(doc.content).toEqual(CONTENT0)
   })
 
-  testIfV3ShouldPassWithAnchoring('Anchor after updating', async () => {
+  test('Anchor after updating', async () => {
     const doc = await ModelInstanceDocument.create(ceramic, CONTENT0, midMetadata)
     expect(doc.state.anchorStatus).toEqual(AnchorStatus.PENDING)
     await doc.replace(CONTENT1)
@@ -303,7 +296,7 @@ describe('ModelInstanceDocument API http-client tests', () => {
     expect(doc.content).toEqual(CONTENT1)
   })
 
-  testIfV3ShouldPassWithAnchoring('multiple updates', async () => {
+  test('multiple updates', async () => {
     const doc = await ModelInstanceDocument.create(ceramic, CONTENT0, midMetadata)
     await doc.replace(CONTENT1)
 
@@ -350,7 +343,7 @@ describe('ModelInstanceDocument API http-client tests', () => {
     ).rejects.toThrow(/Attempting to create a ModelInstanceDocument with an invalid DID string/)
   })
 
-  testIfV3ShouldPassWithAnchoring('Can load a stream', async () => {
+  test('Can load a stream', async () => {
     const doc = await ModelInstanceDocument.create(ceramic, CONTENT0, midMetadata)
     await doc.replace(CONTENT1)
     await CoreUtils.anchorUpdate(core, doc)
@@ -428,10 +421,7 @@ describe('ModelInstanceDocument API http-client tests', () => {
   })
 })
 
-// should pass on v4 as soon as recon is integrated and cross-node syncing works.
-const describeIfV3ShouldPass = process.env.CERAMIC_RECON_MODE ? describe.skip : describe
-
-describeIfV3ShouldPass('ModelInstanceDocument API multi-node tests', () => {
+describe('ModelInstanceDocument API multi-node tests', () => {
   jest.setTimeout(1000 * 30)
 
   let ipfs0: IpfsApi
@@ -442,16 +432,26 @@ describeIfV3ShouldPass('ModelInstanceDocument API multi-node tests', () => {
   let midMetadata: ModelInstanceDocumentMetadataArgs
 
   beforeAll(async () => {
-    ipfs0 = await createIPFS()
-    ipfs1 = await createIPFS()
+    ipfs0 = await createIPFS({
+      rust: {
+        type: 'binary',
+        network: Networks.INMEMORY,
+      },
+    })
+    ipfs1 = await createIPFS({
+      rust: {
+        type: 'binary',
+        network: Networks.INMEMORY,
+      },
+    })
     await swarmConnect(ipfs0, ipfs1)
 
     ceramic0 = await createCeramic(ipfs0)
     ceramic1 = await createCeramic(ipfs1)
 
     model = await Model.create(ceramic0, MODEL_DEFINITION)
     midMetadata = { model: model.id }
-  }, 12000)
+  }, 80000)
 
   afterAll(async () => {
     await ceramic0.close()