import type {
  EnvironmentId,
  PreviewOpenInput,
  PreviewSessionSnapshot,
  ScopedThreadRef,
} from "@t3tools/contracts";
import type { AtomCommandResult } from "@t3tools/client-runtime/state/runtime";

import type { PreviewStateStoreState } from "~/previewStateStore";

interface OpenPreviewSessionInput<E> {
  openPreview: (input: {
    readonly environmentId: EnvironmentId;
    readonly input: PreviewOpenInput;
  }) => Promise<AtomCommandResult<PreviewSessionSnapshot, E>>;
  threadRef: ScopedThreadRef;
  url: string;
  applyServerSnapshot: PreviewStateStoreState["applyServerSnapshot"];
  rememberUrl: PreviewStateStoreState["rememberUrl"];
}

export async function openPreviewSession<E>(
  input: OpenPreviewSessionInput<E>,
): Promise<AtomCommandResult<PreviewSessionSnapshot, E>> {
  const result = await input.openPreview({
    environmentId: input.threadRef.environmentId,
    input: {
      threadId: input.threadRef.threadId,
      url: input.url,
    },
  });
  if (result._tag === "Failure") {
    return result;
  }
  const snapshot = result.value;
  input.applyServerSnapshot(input.threadRef, snapshot);
  input.rememberUrl(
    input.threadRef,
    snapshot.navStatus._tag === "Idle" ? input.url : snapshot.navStatus.url,
  );
  return result;
}