-
Notifications
You must be signed in to change notification settings - Fork 4.9k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge origin/develop into master-sync
- Loading branch information
Showing
734 changed files
with
38,437 additions
and
12,531 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,211 @@ | ||
| const CIRCLE_TOKEN = process.env.API_V2_TOKEN; | ||
|
|
||
| interface Actor { | ||
| login: string; | ||
| avatar_url: string | null; | ||
| } | ||
|
|
||
| interface Trigger { | ||
| received_at: string; | ||
| type: string; | ||
| actor: Actor; | ||
| } | ||
|
|
||
| interface VCS { | ||
| origin_repository_url: string; | ||
| target_repository_url: string; | ||
| revision: string; | ||
| provider_name: string; | ||
| branch: string; | ||
| } | ||
|
|
||
| interface WorkflowItem { | ||
| id: string; | ||
| errors: string[]; | ||
| project_slug: string; | ||
| updated_at: string; | ||
| number: number; | ||
| state: string; | ||
| created_at: string; | ||
| trigger: Trigger; | ||
| vcs: VCS; | ||
| } | ||
|
|
||
| interface CircleCIResponse { | ||
| next_page_token: string | null; | ||
| items: WorkflowItem[]; | ||
| } | ||
|
|
||
| interface WorkflowStatusItem { | ||
| pipeline_id: string; | ||
| id: string; | ||
| name: string; | ||
| project_slug: string; | ||
| tag?: string; | ||
| status: string; | ||
| started_by: string; | ||
| pipeline_number: number; | ||
| created_at: string; | ||
| stopped_at: string; | ||
| } | ||
|
|
||
| interface WorkflowStatusResponse { | ||
| next_page_token: string | null; | ||
| items: WorkflowStatusItem[]; | ||
| } | ||
|
|
||
| /** | ||
| * Fetches the last 20 CircleCI workflows for the given branch. | ||
| * Note: the API returns the first 20 workflows by default. | ||
| * If we wanted to get older workflows, we would need to use the 'page-token' we would get in the first response | ||
| * and perform a subsequent request with the 'page-token' parameter. | ||
| * This seems unnecessary as of today, as the amount of daily PRs merged to develop is not that high. | ||
| * | ||
| * @returns {Promise<WorkflowItem[]>} A promise that resolves to an array of workflow items. | ||
| * @throws Will throw an error if the CircleCI token is not defined or if the HTTP request fails. | ||
| */ | ||
| async function getCircleCiWorkflowsByBranch(branch: string): Promise<WorkflowItem[]> { | ||
| if (!CIRCLE_TOKEN) { | ||
| throw new Error('CircleCI token is not defined'); | ||
| } | ||
|
|
||
| const url = `https://circleci.com/api/v2/project/github/${process.env.CIRCLE_PROJECT_USERNAME}/${process.env.CIRCLE_PROJECT_REPONAME}/pipeline?branch=${branch}`; | ||
| const options = { | ||
| method: 'GET', | ||
| headers: { | ||
| 'Content-Type': 'application/json', | ||
| } | ||
| }; | ||
|
|
||
| try { | ||
| const response = await fetch(url, options); | ||
| if (!response.ok) { | ||
| const errorBody = await response.text(); | ||
| console.error('HTTP error response:', errorBody); | ||
| throw new Error(`HTTP error! status: ${response.status}`); | ||
| } | ||
| const body = await response.json(); | ||
| console.log('Circle Ci workflows fetched successfully!'); | ||
| return body.items; | ||
| } catch (error) { | ||
| console.error('Error:', error); | ||
| throw error; | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Fetches the status of a specific CircleCI workflow. | ||
| * | ||
| * @param {string} workflowId - The ID of the workflow to fetch the status for. | ||
| * @returns {Promise<WorkflowStatusResponse>} A promise that resolves to the workflow status response. | ||
| * @throws Will throw an error if the CircleCI token is not defined or if the HTTP request fails. | ||
| */ | ||
| async function getWorkflowStatusById(workflowId: string): Promise<WorkflowStatusResponse> { | ||
| if (!CIRCLE_TOKEN) { | ||
| throw new Error('CircleCI token is not defined'); | ||
| } | ||
|
|
||
| const url = `https://circleci.com/api/v2/pipeline/${workflowId}/workflow`; | ||
| const options = { | ||
| method: 'GET', | ||
| headers: { | ||
| 'Content-Type': 'application/json', | ||
| } | ||
| }; | ||
|
|
||
| try { | ||
| console.log(`Fetching workflow ${workflowId}...`); | ||
|
|
||
| const response = await fetch(url, options); | ||
| if (!response.ok) { | ||
| const errorBody = await response.text(); | ||
| console.error('HTTP error response:', errorBody); | ||
| throw new Error(`HTTP error! status: ${response.status}`); | ||
| } | ||
| const workflowStatus = await response.json(); | ||
|
|
||
| console.log(`Number of runs: ${workflowStatus.items.length}`); | ||
| console.log(`Workflow status from last run: ${workflowStatus.items[0].status}`); | ||
|
|
||
| return workflowStatus; | ||
|
|
||
| } catch (error) { | ||
| console.error('Error:', error); | ||
| throw error; | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Reruns a CircleCI workflow by its ID. | ||
| * | ||
| * @param {string} workflowId - The ID of the workflow to rerun. | ||
| * @throws Will throw an error if the CircleCI token is not defined or if the HTTP request fails. | ||
| */ | ||
| async function rerunWorkflowById(workflowId: string) { | ||
| if (!CIRCLE_TOKEN) { | ||
| throw new Error('CircleCI token is not defined'); | ||
| } | ||
|
|
||
| const url = `https://circleci.com/api/v2/workflow/${workflowId}/rerun`; | ||
| const options = { | ||
| method: 'POST', | ||
| headers: { | ||
| 'Content-Type': 'application/json', | ||
| 'Circle-Token': CIRCLE_TOKEN, | ||
| }, | ||
| body: JSON.stringify({ | ||
| enable_ssh: false, | ||
| from_failed: true, | ||
| sparse_tree: false, // mutually exclusive with the from_failed parameter | ||
| }) | ||
| }; | ||
|
|
||
| try { | ||
| console.log(`Rerunning workflow ${workflowId}...`); | ||
| const response = await fetch(url, options); | ||
| if (!response.ok) { | ||
| const errorBody = await response.text(); | ||
| console.error('HTTP error response:', errorBody); | ||
| throw new Error(`HTTP error! status: ${response.status}`); | ||
| } | ||
| const body = await response.json(); | ||
| console.log('Workflow rerun successfully!'); | ||
| console.log(body); | ||
| } catch (error) { | ||
| console.error('Error:', error); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Re-runs failed CircleCI workflows from develop branch. | ||
| * The workflow will only be re-runed if: | ||
| * 1. It has the status of 'failed' | ||
| * 2. It has only been run once | ||
| * 3. It is among the most recent 20 workflows | ||
| * 4. It was triggered by the 'github-merge-queue[bot]' user | ||
| * | ||
| * @throws Will throw an error if fetching the workflows or re-running a workflow fails. | ||
| */ | ||
| async function rerunFailedWorkflowsFromDevelop() { | ||
| console.log('Getting Circle Ci workflows from develop branch...'); | ||
| const workflows = await getCircleCiWorkflowsByBranch('develop'); | ||
|
|
||
| console.log('Assessing if any of the workflows needs to be rerun...'); | ||
| for (const item of workflows) { | ||
| if (item.trigger.actor.login === 'github-merge-queue[bot]') { | ||
| const workflowStatus = await getWorkflowStatusById(item.id); | ||
|
|
||
| if (workflowStatus.items.length === 1 && workflowStatus.items[0].status === 'failed') { | ||
| await rerunWorkflowById(workflowStatus.items[0].id); | ||
| console.log(`Rerun workflow with ID: ${workflowStatus.items[0].id}`); | ||
| } | ||
| } | ||
| } | ||
| console.log('Task completed successfully!'); | ||
| } | ||
|
|
||
| rerunFailedWorkflowsFromDevelop() | ||
| .catch((error) => { | ||
| console.error(error); | ||
| process.exitCode = 1; | ||
| }); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.