import type { PreviewOpenInput, PreviewSessionSnapshot, ScopedThreadRef } from "@t3tools/contracts";import * as Cause from "effect/Cause";import { AsyncResult } from "effect/unstable/reactivity";import { describe, expect, it, vi } from "vite-plus/test"; import { openPreviewSession } from "./openPreviewSession"; const threadRef = {  environmentId: "local" as ScopedThreadRef["environmentId"],  threadId: "thread-1" as ScopedThreadRef["threadId"],}; const snapshot: PreviewSessionSnapshot = {  threadId: threadRef.threadId,  tabId: "tab-1",  navStatus: {    _tag: "Loading",    url: "https://t3.chat/",    title: "",  },  canGoBack: false,  canGoForward: false,  updatedAt: "2026-06-11T23:00:00.000Z",}; describe("openPreviewSession", () => {  it("applies the RPC response without waiting for a preview event", async () => {    const open = vi.fn(async (_input: PreviewOpenInput) => AsyncResult.success(snapshot));    const applyServerSnapshot = vi.fn();    const rememberUrl = vi.fn();     await openPreviewSession({      openPreview: ({ input }) => open(input),      threadRef,      url: "t3.chat",      applyServerSnapshot,      rememberUrl,    });     expect(open).toHaveBeenCalledWith({ threadId: "thread-1", url: "t3.chat" });    expect(applyServerSnapshot).toHaveBeenCalledWith(threadRef, snapshot);    expect(rememberUrl).toHaveBeenCalledWith(threadRef, "https://t3.chat/");  });   it("returns failures without mutating preview state", async () => {    const failure = new Error("preview unavailable");    const applyServerSnapshot = vi.fn();    const rememberUrl = vi.fn();     const result = await openPreviewSession({      openPreview: async () => AsyncResult.failure(Cause.fail(failure)),      threadRef,      url: "t3.chat",      applyServerSnapshot,      rememberUrl,    });     expect(result._tag).toBe("Failure");    expect(applyServerSnapshot).not.toHaveBeenCalled();    expect(rememberUrl).not.toHaveBeenCalled();  });});