@artsy/dupe-report/lib/index.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.dupeReport = void 0;
const diff_1 = require("diff");
const circle_1 = require("./api/circle");
const github_1 = require("./api/github");
const format_report_1 = require("./lib/format-report");
const DUPE_IDENTIFIER = "<!-- DUPE:REPORT -->";
const jobName = "build";
const artifactName = "duplicates-report";
const dupeReport = async ({ owner, repo, buildNum, dryRun = false }) => {
    const circle = new circle_1.Circle({ owner, repo });
    const pullRequestURL = await circle.getPullRequest(buildNum);
    /** If a build has no PR associated with it we just skip the dupe report */
    if (!pullRequestURL) {
        console.log(`Exiting for build ${owner}/${repo} #${buildNum} because there was no PR`);
        return;
    }
    const github = new github_1.GitHub({
        owner,
        repo,
        pullRequest: pullRequestURL,
        dryRun
    });
    // Grab the report generated by CI (Retrieved from passed in buildNum)
    let headReport;
    try {
        headReport = await circle.fetchArtifact({
            jobName,
            artifactName,
            buildNum
        });
    }
    catch (_a) {
        console.error("failed to read head duplicate report");
    }
    if (!headReport) {
        console.log("local report is empty");
        headReport = "";
    }
    // Try to grab the report of the base commit. Use master if fails.
    let baseReport;
    try {
        const buildNum = await github.getBaseCommitBuild(jobName);
        baseReport = await circle.fetchArtifact({
            jobName,
            artifactName,
            buildNum
        });
    }
    catch (_b) {
        console.warn(`Failed to get based build, falling back to master`);
        try {
            baseReport = await circle.fetchArtifact({
                jobName,
                artifactName
            });
        }
        catch (error) {
            console.error("failed to fetch base report");
            throw error;
        }
    }
    if (!baseReport) {
        console.log("base report is empty");
        baseReport = "";
    }
    // If everything's empty, just quit
    if (baseReport === "" && headReport === "") {
        console.log("Nothing to compare");
        return;
    }
    // Diff the reports
    let dupeDiff = "";
    let headerDiff = false;
    let hasDiff = false;
    let change = 0;
    const masterHeader = baseReport
        .trim()
        .split("\n", 5)
        .slice(0, 4)
        .join("\n");
    const localHeader = headReport
        .trim()
        .split("\n", 5)
        .slice(0, 4)
        .join("\n");
    if (masterHeader !== localHeader) {
        headerDiff = true;
    }
    diff_1.diffLines(baseReport.trim(), headReport.trim(), {
        newlineIsToken: true
    }).forEach((line, lineNumber) => {
        let lineStart = " ";
        if (line.added) {
            hasDiff = true;
            lineStart = "+";
        }
        else if (line.removed) {
            hasDiff = true;
            lineStart = "-";
        }
        line.value.split("\n").forEach((l, lineOffset) => {
            lineStart === "+" && change++;
            lineStart === "-" && change--;
            dupeDiff += lineStart + l + "\n";
        });
    });
    dupeDiff = "```diff\n" + dupeDiff + "\n```";
    // Check the PR to see if there's an existing dupe-report comment
    let existingPRComment;
    try {
        existingPRComment = await github.checkForPRCommentWithString(DUPE_IDENTIFIER);
    }
    catch (_c) {
        console.error("failed when trying to check to see if message existed on pr");
    }
    // If there's no diff, remove the existing comment (if it exists) and quit
    console.log("diff info", { hasDiff, headerDiff, change });
    if (!hasDiff || (change === 0 && !headerDiff)) {
        if (existingPRComment) {
            try {
                await github.deleteComment(existingPRComment.id);
            }
            catch (error) {
                console.error(`Failed to delete comment ${existingPRComment.id} in PR ${pullRequestURL}`, error);
            }
        }
        console.log(`No change in build #${buildNum} in PR ${pullRequestURL}, exiting...`);
        return;
    }
    // Grab the ticket assignees to mention in the PR comment body
    let assignees = [];
    try {
        assignees = await github.getAssignees();
    }
    catch (error) {
        console.error("failed to fetch assignees", error.message);
    }
    // Format the report and build up the comment body
    let prComment = `${DUPE_IDENTIFIER}\n\n`;
    prComment += format_report_1.formatReport(headReport, dupeDiff, change, assignees);
    // Update the existing PR comment or create a new one
    try {
        if (existingPRComment) {
            await github.updateComment(existingPRComment.id, prComment);
        }
        else {
            await github.createComment(prComment);
        }
    }
    catch (error) {
        console.error("failed to create dupe report comment with code", error.status);
    }
};
exports.dupeReport = dupeReport;