import { Octokit } from "@octokit/rest";

import { fetchWorkflowRunInfo } from "./api.ts";

import { getGitHubInstallationToken, parseRepoContext } from "./github.ts";

/**

* Get progress comment ID from environment variable or database.

*/

function getProgressCommentIdFromEnv(): number | null {

const envCommentId = process.env.PULLFROG_PROGRESS_COMMENT_ID;

if (envCommentId) {

const parsed = parseInt(envCommentId, 10);

if (!Number.isNaN(parsed)) {

return parsed;

}

}

return null;

}

export async function reportErrorToComment({

error,

title,

}: {

error: string;

title?: string;

}): Promise<void> {

const formattedError = title ? `${title}\n\n${error}` : `❌ ${error}`;

// try to get comment ID from env var first, then from database if needed

let commentId = getProgressCommentIdFromEnv();

// if not in env var, try fetching from database using run ID

if (!commentId) {

const runId = process.env.GITHUB_RUN_ID;

if (runId) {

try {

const workflowRunInfo = await fetchWorkflowRunInfo(runId);

if (workflowRunInfo.progressCommentId) {

const parsed = parseInt(workflowRunInfo.progressCommentId, 10);

if (!Number.isNaN(parsed)) {

commentId = parsed;

// cache it in env var for future use

process.env.PULLFROG_PROGRESS_COMMENT_ID = workflowRunInfo.progressCommentId;

}

}

} catch {

// database fetch failed, continue without comment ID

}

}

}

// if no comment ID available, can't update comment

if (!commentId) {

return;

}

// update comment directly using GitHub API

const repoContext = parseRepoContext();

const token = getGitHubInstallationToken();

const octokit = new Octokit({ auth: token });

await octokit.rest.issues.updateComment({

owner: repoContext.owner,

repo: repoContext.name,

comment_id: commentId,

body: formattedError,

});

}