fix(vnext): expose bounded catalog invalidation

Author: Light2Dark

docs/vnext/codemirror-adapter.md

@@ -87,6 +87,17 @@ const visible = support.statementBoundariesIntersecting(view, {
 ```
 
 Both methods return `null` for foreign, destroyed, or unsynchronized views.
+Catalog-backed hosts can invalidate the adapter-owned session without exposing
+it:
+
+```ts
+const revision = support.invalidateCatalog(view);
+```
+
+This returns `null` for foreign or destroyed views. A live view advances its
+revision, cancels stale catalog work, and forces relation, column, and namespace
+providers to be consulted again.
+
 An opt-in structural gutter marks only lines intersecting scanner-owned SQL
 `code` spans. It never parses or copies statement text:
 

src/vnext/codemirror/__tests__/sql-editor.test.ts

@@ -48,6 +48,7 @@ interface FakeServiceHarness {
   readonly completeSignals: AbortSignal[];
   readonly emit: (event: SqlSessionChangeEvent) => void;
   readonly getLastToken: () => SqlCompletionRefreshToken | null;
+  readonly invalidations: () => number;
   readonly service: SqlLanguageService<TestContext>;
   readonly sessionDisposals: () => number;
   readonly statementBoundaryCalls: () => number;
@@ -138,6 +139,7 @@ function fakeService(
     | ((event: SqlSessionChangeEvent) => void)
     | null = null;
   let lastToken: SqlCompletionRefreshToken | null = null;
+  let invalidationCount = 0;
   let sessionDisposalCount = 0;
   let statementBoundaryCallCount = 0;
   let statementIntersectionCallCount = 0;
@@ -162,6 +164,7 @@ function fakeService(
           sessionDisposalCount += 1;
         },
         invalidateCatalog: () => {
+          invalidationCount += 1;
           revision = createSqlRevisionToken();
           return revision;
         },
@@ -243,6 +246,7 @@ function fakeService(
     completeSignals,
     emit: (event) => listener?.(event),
     getLastToken: () => lastToken,
+    invalidations: () => invalidationCount,
     service,
     sessionDisposals: () => sessionDisposalCount,
     statementBoundaryCalls: () => statementBoundaryCallCount,
@@ -360,7 +364,7 @@ async function resolveCompletionInfo(
 }
 
 describe("sqlEditor", () => {
-  it("exposes current statement boundaries only for owned views", () => {
+  it("exposes session controls only for owned views", () => {
     const service = createSqlLanguageService<TestContext>({
       dialects: [duckdbDialect()],
     });
@@ -383,6 +387,8 @@ describe("sqlEditor", () => {
       from: 0,
       to: view.state.doc.length,
     })?.boundaries).toHaveLength(2);
+    expect(support.invalidateCatalog(view)).not.toBeNull();
+    expect(support.invalidateCatalog(foreign)).toBeNull();
     expect(support.statementBoundaryAt(foreign, {
       affinity: "left",
       position: 0,
@@ -397,6 +403,7 @@ describe("sqlEditor", () => {
     })).toBeNull();
 
     view.destroy();
+    expect(support.invalidateCatalog(view)).toBeNull();
     expect(support.statementBoundaryAt(view, {
       affinity: "left",
       position: 0,
@@ -408,6 +415,24 @@ describe("sqlEditor", () => {
     service.dispose();
   });
 
+  it("proxies catalog invalidation only to its owned live session", () => {
+    const harness = fakeService((revision) => readyResult(revision, []));
+    const support = sqlEditor({
+      initialContext: context(),
+      service: harness.service,
+    });
+    const view = createView(support.extension);
+    const foreign = createView([]);
+
+    expect(support.invalidateCatalog(view)).not.toBeNull();
+    expect(harness.invalidations()).toBe(1);
+    expect(support.invalidateCatalog(foreign)).toBeNull();
+    expect(harness.invalidations()).toBe(1);
+    view.destroy();
+    expect(support.invalidateCatalog(view)).toBeNull();
+    expect(harness.invalidations()).toBe(1);
+  });
+
   it("renders an opt-in visible-line statement gutter", async () => {
     const service = createSqlLanguageService<TestContext>({
       dialects: [duckdbDialect()],

src/vnext/codemirror/sql-editor.ts

@@ -95,6 +95,7 @@ export interface SqlEditorSupport<
     readonly SqlEmbeddedRegion[]
   >;
   readonly extension: Extension;
+  readonly invalidateCatalog: (view: EditorView) => SqlRevision | null;
   readonly statementBoundariesIntersecting: (
     view: EditorView,
     request: SqlStatementBoundariesIntersectingRequest,
@@ -671,6 +672,15 @@ export function createSqlEditorInternal<
       this.#clearCompletionState();
     };
 
+    readonly invalidateCatalog = (): SqlRevision | null => {
+      if (this.#destroyed) return null;
+      try {
+        return this.#session.invalidateCatalog();
+      } catch {
+        return null;
+      }
+    };
+
     readonly statementBoundariesIntersecting = (
       request: SqlStatementBoundariesIntersectingRequest,
     ): SqlStatementBoundariesIntersectingResult | null => {
@@ -869,6 +879,8 @@ export function createSqlEditorInternal<
         override: [completionSource, ...externalSources],
       }),
     ],
+    invalidateCatalog: (view: EditorView): SqlRevision | null =>
+      view.plugin(plugin)?.invalidateCatalog() ?? null,
     statementBoundariesIntersecting: (
       view: EditorView,
       request: SqlStatementBoundariesIntersectingRequest,

src/vnext/session.ts

@@ -2695,6 +2695,7 @@ export class DefaultSqlDocumentSession<Context extends SqlDocumentContext>
     }
     this.#activeCompletion = null;
     this.#columnLoadingRetry = null;
+    this.#namespaceLoadingRetry = null;
     this.#refreshIntent = null;
     this.#clearSoftRefreshIntentTimer();
     this.#clearTerminalIntent();