refactor(core): use new backlink indexer

packages/frontend/core/src/components/affine/page-properties/table.tsx

@@ -8,7 +8,7 @@ import {
   Tooltip,
 } from '@affine/component';
 import { useCurrentWorkspacePropertiesAdapter } from '@affine/core/hooks/use-affine-adapter';
-import { useBlockSuitePageBacklinks } from '@affine/core/hooks/use-block-suite-page-backlinks';
+import { DocLinksServices } from '@affine/core/modules/doc-link';
 import type {
   PageInfoCustomProperty,
   PageInfoCustomPropertyMeta,
@@ -379,7 +379,7 @@ export const PagePropertiesSettingsPopup = ({
 };
 
 type PageBacklinksPopupProps = PropsWithChildren<{
-  backlinks: string[];
+  backlinks: { docId: string; blockId: string; title: string }[];
 }>;
 
 export const PageBacklinksPopup = ({
@@ -397,11 +397,11 @@ export const PageBacklinksPopup = ({
       }}
       items={
         <div className={styles.backlinksList}>
-          {backlinks.map(pageId => (
+          {backlinks.map(link => (
             <AffinePageReference
-              key={pageId}
+              key={link.docId + ':' + link.blockId}
               wrapper={MenuItem}
-              pageId={pageId}
+              pageId={link.docId}
               docCollection={manager.workspace.docCollection}
             />
           ))}
@@ -596,10 +596,13 @@ export const PagePropertiesTableHeader = ({
   const manager = useContext(managerContext);
 
   const t = useI18n();
-  const backlinks = useBlockSuitePageBacklinks(
-    manager.workspace.docCollection,
-    manager.pageId
-  );
+  const { docLinksServices } = useServices({ DocLinksServices });
+  const docBacklinks = docLinksServices.backlinks;
+  const backlinks = useLiveData(docBacklinks.backlinks$);
+
+  useEffect(() => {
+    docBacklinks.revalidate();
+  }, [docBacklinks]);
 
   const { docService, workspaceService } = useServices({
     DocService,

packages/frontend/core/src/components/blocksuite/block-suite-editor/lit-adaper.tsx

@@ -211,9 +211,9 @@ export const BlocksuiteDocEditor = forwardRef<
             }}
           ></div>
         ) : null}
-        {docPage && !page.readonly ? (
+        {/* {docPage && !page.readonly ? (
           <adapted.BiDirectionalLinkPanel doc={page} pageRoot={docPage} />
-        ) : null}
+        ) : null} */}
       </div>
       {portals}
     </>

packages/frontend/core/src/modules/doc-link/entities/doc-backlinks.ts

@@ -0,0 +1,36 @@
+import type { DocService } from '@toeverything/infra';
+import {
+  effect,
+  Entity,
+  fromPromise,
+  LiveData,
+  mapInto,
+} from '@toeverything/infra';
+import { exhaustMap } from 'rxjs';
+
+import type { DocsSearchService } from '../../docs-search';
+
+interface Backlink {
+  docId: string;
+  blockId: string;
+  title: string;
+}
+
+export class DocBacklinks extends Entity {
+  constructor(
+    private readonly docsSearchService: DocsSearchService,
+    private readonly docService: DocService
+  ) {
+    super();
+  }
+
+  backlinks$ = new LiveData<Backlink[]>([]);
+
+  revalidate = effect(
+    exhaustMap(() => {
+      return fromPromise(
+        this.docsSearchService.searchRefsTo(this.docService.doc.id)
+      ).pipe(mapInto(this.backlinks$));
+    })
+  );
+}

packages/frontend/core/src/modules/doc-link/index.ts

@@ -0,0 +1,14 @@
+import { DocScope, DocService, type Framework } from '@toeverything/infra';
+
+import { DocsSearchService } from '../docs-search';
+import { DocBacklinks } from './entities/doc-backlinks';
+import { DocLinksServices } from './services/doc-links';
+
+export { DocLinksServices } from './services/doc-links';
+
+export function configureDocLinksModules(framework: Framework) {
+  framework
+    .scope(DocScope)
+    .service(DocLinksServices)
+    .entity(DocBacklinks, [DocsSearchService, DocService]);
+}

packages/frontend/core/src/modules/doc-link/services/doc-links.ts

@@ -0,0 +1,7 @@
+import { Service } from '@toeverything/infra';
+
+import { DocBacklinks } from '../entities/doc-backlinks';
+
+export class DocLinksServices extends Service {
+  backlinks = this.framework.createEntity(DocBacklinks);
+}

packages/frontend/core/src/modules/docs-search/schema.ts

@@ -1,12 +1,18 @@
-import type { Schema } from '@toeverything/infra';
+import { defineSchema } from '@toeverything/infra';
 
-export const docIndexSchema = {
+export const docIndexSchema = defineSchema({
   title: 'FullText',
-} satisfies Schema;
+});
 
-export const blockIndexSchema = {
+export type DocIndexSchema = typeof docIndexSchema;
+
+export const blockIndexSchema = defineSchema({
   docId: 'String',
   blockId: 'String',
   content: 'FullText',
   flavour: 'String',
-} satisfies Schema;
+  ref: 'String',
+  blob: 'String',
+});
+
+export type BlockIndexSchema = typeof blockIndexSchema;

packages/frontend/core/src/modules/docs-search/services/docs-search.ts

@@ -115,6 +115,49 @@ export class DocsSearchService extends Service {
     return result;
   }
 
+  async searchRefsTo(docId: string): Promise<
+    {
+      docId: string;
+      blockId: string;
+      title: string;
+    }[]
+  > {
+    const { buckets } = await this.indexer.blockIndex.aggregate(
+      {
+        type: 'match',
+        field: 'ref',
+        match: docId,
+      },
+      'docId',
+      {
+        hits: {
+          fields: ['docId', 'blockId'],
+          pagination: {
+            limit: 1,
+          },
+        },
+        pagination: {
+          limit: 100,
+        },
+      }
+    );
+
+    const docData = await this.indexer.docIndex.getAll(
+      buckets.map(bucket => bucket.key)
+    );
+
+    return buckets.map(bucket => {
+      const title =
+        docData.find(doc => doc.id === bucket.key)?.get('title') ?? '';
+      const blockId = bucket.hits.nodes[0]?.fields.blockId ?? '';
+      return {
+        docId: bucket.key,
+        blockId: typeof blockId === 'string' ? blockId : blockId[0],
+        title: typeof title === 'string' ? title : title[0],
+      };
+    });
+  }
+
   async getDocTitle(docId: string) {
     const doc = await this.indexer.docIndex.get(docId);
     const title = doc?.get('title');

packages/frontend/core/src/modules/index.ts

@@ -3,6 +3,7 @@ import { configureInfraModules, type Framework } from '@toeverything/infra';
 
 import { configureCloudModule } from './cloud';
 import { configureCollectionModule } from './collection';
+import { configureDocLinksModules } from './doc-link';
 import { configureDocsSearchModule } from './docs-search';
 import { configureFindInPageModule } from './find-in-page';
 import { configureNavigationModule } from './navigation';
@@ -34,6 +35,7 @@ export function configureCommonModules(framework: Framework) {
   configurePeekViewModule(framework);
   configureQuickSearchModule(framework);
   configureDocsSearchModule(framework);
+  configureDocLinksModules(framework);
 }
 
 export function configureImpls(framework: Framework) {