Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Proposal To Allow An Array of Repos #23

Open
wants to merge 13 commits into
base: main
Choose a base branch
from
+578 −243
Open

Proposal To Allow An Array of Repos #23

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
c3872d1
Bump undici from 5.28.2 to 5.28.3
dependabot[bot] Feb 16, 2024
7174863
update deps
mattriordan1uphealth Apr 30, 2024
a7ac1fb
formatting
mattriordan1uphealth Apr 30, 2024
3f93753
save repo array input
mattriordan1uphealth Apr 30, 2024
a302011
est
mattriordan1uphealth Apr 30, 2024
76e6dfa
allow run
mattriordan1uphealth Apr 30, 2024
f41b682
test repo to run
mattriordan1uphealth Apr 30, 2024
e065044
remove defaults
mattriordan1uphealth Apr 30, 2024
5acf809
add logs
mattriordan1uphealth Apr 30, 2024
88d2dd4
parse as array
mattriordan1uphealth Apr 30, 2024
f9295b6
remove logs
mattriordan1uphealth Apr 30, 2024
1a24f9f
update readme
mattriordan1uphealth Apr 30, 2024
03eefb1
Merge pull request #1 from 1uphealth/test
mattriordan1uphealth Apr 30, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
formatting
@mattriordan1uphealth
mattriordan1uphealth committed Apr 30, 2024

Verified

