import {
  getRequestOrgId,
  getRequestUserEmail,
} from "@agent-native/core/server";
import { assertAccess } from "@agent-native/core/sharing";

import { flushOpenDocumentEditorToSql } from "./_document-flush.js";

export function getCurrentNotionOwner() {
  const owner = getRequestUserEmail();
  if (!owner) throw new Error("no authenticated user");
  return owner;
}

export async function getNotionDocumentOwner(documentId: string) {
  const userEmail = getCurrentNotionOwner();
  const access = await assertAccess("document", documentId, "editor", {
    userEmail,
    orgId: getRequestOrgId(),
  });
  const owner = access?.resource?.ownerEmail;
  if (typeof owner !== "string" || owner.length === 0) {
    throw new Error("Document not found");
  }
  return owner;
}

/**
 * Flush the live collaborative editor before a user-triggered Notion operation
 * reads or replaces SQL content. The Y.Doc can be ahead of the debounced
 * documents row; without this handshake "Use local" can push a stale snapshot,
 * while "Use Notion" can discard edits that never reached version history.
 */
export async function flushNotionDocumentEditor(
  documentId: string,
  ownerEmail: string,
) {
  await flushOpenDocumentEditorToSql({ documentId, ownerEmail });
}

export function resolveDocumentId(args: { documentId?: string; id?: string }) {
  const documentId = args.documentId?.trim() || args.id?.trim();
  if (!documentId) {
    throw Object.assign(new Error("documentId is required"), {
      statusCode: 400,
    });
  }
  return documentId;
}