dev

packages/common/nbstore/src/impls/sqlite/db.ts

@@ -15,7 +15,7 @@ export interface SqliteNativeDBOptions {
   readonly id: string;
 }
 
-type NativeDBApis = {
+export type NativeDBApis = {
   connect: (id: string) => Promise<void>;
   close: (id: string) => Promise<void>;
   pushDocUpdate: (id: string, update: DocUpdate) => Promise<DocClock>;

packages/common/nbstore/src/impls/sqlite/index.ts

@@ -1,4 +1,4 @@
 export * from './blob';
 export * from './doc';
 export * from './sync';
-export { bindNativeDBApis } from './db';
+export { bindNativeDBApis, type NativeDBApis } from './db';

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

@@ -23,7 +23,10 @@ import { PopupWindowProvider } from '@affine/core/modules/url';
 import { ClientSchemeProvider } from '@affine/core/modules/url/providers/client-schema';
 import { configureIndexedDBUserspaceStorageProvider } from '@affine/core/modules/userspace';
 import { configureBrowserWorkbenchModule } from '@affine/core/modules/workbench';
-import { WorkspacesService } from '@affine/core/modules/workspace';
+import {
+  WorkspaceEngineWorkerProvider,
+  WorkspacesService,
+} from '@affine/core/modules/workspace';
 import {
   configureBrowserWorkspaceFlavours,
   configureIndexedDBWorkspaceEngineStorageProvider,
@@ -55,6 +58,8 @@ import { Cookie } from './plugins/cookie';
 import { Hashcash } from './plugins/hashcash';
 import { Intelligents } from './plugins/intelligents';
 import { enableNavigationGesture$ } from './web-navigation-control';
+import { WorkerClient } from '@affine/nbstore/worker/client';
+import { OpClient } from '@toeverything/infra/op';
 
 const future = {
   v7_startTransition: true,
@@ -68,6 +73,23 @@ configureBrowserWorkspaceFlavours(framework);
 configureIndexedDBWorkspaceEngineStorageProvider(framework);
 configureIndexedDBUserspaceStorageProvider(framework);
 configureMobileModules(framework);
+framework.impl(WorkspaceEngineWorkerProvider, {
+  openWorker(options) {
+    const worker = new Worker(
+      new URL(
+        /* webpackChunkName: "nbstore-worker" */ './worker.ts',
+        import.meta.url
+      )
+    );
+    const client = new WorkerClient(new OpClient(worker), options);
+    return {
+      client,
+      dispose: () => {
+        worker.terminate();
+      },
+    };
+  },
+});
 framework.impl(PopupWindowProvider, {
   open: (url: string) => {
     Browser.open({

packages/frontend/apps/ios/src/plugins/nbstore/index.ts

@@ -1,5 +1,17 @@
+import { registerPlugin } from '@capacitor/core';
+import { type NativeDBApis } from '@affine/nbstore/sqlite';
+
+import type { NbStorePlugin } from './definitions';
+import type {
+  DocUpdate,
+  DocClock,
+  DocRecord,
+  DocClocks,
+  BlobRecord,
+  ListedBlobRecord,
+} from '@affine/nbstore';
+import { uint8ArrayToBase64 } from '@affine/core/modules/workspace-engine';
+
 export * from './definitions';
-export { nbstoreHandlers } from './handlers';
-export { NbStoreDocStorage } from './plugin';
-export * from './storage';
-export { universalId } from '@affine/nbstore';
+
+export const NbStore = registerPlugin<NbStorePlugin>('NbStoreDocStorage');