Skip to content

Commit

Permalink
chore: added some print statements
Browse files Browse the repository at this point in the history
  • Loading branch information
@jburns24
jburns24 committed Dec 11, 2024
1 parent 4130a7f commit d095142
Showing 1 changed file with 129 additions and 92 deletions.
221 changes: 129 additions & 92 deletions index.js
View file
Original file line number Diff line number Diff line change
@@ -1,23 +1,25 @@
const core = require('@actions/core');
const github = require('@actions/github');
const fs = require('fs');
const core = require("@actions/core");
const github = require("@actions/github");
const fs = require("fs");

const expandDetailsComment = core.getBooleanInput('expand-comment');
const includePlanSummary = core.getBooleanInput('include-plan-job-summary');
const myToken = core.getInput('github-token');
const expandDetailsComment = core.getBooleanInput("expand-comment");
const includePlanSummary = core.getBooleanInput("include-plan-job-summary");
const myToken = core.getInput("github-token");
const octokit = github.getOctokit(myToken);
const context = github.context;
const inputFilenames = core.getMultilineInput('json-file');
const commentHeader = core.getMultilineInput('comment-header');
const commentFooter = core.getMultilineInput('comment-footer');
const quietMode = core.getBooleanInput('quiet');
const includeLinkToWorkflow = core.getBooleanInput('include-workflow-link');
const hidePreviousComments = core.getBooleanInput('hide-previous-comments');
const logChangedResources = core.getBooleanInput('log-changed-resources');

const workflowLink = includeLinkToWorkflow ? `
[Workflow: ${context.workflow}](${context.serverUrl}/${context.repo.owner}/${context.repo.repo}/actions/runs/${context.runId })
` : "";
const inputFilenames = core.getMultilineInput("json-file");
const commentHeader = core.getMultilineInput("comment-header");
const commentFooter = core.getMultilineInput("comment-footer");
const quietMode = core.getBooleanInput("quiet");
const includeLinkToWorkflow = core.getBooleanInput("include-workflow-link");
const hidePreviousComments = core.getBooleanInput("hide-previous-comments");
const logChangedResources = core.getBooleanInput("log-changed-resources");

const workflowLink = includeLinkToWorkflow
? `
[Workflow: ${context.workflow}](${context.serverUrl}/${context.repo.owner}/${context.repo.repo}/actions/runs/${context.runId})
`
: "";

var hasNoChanges = false;

Expand Down Expand Up @@ -47,17 +49,17 @@ const commentsQuery = /* GraphQL */ `
`;

const output = () => {
let body = '';
let body = "";
// for each file
for (const file of inputFilenames) {
const resource_changes = JSON.parse(fs.readFileSync(file)).resource_changes;
try {
let changed_resources = resource_changes.filter((resource) => {
return resource.change.actions != ["no-op"];
})
});

if (logChangedResources) {
console.log("changed_resources", changed_resources)
console.log("changed_resources", changed_resources);
}
if (Array.isArray(resource_changes) && resource_changes.length > 0) {
const resources_to_create = [],
Expand Down Expand Up @@ -106,26 +108,36 @@ ${details("delete", resources_to_delete, "-")}
${details("update", resources_to_update, "!")}
${details("replace", resources_to_replace, "+")}
</details>
${commentFooter.map(a => a == '' ? '\n' : a).join('\n')}
${commentFooter.map((a) => (a == "" ? "\n" : a)).join("\n")}
${workflowLink}
`
if (resources_to_create + resources_to_delete + resources_to_update + resources_to_replace == []) {
`;
if (
resources_to_create +
resources_to_delete +
resources_to_update +
resources_to_replace ==
[]
) {
hasNoChanges = true;
}
} else {
hasNoChanges = true;
console.log("No changes found in the plan. setting hasNoChanges to true.")
console.log(
"No changes found in the plan. setting hasNoChanges to true.",
);
body += `
<p>There were no changes done to the infrastructure.</p>
`
core.info(`"The content of ${file} did not result in a valid array or the array is empty... Skipping."`)
`;
core.info(
`"The content of ${file} did not result in a valid array or the array is empty... Skipping."`,
);
}
} catch (error) {
core.error(`${file} is not a valid JSON file. error: ${error}`);
}
}
return body;
}
};

const details = (action, resources, operator) => {
let str = "";
Expand All @@ -138,23 +150,23 @@ const details = (action, resources, operator) => {
for (const el of resources) {
// In the replace block, we show delete (-) and then create (+)
if (action === "replace") {
str += `- ${el}\n`
str += `- ${el}\n`;
}
str += `${operator} ${el}\n`
str += `${operator} ${el}\n`;
}

str += "```\n"
str += "```\n";
}

return str;
}
};

const queryComments = (variables) => {
return octokit.graphql(commentsQuery, variables);
return octokit.graphql(commentsQuery, variables);
};

const minimizeComment = (variables) => {
return octokit.graphql(minimizeCommentQuery, variables);
return octokit.graphql(minimizeCommentQuery, variables);
};

