fix(android): fix android nbstore provider (#9865)

packages/frontend/apps/android/package.json

@@ -11,6 +11,7 @@
     "@affine/component": "workspace:*",
     "@affine/core": "workspace:*",
     "@affine/i18n": "workspace:*",
+    "@affine/nbstore": "workspace:*",
     "@blocksuite/affine": "workspace:*",
     "@blocksuite/icons": "2.2.2",
     "@capacitor/android": "^7.0.0",

packages/frontend/apps/android/src/app.tsx

@@ -5,10 +5,15 @@ import { router } from '@affine/core/mobile/router';
 import { configureCommonModules } from '@affine/core/modules';
 import { I18nProvider } from '@affine/core/modules/i18n';
 import { LifecycleService } from '@affine/core/modules/lifecycle';
-import { configureLocalStorageStateStorageImpls } from '@affine/core/modules/storage';
+import {
+  configureLocalStorageStateStorageImpls,
+  NbstoreProvider,
+} from '@affine/core/modules/storage';
 import { configureBrowserWorkbenchModule } from '@affine/core/modules/workbench';
 import { configureBrowserWorkspaceFlavours } from '@affine/core/modules/workspace-engine';
+import { WorkerClient } from '@affine/nbstore/worker/client';
 import { Framework, FrameworkRoot, getCurrentStore } from '@toeverything/infra';
+import { OpClient } from '@toeverything/infra/op';
 import { Suspense } from 'react';
 import { RouterProvider } from 'react-router-dom';
 
@@ -22,6 +27,20 @@ configureBrowserWorkbenchModule(framework);
 configureLocalStorageStateStorageImpls(framework);
 configureBrowserWorkspaceFlavours(framework);
 configureMobileModules(framework);
+framework.impl(NbstoreProvider, {
+  openStore(_key, options) {
+    const worker = new Worker(
+      new URL(/* webpackChunkName: "nbstore" */ './nbstore.ts', import.meta.url)
+    );
+    const client = new WorkerClient(new OpClient(worker), options);
+    return {
+      store: client,
+      dispose: () => {
+        worker.terminate();
+      },
+    };
+  },
+});
 const frameworkProvider = framework.provider();
 
 // setup application lifecycle events, and emit application start event

packages/frontend/apps/android/src/nbstore.ts

@@ -0,0 +1,22 @@
+import '@affine/core/bootstrap/browser';
+
+import { broadcastChannelStorages } from '@affine/nbstore/broadcast-channel';
+import { cloudStorages } from '@affine/nbstore/cloud';
+import { idbStorages } from '@affine/nbstore/idb';
+import {
+  WorkerConsumer,
+  type WorkerOps,
+} from '@affine/nbstore/worker/consumer';
+import { type MessageCommunicapable, OpConsumer } from '@toeverything/infra/op';
+
+const consumer = new WorkerConsumer([
+  ...idbStorages,
+  ...broadcastChannelStorages,
+  ...cloudStorages,
+]);
+
+const opConsumer = new OpConsumer<WorkerOps>(
+  globalThis as MessageCommunicapable
+);
+
+consumer.bindConsumer(opConsumer);

packages/frontend/apps/android/tsconfig.json

@@ -10,6 +10,7 @@
     { "path": "../../component" },
     { "path": "../../core" },
     { "path": "../../i18n" },
+    { "path": "../../../common/nbstore" },
     { "path": "../../../../blocksuite/affine/all" },
     { "path": "../../../common/infra" }
   ]