// Diffs helper module supports test helpers behavior.
import { execFile } from "node:child_process";
import fs from "node:fs/promises";
import path from "node:path";
import { fileURLToPath } from "node:url";
import { promisify } from "node:util";
import type { PluginBlobStore } from "openclaw/plugin-sdk/plugin-state-runtime";
import {
  createPluginBlobStoreForTests,
  resetPluginBlobStoreForTests,
} from "openclaw/plugin-sdk/plugin-state-test-runtime";
import { resolvePreferredOpenClawTmpDir } from "../api.js";
import { DiffArtifactStore } from "./store.js";
import type { DiffArtifactBlobMetadata } from "./types.js";

const execFileAsync = promisify(execFile);

async function pathExists(filePath: string): Promise<boolean> {
  try {
    await fs.stat(filePath);
    return true;
  } catch (error) {
    if (error instanceof Error && "code" in error && error.code === "ENOENT") {
      return false;
    }
    throw error;
  }
}

export async function ensureCuratedViewerRuntimeForTests(): Promise<void> {
  const repoRoot = path.resolve(path.dirname(fileURLToPath(import.meta.url)), "../../..");
  const runtimePath = path.join(repoRoot, "extensions", "diffs", "assets", "viewer-runtime.js");
  if (await pathExists(runtimePath)) {
    return;
  }

  // The curated runtime is generated output. Source tests that serve viewer
  // assets need a clean-checkout fixture before the normal build hook runs.
  await execFileAsync(
    process.execPath,
    ["--import", "tsx", "scripts/build-diffs-viewer-runtime.mts", "curated"],
    {
      cwd: repoRoot,
    },
  );
}

export async function createTempDiffRoot(prefix: string): Promise<{
  rootDir: string;
  cleanup: () => Promise<void>;
}> {
  const rootDir = await fs.mkdtemp(path.join(resolvePreferredOpenClawTmpDir(), prefix));
  return {
    rootDir,
    cleanup: async () => {
      await fs.rm(rootDir, { recursive: true, force: true });
    },
  };
}

export async function createDiffStoreHarness(prefix: string): Promise<{
  rootDir: string;
  store: DiffArtifactStore;
  blobStore: PluginBlobStore<DiffArtifactBlobMetadata>;
  reopen: () => {
    store: DiffArtifactStore;
    blobStore: PluginBlobStore<DiffArtifactBlobMetadata>;
  };
  cleanup: () => Promise<void>;
}> {
  const { rootDir: harnessRoot, cleanup } = await createTempDiffRoot(prefix);
  const rootDir = path.join(harnessRoot, "files");
  const env = {
    ...process.env,
    OPENCLAW_STATE_DIR: path.join(harnessRoot, "state"),
  };
  const openBlobStore = () =>
    createPluginBlobStoreForTests<DiffArtifactBlobMetadata>(
      "diffs",
      {
        namespace: "diff-artifacts",
        maxEntries: 2_048,
        maxBytesPerEntry: 32 * 1024 * 1024,
        maxBytesPerNamespace: 256 * 1024 * 1024,
        overflowPolicy: "reject-new",
      },
      env,
    );
  const blobStore = openBlobStore();
  return {
    rootDir,
    store: new DiffArtifactStore({ rootDir, blobStore }),
    blobStore,
    reopen: () => {
      resetPluginBlobStoreForTests();
      const reopenedBlobStore = openBlobStore();
      return {
        store: new DiffArtifactStore({ rootDir, blobStore: reopenedBlobStore }),
        blobStore: reopenedBlobStore,
      };
    },
    cleanup: async () => {
      resetPluginBlobStoreForTests();
      await cleanup();
    },
  };
}