return run("git", ["rev-parse", ref], { capture: true }).trim();

}

async function workflowRuns(repo, workflowFile) {

const data = await githubApi(

`repos/${repo}/actions/workflows/${workflowFile}/runs?event=workflow_dispatch&per_page=100`,

);

return (data.workflow_runs ?? []).map((runEntry) => ({

databaseId: runEntry.id,

workflowName: runEntry.name,

event: runEntry.event,

createdAt: runEntry.created_at,

}));

}

async function runArtifacts(repo, runId) {

const data = await githubApi(`repos/${repo}/actions/runs/${runId}/artifacts?per_page=100`);

return (data.artifacts ?? []).map((artifact) => ({

return resolveArtifactName(await runArtifacts(repo, runId), preferredName, prefix);

}

async function beforeRunIds(repo, workflowFile) {

return new Set(

(await workflowRuns(repo, workflowFile)).map((runResult) => String(runResult.databaseId)),

);

}

function runAndEcho(command, args) {

const result = spawnSync(command, args, {

encoding: "utf8",

return output.match(/actions\/runs\/([0-9]+)/u)?.[1] ?? "";

}

export function requireRunIdFromDispatchOutput(output, workflowFile) {

const runId = parseRunIdFromDispatchOutput(output);

if (!runId) {

throw new Error(

`gh workflow run ${workflowFile} did not return an Actions run URL; refusing to guess from recent workflow_dispatch runs`,

);

}

return runId;

}

async function wait(ms) {

await new Promise((resolve) => {

setTimeout(resolve, ms);

});

}

async function findNewRunId(repo, workflowFile, workflowName, beforeIds) {

for (let attempt = 0; attempt < 60; attempt += 1) {

const match = (await workflowRuns(repo, workflowFile))

.filter(

(runValue) =>

runValue.workflowName === workflowName &&

runValue.event === "workflow_dispatch" &&

!beforeIds.has(String(runValue.databaseId)),

)

.toSorted((a, b) => String(b.createdAt ?? "").localeCompare(String(a.createdAt ?? "")))[0];

if (match?.databaseId) {

return String(match.databaseId);

}

await wait(5_000);

}

throw new Error(`could not find dispatched ${workflowName} run`);

}

function dispatchWorkflow(repo, workflowFile, workflowRef, fields) {

const args = ["workflow", "run", workflowFile, "--repo", repo, "--ref", workflowRef];

for (const [key, value] of Object.entries(fields)) {

args.push("-f", `${key}=${String(value)}`);

}

return parseRunIdFromDispatchOutput(runAndEcho("gh", args));

return requireRunIdFromDispatchOutput(runAndEcho("gh", args), workflowFile);

}

async function runInfo(repo, runId) {

return { status: "skipped" };

}

const workflowFile = "npm-telegram-beta-e2e.yml";

const before = await beforeRunIds(options.repo, workflowFile);

const dispatchedRunId = dispatchWorkflow(options.repo, workflowFile, options.workflowRef, {

const runId = dispatchWorkflow(options.repo, workflowFile, options.workflowRef, {

package_spec: `openclaw@${options.tag.replace(/^v/u, "")}`,

package_label: options.tag,

package_artifact_name: artifactName,

package_artifact_run_id: options.npmPreflightRunId,

harness_ref: options.workflowRef,

provider_mode: options.telegramProviderMode,

});

const runId =

dispatchedRunId ||

(await findNewRunId(options.repo, workflowFile, "NPM Telegram Beta E2E", before));

const runLocal = await waitForSuccessfulRun(options.repo, runId, {

workflowName: "NPM Telegram Beta E2E",

workflowRef: options.workflowRef,

if (!options.fullReleaseRunId && !options.skipDispatch) {

const workflowFile = "full-release-validation.yml";

const before = await beforeRunIds(options.repo, workflowFile);

const dispatchedRunId = dispatchWorkflow(options.repo, workflowFile, options.workflowRef, {

options.fullReleaseRunId = dispatchWorkflow(options.repo, workflowFile, options.workflowRef, {

ref: options.tag,

provider: options.provider,

mode: options.mode,

options.releaseProfile === "stable" || options.releaseProfile === "full" ? "true" : "false",

rerun_group: "all",

});

options.fullReleaseRunId =

dispatchedRunId ||

(await findNewRunId(options.repo, workflowFile, "Full Release Validation", before));

}

if (!options.npmPreflightRunId && !options.skipDispatch) {

const workflowFile = "openclaw-npm-release.yml";

const before = await beforeRunIds(options.repo, workflowFile);

const dispatchedRunId = dispatchWorkflow(options.repo, workflowFile, options.workflowRef, {

options.npmPreflightRunId = dispatchWorkflow(options.repo, workflowFile, options.workflowRef, {

tag: options.tag,

preflight_only: "true",

npm_dist_tag: options.npmDistTag,

});

options.npmPreflightRunId =

dispatchedRunId ||

(await findNewRunId(options.repo, workflowFile, "OpenClaw NPM Release", before));

}

const fullRun = await waitForSuccessfulRun(options.repo, options.fullReleaseRunId, {