// GitHub integration: PR head sha, diff fetch, and review comment upsert.

const { cfg } = require('./config');

const { Octokit } = require('@octokit/rest');

const octokit = new Octokit({ auth: cfg.githubToken });

async function getPrHeadSha({ repoOwner, repoName, prNumber }) {

const { data } = await octokit.pulls.get({

owner: repoOwner,

repo: repoName,

pull_number: prNumber,

});

return data.head.sha;

}

async function fetchDiff({ repoOwner, repoName, prNumber }) {

const { data } = await octokit.pulls.get({

owner: repoOwner,

repo: repoName,

pull_number: prNumber,

mediaType: { format: 'diff' },

});

return data;

}

async function upsertReviewComment({ repoOwner, repoName, prNumber, headSha, findings }) {

const body = `<!-- turtlecode:${headSha} -->\n` + renderReview(findings);

const { data: comments } = await octokit.issues.listComments({

owner: repoOwner,

repo: repoName,

issue_number: prNumber,

});

const existing = comments.find(

(c) => typeof c.body === 'string' && c.body.startsWith('<!-- turtlecode:')

);

if (existing) {

await octokit.issues.updateComment({

owner: repoOwner,

repo: repoName,

comment_id: existing.id,

body,

});

} else {

await octokit.issues.createComment({

owner: repoOwner,

repo: repoName,

issue_number: prNumber,

body,

});

}

}

const SEVERITY_ORDER = { critical: 0, warning: 1, info: 2 };

function renderReview(findings) {

if (!findings || findings.length === 0) {

return 'TurtleCode: no issues found.';

}

const sorted = [...findings].sort(

(a, b) => SEVERITY_ORDER[a.severity] - SEVERITY_ORDER[b.severity]

);

const bullets = sorted

.map((f) => `- **${f.severity}** \`${f.file}:${f.line}\` — ${f.comment}`)

.join('\n');

return '**TurtleCode review**\n\n' + bullets;

}

module.exports = { getPrHeadSha, fetchDiff, upsertReviewComment, renderReview };