import { spawnSync } from "node:child_process";

import fs from "node:fs";

import path from "node:path";

import * as tar from "tar";

import { afterAll, beforeAll, beforeEach, describe, expect, it, vi } from "vitest";

import { safePathSegmentHashed } from "../infra/install-safe-path.js";

import { resolveOpenClawPackageRootSync } from "../infra/openclaw-root.js";

PLUGIN_INSTALL_ERROR_CODE,

resolvePluginInstallDir,

} from "./install.js";

import { packToArchive } from "./test-helpers/archive-fixtures.js";

import { createSuiteTempRootTracker } from "./test-helpers/fs-fixtures.js";

vi.mock("../process/exec.js", () => ({

return suiteFixtureRoot;

}

async function packToArchive({

pkgDir,

outDir,

outName,

flatRoot,

}: {

pkgDir: string;

outDir: string;

outName: string;

flatRoot?: boolean;

}) {

const dest = path.join(outDir, outName);

fs.rmSync(dest, { force: true });

const entries = flatRoot ? listFlatRootArchiveEntries(pkgDir) : [path.basename(pkgDir)];

await tar.c(

{

gzip: true,

file: dest,

cwd: flatRoot ? pkgDir : path.dirname(pkgDir),

},

entries,

);

return dest;

}

function listFlatRootArchiveEntries(pkgDir: string): string[] {

const externalEntries = listFindFlatRootArchiveEntries(pkgDir);

if (externalEntries) {

return externalEntries;

}

return fs.readdirSync(pkgDir).toSorted((left, right) => left.localeCompare(right));

}

function listFindFlatRootArchiveEntries(pkgDir: string): string[] | null {

const result = spawnSync("find", [pkgDir, "-mindepth", "1", "-maxdepth", "1"], {

encoding: "utf8",

maxBuffer: 1024 * 1024,

stdio: ["ignore", "pipe", "ignore"],

});

if (result.status !== 0) {

return null;

}

return result.stdout

.split("\n")

.map((line) => line.trim())

.filter((line) => line.length > 0)

.map((entry) => path.basename(entry))

.toSorted((left, right) => left.localeCompare(right));

}

function getArchiveFixturePath(params: {

cacheKey: string;

outName: string;

});

describe("installPluginFromArchive", () => {

it("lists flat archive entries without scanning package dirs in-process", () => {

const pkgDir = suiteTempRootTracker.makeTempDir();

fs.writeFileSync(path.join(pkgDir, "package.json"), "{}\n");

fs.mkdirSync(path.join(pkgDir, "dist"));

fs.writeFileSync(path.join(pkgDir, "dist", "index.js"), "export {}\n");

const readDir = vi.spyOn(fs, "readdirSync");

try {

expect(listFlatRootArchiveEntries(pkgDir)).toEqual(["dist", "package.json"]);

expect(readDir).not.toHaveBeenCalled();

} finally {

readDir.mockRestore();

}

});

it("installs package archive runtime dependencies", async () => {

const result = await installArchivePackageAndReturnResult({

packageJson: {