const hideComments = () => {
Expand All @@ -163,85 +175,110 @@ const hideComments = () => {
queryComments({
owner: context.repo.owner,
name: context.repo.repo,
number: context.issue.number
number: context.issue.number,
})
.then(response => {
core.info(`Successfully retrieved comments for PR #${context.issue.number}.`);
.then((response) => {
core.info(
`Successfully retrieved comments for PR #${context.issue.number}.`,
);
const comments = response.repository.pullRequest.comments.nodes;

core.info(`Found ${comments.length} comments in the PR.`);

filteredComments = comments.filter(comment =>
comment.body.includes('Terraform Plan:') ||
comment.body.includes('There were no changes done to the infrastructure.')
core.info(`Comment header used for matching is: ${commentHeader}`);

filteredComments = comments.filter(
(comment) =>
comment.body.includes("Terraform Plan:") ||
comment.body.includes(
"There were no changes done to the infrastructure.",
),
);
filteredComments = filteredComments.filter(comment =>
comment.body.includes(commentHeader)

core.info(
`Filtered down to ${filteredComments.length} comments created by this action.`,
);

core.info(`Filtered down to ${filteredComments.length} comments that need to be minimized.`);
filteredComments = filteredComments.filter((comment) =>
comment.body.includes(commentHeader),
);

core.info(
`Filtered down to ${filteredComments.length} comments that need to be minimized.`,
);

const minimizePromises = filteredComments
.filter(comment => !comment.isMinimized)
.map(comment => {
return minimizeComment({ id: comment.id })
.catch(error => core.error(`Failed to minimize comment ${comment.id}: ${error.message}`));
.filter((comment) => !comment.isMinimized)
.map((comment) => {
return minimizeComment({ id: comment.id }).catch((error) =>
core.error(
`Failed to minimize comment ${comment.id}: ${error.message}`,
),
);
});

return Promise.all(minimizePromises)
.then(() => core.info('All minimize operations completed.'))
.catch(error => core.error(`Error during minimize operations: ${error.message}`));
.then(() => core.info("All minimize operations completed."))
.catch((error) =>
core.error(`Error during minimize operations: ${error.message}`),
);
})
.catch(error => core.error(`Failed to retrieve comments: ${error.message}`));
.catch((error) =>
core.error(`Failed to retrieve comments: ${error.message}`),
);
};


try {
let rawOutput = output();
let createComment = true;

console.log("hidePreviousComments", hidePreviousComments)
console.log("hidePreviousComments && context.eventName === pull_request", hidePreviousComments && context.eventName === 'pull_request')
if (hidePreviousComments && context.eventName === 'pull_request') {
hideComments();
}
let rawOutput = output();
let createComment = true;

console.log("includePlanSummary", includePlanSummary)
if (includePlanSummary) {
core.info("Adding plan output to job summary")
core.summary.addHeading('Terraform Plan Results').addRaw(rawOutput).write()
}
console.log("hidePreviousComments", hidePreviousComments);
console.log(
"hidePreviousComments && context.eventName === pull_request",
hidePreviousComments && context.eventName === "pull_request",
);
if (hidePreviousComments && context.eventName === "pull_request") {
hideComments();
}

console.log("quietMode", quietMode)
console.log("hasNoChanges", hasNoChanges)
console.log("quietMode && hasNoChanges", quietMode && hasNoChanges)
if (quietMode && hasNoChanges) {
core.info("quiet mode is enabled and there are no changes to the infrastructure.")
core.info("Skipping comment creation.")
createComment = false
}
console.log("includePlanSummary", includePlanSummary);
if (includePlanSummary) {
core.info("Adding plan output to job summary");
core.summary.addHeading("Terraform Plan Results").addRaw(rawOutput).write();
}

if (context.eventName === 'pull_request') {
core.info(`Found PR # ${context.issue.number} from workflow context - proceeding to comment.`)
} else {
core.info("Action doesn't seem to be running in a PR workflow context.")
core.info("Skipping comment creation.")
createComment = false
}
console.log("quietMode", quietMode);
console.log("hasNoChanges", hasNoChanges);
console.log("quietMode && hasNoChanges", quietMode && hasNoChanges);
if (quietMode && hasNoChanges) {
core.info(
"quiet mode is enabled and there are no changes to the infrastructure.",
);
core.info("Skipping comment creation.");
createComment = false;
}

if (createComment) {
core.info("Adding comment to PR");
core.info(`Comment: ${rawOutput}`);
octokit.rest.issues.createComment({
issue_number: context.issue.number,
owner: context.repo.owner,
repo: context.repo.repo,
body: rawOutput
});
core.info("Comment added successfully.");
}
if (context.eventName === "pull_request") {
core.info(
`Found PR # ${context.issue.number} from workflow context - proceeding to comment.`,
);
} else {
core.info("Action doesn't seem to be running in a PR workflow context.");
core.info("Skipping comment creation.");
createComment = false;
}

if (createComment) {
core.info("Adding comment to PR");
core.info(`Comment: ${rawOutput}`);
octokit.rest.issues.createComment({
issue_number: context.issue.number,
owner: context.repo.owner,
repo: context.repo.repo,
body: rawOutput,
});
core.info("Comment added successfully.");
}
} catch (error) {
core.setFailed(error.message);
}
core.setFailed(error.message);
}

0 comments on commit d095142

Please sign in to comment.