File size: 4,730 Bytes
eb3f11e | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 | import "./update-command-execution.test-support.js";
import fs from "node:fs/promises";
import path from "node:path";
import { describe, expect, it, vi } from "vitest";
import * as tempRoot from "../../infra/tmp-openclaw-dir.js";
import { createUpdateRun, getUpdateRun } from "../../infra/update-run-ledger.js";
import { prepareGitMutation } from "../../infra/update-runner-git-target.js";
import { withTestDir } from "../../test-helpers/temp-dir.js";
import { executeMutableUpdate } from "./update-command-execution.js";
import { withUpdateCommandExecutor } from "./update-command-executor.js";
const { executionParams, mocks, successfulUpdate } =
await import("./update-command-execution.test-support.js");
describe("update target admission", () => {
it.each(["package", "staged", "git"] as const)(
"refuses an unsupported native receiver before activation: %s",
async (route) =>
withTestDir({ prefix: "native-before-activation-" }, async (dir) => {
const control = path.join(dir, "leases");
await fs.mkdir(control);
vi.spyOn(tempRoot, "resolvePreferredOpenClawTmpDir").mockReturnValue(control);
const env = { OPENCLAW_STATE_DIR: dir };
const runId = createUpdateRun(
{
trigger: "cli",
target: route === "git" ? { kind: "git", channel: "dev", tag: "latest" } : {},
},
{ env },
).runId;
const params = executionParams(route === "git" ? "git" : "package");
params.root = dir;
params.updateStepTimeoutMs = 600_000;
params.opts.run = { runId, env };
if (route === "staged") {
params.packageInstallSpec = path.join(dir, "candidate.tgz");
}
const events: string[] = [];
mocks.nativeSupport.mockImplementation(async ({ executor }) => {
executor.assertCurrent();
events.push("native-admission");
return false;
});
const candidate = async ({
validateCandidate,
}: {
validateCandidate: (root: string) => Promise<unknown>;
}) => {
await validateCandidate(dir);
// Models the package/Git publisher which follows successful validation.
events.push("publish");
return successfulUpdate;
};
mocks.runPackageUpdate.mockImplementation(candidate);
mocks.runGitUpdate.mockImplementation(
async (
options: Parameters<typeof import("./update-command-git.js").updateGitInstall>[0],
) => {
if (!options.inspectGitTarget || !options.validateCandidate) {
throw new Error("Missing actual Git admission callbacks");
}
await prepareGitMutation({
root: dir,
revision: "1111111111111111111111111111111111111111",
timeoutMs: params.updateStepTimeoutMs,
runCommand: async () => ({
code: 0,
stderr: "",
stdout: JSON.stringify({
version: "2026.9.4",
openclaw: { schemaVersions: { state: 15, agent: 19 } },
}),
}),
beforeGitMutation: options.inspectGitTarget,
});
expect(getUpdateRun(runId, { env })?.target).toMatchObject({
version: "2026.9.4",
sha: "1111111111111111111111111111111111111111",
});
await options.inspectGitTarget({
sha: "2222222222222222222222222222222222222222",
schemaVersions: { state: 15, agent: 19 },
});
return candidate({ validateCandidate: options.validateCandidate });
},
);
const result = await withUpdateCommandExecutor(runId, async (executor) => {
mocks.prepareMutableUpdate.mockImplementation(async () => {
params.opts.run!.executorFence = await executor.enter(dir);
});
return executeMutableUpdate(params);
});
expect(result?.result).toMatchObject({
status: "error",
reason: "target-native-unsupported",
});
expect(events).toEqual(["native-admission"]);
expect(mocks.nativeSupport.mock.calls[0]?.[0]).toMatchObject({
timeoutMs: params.updateStepTimeoutMs,
});
expect(mocks.serviceStopped).toBe(false);
expect(mocks.validateCanary).not.toHaveBeenCalled();
if (route === "git") {
expect(getUpdateRun(runId, { env })?.target).toEqual({
kind: "git",
channel: "dev",
tag: "latest",
sha: "2222222222222222222222222222222222222222",
});
}
}),
);
});
|