This commit was signed with the committer’s verified signature.
ddl-ebrown Ethan Brown (Domino)
SSH Key Fingerprint: 4U9a/KMSneags73tZMOcWeHKE906fcmKOO/JXDOULz0
Verified
Learn about vigilant mode
commit a7ac1fbbd74bb10d0754e90cf9acbe9b86f1bb00
193 changes: 126 additions & 67 deletions dist/index.js
View file
Original file line number Diff line number Diff line change
@@ -2,21 +2,31 @@ async function run() {
const core = require("@actions/core");
try {
// Fetch all the inputs
const token = core.getInput('token');
const url = core.getInput('baseUrl');
const repository = core.getInput('repository');
const retain_days = Number(core.getInput('retain_days'));
const keep_minimum_runs = Number(core.getInput('keep_minimum_runs'));
const delete_workflow_pattern = core.getInput('delete_workflow_pattern');
const delete_workflow_by_state_pattern = core.getInput('delete_workflow_by_state_pattern');
const delete_run_by_conclusion_pattern = core.getInput('delete_run_by_conclusion_pattern');
const dry_run = core.getInput('dry_run');
const check_branch_existence = core.getInput("check_branch_existence")
const check_pullrequest_exist = core.getInput("check_pullrequest_exist")
const token = core.getInput("token");
const url = core.getInput("baseUrl");
const repository = core.getInput("repository");
const retain_days = Number(core.getInput("retain_days"));
const keep_minimum_runs = Number(core.getInput("keep_minimum_runs"));
const delete_workflow_pattern = core.getInput("delete_workflow_pattern");
const delete_workflow_by_state_pattern = core.getInput(
"delete_workflow_by_state_pattern"
);
const delete_run_by_conclusion_pattern = core.getInput(
"delete_run_by_conclusion_pattern"
);
const dry_run = core.getInput("dry_run");
const check_branch_existence = core.getInput("check_branch_existence");
const check_pullrequest_exist = core.getInput("check_pullrequest_exist");
// Split the input 'repository' (format {owner}/{repo}) to be {owner} and {repo}
const splitRepository = repository.split('/');
if (splitRepository.length !== 2 || !splitRepository[0] || !splitRepository[1]) {
throw new Error(`Invalid repository '${repository}'. Expected format {owner}/{repo}.`);
const splitRepository = repository.split("/");
if (
splitRepository.length !== 2 ||
!splitRepository[0] ||
!splitRepository[1]
) {
throw new Error(
`Invalid repository '${repository}'. Expected format {owner}/{repo}.`
);
}
const repo_owner = splitRepository[0];
const repo_name = splitRepository[1];
@@ -30,7 +40,7 @@ async function run() {
throttle: {
onRateLimit: (retryAfter, options, octokit, retryCount) => {
octokit.log.warn(
`Request quota exhausted for request ${options.method} ${options.url}`,
`Request quota exhausted for request ${options.method} ${options.url}`
);
if (retryCount < 1) {
// only retries once
@@ -41,26 +51,30 @@ async function run() {
onSecondaryRateLimit: (retryAfter, options, octokit) => {
// does not retry, only logs a warning
octokit.log.warn(
`SecondaryRateLimit detected for request ${options.method} ${options.url}`,
`SecondaryRateLimit detected for request ${options.method} ${options.url}`
);
},
},
});
let workflows = await octokit
.paginate("GET /repos/:owner/:repo/actions/workflows", {
let workflows = await octokit.paginate(
"GET /repos/:owner/:repo/actions/workflows",
{
owner: repo_owner,
repo: repo_name,
});
}
);

let workflow_ids = workflows.map(w => w.id);
let workflow_ids = workflows.map((w) => w.id);

// Gets all workflow runs for the repository
// see https://docs.github.com/en/rest/actions/workflow-runs?apiVersion=2022-11-28#list-workflow-runs-for-a-repository
let all_runs = await octokit
.paginate('GET /repos/:owner/:repo/actions/runs', {
let all_runs = await octokit.paginate(
"GET /repos/:owner/:repo/actions/runs",
{
owner: repo_owner,
repo: repo_name,
});
}
);

// Creates the delete runs array, and adds the runs that don't have a workflow associated with it
let del_runs = new Array();
@@ -78,127 +92,172 @@ async function run() {
// Execute the API "Delete a workflow run", see 'https://octokit.github.io/rest.js/v18#actions-delete-workflow-run'

if (dry_run) {
console.log(`[dry-run] 🚀 Delete run ${del.id} of '${del.name}' workflow`);
console.log(
`[dry-run] 🚀 Delete run ${del.id} of '${del.name}' workflow`
);
continue;
}

await octokit.actions.deleteWorkflowRun({
owner: repo_owner,
repo: repo_name,
run_id: del.id
run_id: del.id,
});

console.log(`🚀 Delete run ${del.id} of '${del.name}' workflow`);
}

if (delete_workflow_pattern) {
console.log(`💬 workflows containing '${delete_workflow_pattern}' will be targeted`);
workflows = workflows.filter(
({ name, path }) => {
const filename = path.replace(".github/workflows/");
return [name, filename].some(x => x.indexOf(delete_workflow_pattern) !== -1);
}
console.log(
`💬 workflows containing '${delete_workflow_pattern}' will be targeted`
);
workflows = workflows.filter(({ name, path }) => {
const filename = path.replace(".github/workflows/");
return [name, filename].some(
(x) => x.indexOf(delete_workflow_pattern) !== -1
);
});
}

if (delete_workflow_by_state_pattern && delete_workflow_by_state_pattern.toUpperCase() !== "ALL") {
console.log(`💬 workflows containing state '${delete_workflow_by_state_pattern}' will be targeted`);
workflows = workflows.filter(
({ state }) => delete_workflow_by_state_pattern.split(",").map(x => x.trim()).includes(state)
if (
delete_workflow_by_state_pattern &&
delete_workflow_by_state_pattern.toUpperCase() !== "ALL"
) {
console.log(
`💬 workflows containing state '${delete_workflow_by_state_pattern}' will be targeted`
);
workflows = workflows.filter(({ state }) =>
delete_workflow_by_state_pattern
.split(",")
.map((x) => x.trim())
.includes(state)
);
}

let branches = await octokit
.paginate("GET /repos/:owner/:repo/branches", {
owner: repo_owner,
repo: repo_name,
})
let branches = await octokit.paginate("GET /repos/:owner/:repo/branches", {
owner: repo_owner,
repo: repo_name,
});

let branchNames = branches.map(a => a.name);
let branchNames = branches.map((a) => a.name);

console.log(`💬 found total of ${workflows.length} workflow(s)`);
for (const workflow of workflows) {
core.debug(`Workflow: ${workflow.name} ${workflow.id} ${workflow.state}`);
let del_runs = new Array();
let Skip_runs = new Array();
// Execute the API "List workflow runs for a repository", see 'https://octokit.github.io/rest.js/v18#actions-list-workflow-runs-for-repo'
const runs = await octokit
.paginate("GET /repos/:owner/:repo/actions/workflows/:workflow_id/runs", {
const runs = await octokit.paginate(
"GET /repos/:owner/:repo/actions/workflows/:workflow_id/runs",
{
owner: repo_owner,
repo: repo_name,
workflow_id: workflow.id
});
workflow_id: workflow.id,
}
);

for (const run of runs) {
core.debug(`Run: '${workflow.name}' workflow run ${run.id} (status=${run.status})`)
core.debug(
`Run: '${workflow.name}' workflow run ${run.id} (status=${run.status})`
);

if (run.status !== "completed") {
console.log(`👻 Skipped '${workflow.name}' workflow run ${run.id}: it is in '${run.status}' state`);
console.log(
`👻 Skipped '${workflow.name}' workflow run ${run.id}: it is in '${run.status}' state`
);
continue;
}

if (check_pullrequest_exist && run.pull_requests.length > 0) {
console.log(` Skipping '${workflow.name}' workflow run ${run.id} because PR is attached.`);
console.log(
` Skipping '${workflow.name}' workflow run ${run.id} because PR is attached.`
);
continue;
}

if (check_branch_existence && branchNames.indexOf(run.head_branch) === 1) {
console.log(` Skipping '${workflow.name}' workflow run ${run.id} because branch is still active.`);
if (
check_branch_existence &&
branchNames.indexOf(run.head_branch) === 1
) {
console.log(
` Skipping '${workflow.name}' workflow run ${run.id} because branch is still active.`
);
continue;
}

if (delete_run_by_conclusion_pattern
&& !delete_run_by_conclusion_pattern.split(",").map(x => x.trim()).includes(run.conclusion)
&& delete_run_by_conclusion_pattern.toUpperCase() !== "ALL") {
core.debug(` Skipping '${workflow.name}' workflow run ${run.id} because conclusion was ${run.conclusion}`);
if (
delete_run_by_conclusion_pattern &&
!delete_run_by_conclusion_pattern
.split(",")
.map((x) => x.trim())
.includes(run.conclusion) &&
delete_run_by_conclusion_pattern.toUpperCase() !== "ALL"
) {
core.debug(
` Skipping '${workflow.name}' workflow run ${run.id} because conclusion was ${run.conclusion}`
);
continue;
}
const created_at = new Date(run.created_at);
const current = new Date();
const ELAPSE_ms = current.getTime() - created_at.getTime();
const ELAPSE_days = ELAPSE_ms / (1000 * 3600 * 24);
if (ELAPSE_days >= retain_days) {
core.debug(` Added to del list '${workflow.name}' workflow run ${run.id}`);
core.debug(
` Added to del list '${workflow.name}' workflow run ${run.id}`
);
del_runs.push(run);
}
else {
console.log(`👻 Skipped '${workflow.name}' workflow run ${run.id}: created at ${run.created_at}`);
} else {
console.log(
`👻 Skipped '${workflow.name}' workflow run ${run.id}: created at ${run.created_at}`
);
}
}
core.debug(`Delete list for '${workflow.name}' is ${del_runs.length} items`);
core.debug(
`Delete list for '${workflow.name}' is ${del_runs.length} items`
);
const arr_length = del_runs.length - keep_minimum_runs;
if (arr_length > 0) {
del_runs = del_runs.sort((a, b) => { return a.id - b.id; });
del_runs = del_runs.sort((a, b) => {
return a.id - b.id;
});
if (keep_minimum_runs !== 0) {
Skip_runs = del_runs.slice(-keep_minimum_runs);
del_runs = del_runs.slice(0, -keep_minimum_runs);
for (const Skipped of Skip_runs) {
console.log(`👻 Skipped '${workflow.name}' workflow run ${Skipped.id}: created at ${Skipped.created_at}`);
console.log(
`👻 Skipped '${workflow.name}' workflow run ${Skipped.id}: created at ${Skipped.created_at}`
);
}
}
core.debug(`Deleting ${del_runs.length} runs for '${workflow.name}' workflow`);
core.debug(
`Deleting ${del_runs.length} runs for '${workflow.name}' workflow`
);
for (const del of del_runs) {
core.debug(`Deleting '${workflow.name}' workflow run ${del.id}`);
// Execute the API "Delete a workflow run", see 'https://octokit.github.io/rest.js/v18#actions-delete-workflow-run'

if (dry_run) {
console.log(`[dry-run] 🚀 Delete run ${del.id} of '${workflow.name}' workflow`);
console.log(
`[dry-run] 🚀 Delete run ${del.id} of '${workflow.name}' workflow`
);
continue;
}

await octokit.actions.deleteWorkflowRun({
owner: repo_owner,
repo: repo_name,
run_id: del.id
run_id: del.id,
});

console.log(`🚀 Delete run ${del.id} of '${workflow.name}' workflow`);
}
console.log(`✅ ${arr_length} runs of '${workflow.name}' workflow deleted.`);
console.log(
`✅ ${arr_length} runs of '${workflow.name}' workflow deleted.`
);
}
}
}
catch (error) {
} catch (error) {
core.setFailed(error.message);
}
}