-
Notifications
You must be signed in to change notification settings - Fork 93
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: trigger Github actions from CircleCI (#1959)
This triggers Github Actions from CircleCi, so we can continue to use CircleCI as the workflow orchestrator, but run x86 macOS jobs on Github. --------- Co-authored-by: jonathanrainer <jonathan.rainer@apollographql.com>
- Loading branch information
1 parent
94580ec
commit b050603
Showing
7 changed files
with
170 additions
and
9 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
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
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
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,131 @@ | ||
| use std::time::Duration; | ||
|
|
||
| use anyhow::{anyhow, Result}; | ||
| use clap::Parser; | ||
| use octocrab::{models::RunId, Octocrab, OctocrabBuilder}; | ||
| use serde_json::json; | ||
|
|
||
| const WORKFLOW_GET_ID_TIMEOUT: Duration = Duration::from_secs(30); | ||
| const WORKFLOW_RUN_TIMEOUT: Duration = Duration::from_secs(600); | ||
| const WORKFLOW_WAIT_TIME: Duration = Duration::from_secs(2); | ||
|
|
||
| #[derive(Debug, Parser)] | ||
| pub struct GithubActions { | ||
| /// The GitHub workflow name | ||
| #[arg(long = "workflow-name", env = "WORKFLOW_NAME")] | ||
| pub(crate) workflow_name: String, | ||
|
|
||
| /// GitHub organization name | ||
| #[arg(long = "organization", default_value = "apollographql")] | ||
| pub(crate) organization: String, | ||
|
|
||
| /// GitHub repository name | ||
| #[arg(long = "repository", default_value = "rover")] | ||
| pub(crate) repository: String, | ||
|
|
||
| /// The repository branch to use | ||
| #[arg(long = "branch")] | ||
| pub(crate) branch: String, | ||
|
|
||
| /// The commit ID for this run | ||
| #[arg(long = "commit-id")] | ||
| pub(crate) commit_id: String, | ||
|
|
||
| /// A JSON document to use as inputs for GitHub Actions | ||
| #[arg(long = "inputs")] | ||
| pub(crate) inputs: String, | ||
| } | ||
|
|
||
| impl GithubActions { | ||
| pub async fn run(&self) -> Result<()> { | ||
| let token = std::env::var("GITHUB_ACTIONS_TOKEN") | ||
| .map_err(|_err| anyhow!("$GITHUB_ACTIONS_TOKEN is not set or is not valid UTF-8."))?; | ||
| let octocrab = OctocrabBuilder::new() | ||
| .personal_token(token.clone()) | ||
| .build()?; | ||
|
|
||
| // Find information about the current user | ||
| let user = octocrab.current().user().await?.login; | ||
|
|
||
| // Trigger GitHub workflow by sending a workflow dispatch event | ||
| // See <https://docs.github.com/en/rest/actions/workflows?apiVersion=2022-11-28#create-a-workflow-dispatch-event> | ||
| let inputs: serde_json::Value = serde_json::from_str(&self.inputs)?; | ||
| let res = octocrab | ||
| ._post( | ||
| format!( | ||
| "https://api.github.com/repos/{}/{}/actions/workflows/{}/dispatches", | ||
| self.organization, self.repository, self.workflow_name | ||
| ), | ||
| Some(&json!({ | ||
| "ref": self.branch, | ||
| "inputs": inputs, | ||
| })), | ||
| ) | ||
| .await?; | ||
|
|
||
| if !res.status().is_success() { | ||
| return Err(anyhow!( | ||
| "failed to start workflow, got status code {}", | ||
| res.status() | ||
| )); | ||
| } | ||
|
|
||
| // Find the corresponding workflow run ID | ||
| let fut = async { | ||
| loop { | ||
| match self.get_run_id(&octocrab, &user).await { | ||
| Ok(run_id) => return run_id, | ||
| Err(_err) => { | ||
| tokio::time::sleep(WORKFLOW_WAIT_TIME).await; | ||
| } | ||
| } | ||
| } | ||
| }; | ||
| let run_id = tokio::time::timeout(WORKFLOW_GET_ID_TIMEOUT, fut).await?; | ||
|
|
||
| crate::info!("monitoring run {}", run_id); | ||
|
|
||
| match self.check_run(&octocrab, run_id).await { | ||
| Ok(()) => crate::info!("run {} completed successfully", run_id), | ||
| Err(_err) => crate::info!("run {} failed or did not complete in time", run_id), | ||
| } | ||
|
|
||
| Ok(()) | ||
| } | ||
|
|
||
| async fn get_run_id(&self, octocrab: &Octocrab, login: &str) -> Result<RunId> { | ||
| Ok(octocrab | ||
| .workflows(&self.organization, &self.repository) | ||
| .list_runs(&self.workflow_name) | ||
| .branch(&self.branch) | ||
| .event("workflow_dispatch") | ||
| .actor(login) | ||
| .send() | ||
| .await? | ||
| .into_iter() | ||
| .find(|run| run.head_commit.id == self.commit_id) | ||
| .ok_or_else(|| anyhow!("could not find a matching run on GitHub"))? | ||
| .id) | ||
| } | ||
|
|
||
| async fn check_run(&self, octocrab: &Octocrab, run_id: RunId) -> Result<()> { | ||
| let fut = async { | ||
| loop { | ||
| let run = octocrab | ||
| .workflows(&self.organization, &self.repository) | ||
| .get(run_id) | ||
| .await?; | ||
|
|
||
| match run.status.as_str() { | ||
| "completed" => return Ok(()), | ||
| "failure" => return Err(anyhow!("GitHub workflow run failed")), | ||
| _ => { | ||
| tokio::time::sleep(WORKFLOW_WAIT_TIME).await; | ||
| } | ||
| } | ||
| } | ||
| }; | ||
|
|
||
| tokio::time::timeout(WORKFLOW_RUN_TIMEOUT, fut).await? | ||
| } | ||
| } |
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