fix: send row document source when creating row pages

Author: appflowy

src/application/database-yjs/context.ts

@@ -16,6 +16,7 @@ import {
   LoadView,
   LoadViewMeta,
   RowId,
+  RowDocumentSourcePayload,
   Subscription,
   TestDatabasePromptConfig,
   TimeFormat,
@@ -84,7 +85,7 @@ export interface DatabaseContextState {
    * Only available in app mode - not provided in publish mode.
    * Returns the doc_state (Y.js update) to initialize the local document.
    */
-  createRowDocument?: (documentId: string) => Promise<Uint8Array | null>;
+  createRowDocument?: (documentId: string, source?: RowDocumentSourcePayload) => Promise<Uint8Array | null>;
   /** Fire-and-forget: ask the server to duplicate the row document with inline DB deep copy. */
   duplicateRowDocument?: (databaseId: string, sourceRowId: string, newRowId: string, clientDocStateB64?: string) => Promise<void>;
   navigateToView?: (viewId: string, blockId?: string) => Promise<void>;

src/application/services/js-services/http/view-api.ts

@@ -1,5 +1,5 @@
 import { AppOutlineResponse } from '@/application/services/services.type';
-import { View } from '@/application/types';
+import { CreateOrphanedViewPayload, View } from '@/application/types';
 
 import { APIResponse, executeAPIRequest, getAxios } from './core';
 
@@ -149,7 +149,7 @@ export async function getAppTrash(workspaceId: string) {
   );
 }
 
-export async function createOrphanedView(workspaceId: string, payload: { document_id: string }): Promise<Uint8Array> {
+export async function createOrphanedView(workspaceId: string, payload: CreateOrphanedViewPayload): Promise<Uint8Array> {
   const url = `/api/workspace/${workspaceId}/orphaned-view`;
 
   // Server returns doc_state as Vec<u8> which is JSON encoded as number[]

src/application/types.ts

@@ -1348,6 +1348,17 @@ export interface UpdatePagePayload {
   is_locked?: boolean;
 }
 
+export interface RowDocumentSourcePayload {
+  database_id: string;
+  database_view_id: string;
+  row_id: string;
+}
+
+export interface CreateOrphanedViewPayload {
+  document_id: string;
+  row_document_source?: RowDocumentSourcePayload;
+}
+
 export type ViewMetaCover = ViewCover;
 
 export interface ViewMetaProps {
@@ -1396,7 +1407,7 @@ export interface ViewComponentProps {
    * Create a row document on the server (orphaned view).
    * Only available in app mode - not provided in publish mode.
    */
-  createRowDocument?: (documentId: string) => Promise<Uint8Array | null>;
+  createRowDocument?: (documentId: string, source?: RowDocumentSourcePayload) => Promise<Uint8Array | null>;
   duplicateRowDocument?: (
     databaseId: string,
     sourceRowId: string,

src/components/app/contexts/AppOperationsContext.ts

@@ -5,6 +5,7 @@ import { SyncContext } from '@/application/services/js-services/sync-protocol';
 import {
   CreateDatabaseViewPayload,
   CreateDatabaseViewResponse,
+  CreateOrphanedViewPayload,
   DuplicatePageOperationOptions,
   CreatePagePayload,
   CreatePageResponse,
@@ -15,6 +16,7 @@ import {
   LoadDatabasePrompts,
   LoadView,
   LoadViewMeta,
+  RowDocumentSourcePayload,
   Subscription,
   TestDatabasePromptConfig,
   TextCount,
@@ -113,7 +115,7 @@ export interface AppOperationsContextType {
 
   // ── Database operations ────────────────────────────────────────────
   /** Create an orphaned view (e.g. for inline database within a document). */
-  createOrphanedView?: (payload: { document_id: string }) => Promise<Uint8Array>;
+  createOrphanedView?: (payload: CreateOrphanedViewPayload) => Promise<Uint8Array>;
   /** Load AI prompt templates for a database. */
   loadDatabasePrompts?: LoadDatabasePrompts;
   /** Test an AI prompt config against a database. */
@@ -123,7 +125,7 @@ export interface AppOperationsContextType {
   /** Load an existing row document. */
   loadRowDocument?: (documentId: string) => Promise<YDoc | null>;
   /** Create a new row document (returns encoded initial state). */
-  createRowDocument?: (documentId: string) => Promise<Uint8Array | null>;
+  createRowDocument?: (documentId: string, source?: RowDocumentSourcePayload) => Promise<Uint8Array | null>;
   /** Fire-and-forget: ask the server to duplicate the row document with inline DB deep copy. */
   duplicateRowDocument?: (databaseId: string, sourceRowId: string, newRowId: string, clientDocStateB64?: string) => Promise<void>;
   /** Resolve a database ID to its primary view ID. */

src/components/app/hooks/useDatabaseOperations.ts

@@ -11,6 +11,7 @@ import {
   DatabasePromptRow,
   GenerateAISummaryRowPayload,
   GenerateAITranslateRowPayload,
+  RowDocumentSourcePayload,
   Types,
   YDatabase,
   YDoc,
@@ -332,15 +333,18 @@ export function useDatabaseOperations(
 
   // Create a row document on the server (orphaned view)
   const createRowDocument = useCallback(
-    async (documentId: string): Promise<Uint8Array | null> => {
+    async (documentId: string, source?: RowDocumentSourcePayload): Promise<Uint8Array | null> => {
       if (!currentWorkspaceId) {
         Log.warn('[createRowDocument] service or workspaceId not available');
         return null;
       }
 
       try {
-        Log.debug('[createRowDocument] creating', { documentId });
-        const docState = await ViewService.createOrphaned(currentWorkspaceId, { document_id: documentId });
+        Log.debug('[createRowDocument] creating', { documentId, source });
+        const docState = await ViewService.createOrphaned(currentWorkspaceId, {
+          document_id: documentId,
+          row_document_source: source,
+        });
 
         return docState;
       } catch (e) {

src/components/app/hooks/usePageOperations.ts

@@ -11,6 +11,7 @@ import {
 } from '@/application/services/js-services/http/publish-api';
 import {
   CreateDatabaseViewPayload,
+  CreateOrphanedViewPayload,
   DuplicatePageOperationOptions,
   CreatePagePayload,
   CreateSpacePayload,
@@ -458,7 +459,7 @@ export function usePageOperations({
 
   // Create orphaned view
   const createOrphanedViewOp = useCallback(
-    async (payload: { document_id: string }) => {
+    async (payload: CreateOrphanedViewPayload) => {
       if (!currentWorkspaceId) {
         throw new Error('No workspace or service found');
       }

src/components/database/Database.tsx

@@ -27,6 +27,7 @@ import {
   LoadView,
   LoadViewMeta,
   RowId,
+  RowDocumentSourcePayload,
   UIVariant,
   UpdatePagePayload,
   View,
@@ -74,7 +75,7 @@ export interface Database2Props {
    * Create a row document on the server (orphaned view).
    * Only available in app mode - not provided in publish mode.
    */
-  createRowDocument?: (documentId: string) => Promise<Uint8Array | null>;
+  createRowDocument?: (documentId: string, source?: RowDocumentSourcePayload) => Promise<Uint8Array | null>;
   duplicateRowDocument?: (
     databaseId: string,
     sourceRowId: string,

src/components/database/components/database-row/DatabaseRowSubDocument.tsx

@@ -25,6 +25,7 @@ import {
   YDatabaseRow,
   YDoc,
   YDocWithMeta,
+  RowDocumentSourcePayload,
   YjsDatabaseKey,
   YjsEditorKey,
 } from '@/application/types';
@@ -124,6 +125,20 @@ export const DatabaseRowSubDocument = memo(({ rowId }: { rowId: string }) => {
   const createRowDocument = context?.createRowDocument;
   const checkIfRowDocumentExists = context?.checkIfRowDocumentExists;
   const bindViewSync = context?.bindViewSync;
+  const rowDocumentSource = useMemo<RowDocumentSourcePayload | undefined>(() => {
+    const databaseId = (database?.get(YjsDatabaseKey.id) as string | undefined) || context?.databaseDoc?.guid;
+    const databaseViewId = context?.activeViewId || context?.databasePageId;
+
+    if (!databaseId || !databaseViewId) {
+      return undefined;
+    }
+
+    return {
+      database_id: databaseId,
+      database_view_id: databaseViewId,
+      row_id: rowId,
+    };
+  }, [context?.activeViewId, context?.databaseDoc, context?.databasePageId, database, rowId]);
   const updateRowMeta = useUpdateRowMetaDispatch(rowId);
   const editorRef = useRef<YjsEditor | null>(null);
   const lastIsEmptyRef = useRef<boolean | null>(null);
@@ -412,7 +427,7 @@ export const DatabaseRowSubDocument = memo(({ rowId }: { rowId: string }) => {
 
         try {
           Log.debug('[DatabaseRowSubDocument] calling createRowDocument', { documentId, requireServerReady });
-          docState = await createRowDocument(documentId);
+          docState = await createRowDocument(documentId, rowDocumentSource);
           Log.debug('[DatabaseRowSubDocument] createRowDocument success', {
             documentId,
             docStateSize: docState?.length ?? 0,
@@ -452,7 +467,15 @@ export const DatabaseRowSubDocument = memo(({ rowId }: { rowId: string }) => {
         setLoading(false);
       }
     },
-    [createRowDocument, handleOpenDocument, hasLocalDocContent, loadRowDocument, openDocumentWithState, rowId]
+    [
+      createRowDocument,
+      handleOpenDocument,
+      hasLocalDocContent,
+      loadRowDocument,
+      openDocumentWithState,
+      rowDocumentSource,
+      rowId,
+    ]
   );
 
   const scheduleEnsureRowDocumentExists = useCallback(() => {
@@ -477,7 +500,7 @@ export const DatabaseRowSubDocument = memo(({ rowId }: { rowId: string }) => {
             rowId,
             documentId,
           });
-          await createRowDocument(documentId);
+          await createRowDocument(documentId, rowDocumentSource);
         }
 
         if (pendingNonEmptyRef.current) {
@@ -507,6 +530,7 @@ export const DatabaseRowSubDocument = memo(({ rowId }: { rowId: string }) => {
     createRowDocument,
     documentId,
     isDocumentEmpty,
+    rowDocumentSource,
     updateRowMeta,
     rowId,
   ]);
@@ -682,7 +706,7 @@ export const DatabaseRowSubDocument = memo(({ rowId }: { rowId: string }) => {
                   rowId,
                   documentId,
                 });
-                await createRowDocument(documentId);
+                await createRowDocument(documentId, rowDocumentSource);
               } catch {
                 // Ignore; we'll retry loading below.
               }
@@ -722,6 +746,7 @@ export const DatabaseRowSubDocument = memo(({ rowId }: { rowId: string }) => {
     isDocumentEmptyResolved,
     hasLocalDocContent,
     createRowDocument,
+    rowDocumentSource,
     rowId,
     doc,
   ]);
@@ -823,7 +848,7 @@ export const DatabaseRowSubDocument = memo(({ rowId }: { rowId: string }) => {
     // Only create orphaned view if document doesn't exist
     if (createRowDocument) {
       try {
-        await createRowDocument(documentId);
+        await createRowDocument(documentId, rowDocumentSource);
         rowDocEnsuredRef.current = true;
         return true;
       } catch {
@@ -833,7 +858,7 @@ export const DatabaseRowSubDocument = memo(({ rowId }: { rowId: string }) => {
     }
 
     return false;
-  }, [checkIfRowDocumentExists, createRowDocument, documentId]);
+  }, [checkIfRowDocumentExists, createRowDocument, documentId, rowDocumentSource]);
 
   useEffect(() => {
     if (!doc) return;

src/components/editor/EditorContext.tsx

@@ -24,6 +24,7 @@ import {
   Subscription,
   MentionablePerson,
   DatabaseRelations,
+  RowDocumentSourcePayload,
   YDoc,
 } from '@/application/types';
 import { SyncContext } from '@/application/services/js-services/sync-protocol';
@@ -77,7 +78,7 @@ export interface EditorContextState {
   loadView?: LoadView;
   loadRowDocument?: (documentId: string) => Promise<YDoc | null>;
   checkIfRowDocumentExists?: (documentId: string) => Promise<boolean>;
-  createRowDocument?: (documentId: string) => Promise<Uint8Array | null>;
+  createRowDocument?: (documentId: string, source?: RowDocumentSourcePayload) => Promise<Uint8Array | null>;
   createRow?: CreateRow;
   bindViewSync?: (doc: YDoc) => SyncContext | null;
   readSummary?: boolean;