zigbee-OTA/src/ghw_report_ota_pr.ts

import assert from "node:assert";
import {existsSync, readFileSync, writeFileSync} from "node:fs";
import type * as CoreApi from "@actions/core";
import type {Octokit} from "@octokit/rest";

import {execute, PR_ARTIFACT_DIR, PR_DIFF_FILENAME, PR_ERROR_FILENAME, PR_NUMBER_FILENAME} from "./common.js";
import type {Context} from "./types.js";

export async function reportOtaPR(github: Octokit, core: typeof CoreApi, context: Context): Promise<void> {
    assert(context.payload.workflow_run, "Not a workflow run");

    // XXX: context.payload.workflow_run is not typed...
    const workflowRun = context.payload.workflow_run as Awaited<ReturnType<typeof github.rest.actions.getWorkflowRun>>["data"];

    // workflow_run.conclusion: action_required, cancelled, failure, neutral, skipped, stale, success, timed_out, startup_failure, null
    if (workflowRun.conclusion !== "success" && workflowRun.conclusion !== "failure") {
        core.info(`Ignoring workflow run ${workflowRun.html_url} with conclusion ${workflowRun.conclusion}.`);

        return;
    }

    const artifacts = await github.rest.actions.listWorkflowRunArtifacts({
        owner: context.repo.owner,
        repo: context.repo.repo,
        run_id: workflowRun.id,
    });
    const matchArtifact = artifacts.data.artifacts.find((artifact) => artifact.name === PR_ARTIFACT_DIR);

    assert(matchArtifact, `No artifact found for ${workflowRun.url}`);

    const download = await github.rest.actions.downloadArtifact({
        owner: context.repo.owner,
        repo: context.repo.repo,
        artifact_id: matchArtifact.id,
        archive_format: "zip",
    });
    const artifactZipFileName = `${PR_ARTIFACT_DIR}.zip`;

    writeFileSync(artifactZipFileName, Buffer.from(download.data as ArrayBuffer));

    const unzipOutput = await execute(`unzip ${artifactZipFileName}`);

    core.info(unzipOutput);

    assert(existsSync(PR_NUMBER_FILENAME), `Invalid artifact for ${workflowRun.html_url}`);

    const prNumber = Number.parseInt(readFileSync(PR_NUMBER_FILENAME, "utf8"), 10);

    core.info(`Running for pr#${prNumber} for ${workflowRun.html_url}`);

    if (workflowRun.conclusion === "failure") {
        assert(existsSync(PR_ERROR_FILENAME), `Workflow failed but could not find ${PR_ERROR_FILENAME} for ${workflowRun.html_url}`);

        const prError = readFileSync(PR_ERROR_FILENAME, "utf8");

        await github.rest.issues.createComment({
            owner: context.repo.owner,
            repo: context.repo.repo,
            issue_number: prNumber,
            body: prError,
        });

        throw new Error(prError);
    }

    if (workflowRun.conclusion === "success") {
        assert(existsSync(PR_DIFF_FILENAME), `Workflow succeeded but could not find ${PR_DIFF_FILENAME} for ${workflowRun.html_url}`);

        const prDiff = readFileSync(PR_DIFF_FILENAME, "utf8");

        core.info(prDiff);
        await github.rest.issues.createComment({
            owner: context.repo.owner,
            repo: context.repo.repo,
            issue_number: prNumber,
            body: `Merging this pull request will add these changes in a following commit:
\`\`\`diff
${prDiff}
\`\`\`
`,
        });
    }
}