Implement PUT /api/v1/trusted_publishing/github_configs API endpoint

Author: Turbo87

src/controllers.rs

@@ -13,5 +13,6 @@ pub mod site_metadata;
 pub mod summary;
 pub mod team;
 pub mod token;
+pub mod trustpub;
 pub mod user;
 pub mod version;

src/controllers/trustpub/github_configs/create/mod.rs

@@ -0,0 +1,129 @@
+use crate::app::AppState;
+use crate::auth::AuthCheck;
+use crate::controllers::krate::load_crate;
+use crate::controllers::trustpub::github_configs::emails::ConfigCreatedEmail;
+use crate::controllers::trustpub::github_configs::json;
+use crate::util::errors::{AppResult, bad_request};
+use axum::Json;
+use crates_io_database::models::OwnerKind;
+use crates_io_database::models::trustpub::NewGitHubConfig;
+use crates_io_database::schema::{crate_owners, emails, users};
+use crates_io_github::GitHubError;
+use crates_io_trustpub::github::validation::{
+    validate_environment, validate_owner, validate_repo, validate_workflow_filename,
+};
+use diesel::prelude::*;
+use diesel_async::RunQueryDsl;
+use http::request::Parts;
+use oauth2::AccessToken;
+use secrecy::ExposeSecret;
+
+#[cfg(test)]
+mod tests;
+
+/// Create a new Trusted Publishing configuration for GitHub Actions.
+#[utoipa::path(
+    put,
+    path = "/api/v1/trusted_publishing/github_configs",
+    security(("cookie" = [])),
+    request_body = inline(json::CreateRequest),
+    tag = "trusted_publishing",
+    responses((status = 200, description = "Successful Response", body = inline(json::CreateResponse))),
+)]
+pub async fn trustpub_create_github_config(
+    state: AppState,
+    parts: Parts,
+    Json(json): Json<json::CreateRequest>,
+) -> AppResult<Json<json::CreateResponse>> {
+    let json_config = json.github_config;
+
+    validate_owner(&json_config.repository_owner)?;
+    validate_repo(&json_config.repository_name)?;
+    validate_workflow_filename(&json_config.workflow_filename)?;
+    if let Some(env) = &json_config.environment {
+        validate_environment(env)?;
+    }
+
+    let mut conn = state.db_write().await?;
+
+    let auth = AuthCheck::only_cookie().check(&parts, &mut conn).await?;
+    let auth_user = auth.user();
+
+    let krate = load_crate(&mut conn, &json_config.krate).await?;
+
+    let user_owners = crate_owners::table
+        .filter(crate_owners::crate_id.eq(krate.id))
+        .filter(crate_owners::deleted.eq(false))
+        .filter(crate_owners::owner_kind.eq(OwnerKind::User))
+        .inner_join(users::table)
+        .inner_join(emails::table.on(users::id.eq(emails::user_id)))
+        .select((users::id, users::gh_login, emails::email, emails::verified))
+        .load::<(i32, String, String, bool)>(&mut conn)
+        .await?;
+
+    if !user_owners.iter().any(|owner| owner.0 == auth_user.id) {
+        return Err(bad_request("You are not an owner of this crate"));
+    }
+
+    // Lookup `repository_owner_id` via GitHub API
+
+    let owner = &json_config.repository_owner;
+    let gh_auth = &auth_user.gh_access_token;
+    let gh_auth = AccessToken::new(gh_auth.expose_secret().to_string());
+    let github_user = match state.github.get_user(owner, &gh_auth).await {
+        Ok(user) => user,
+        Err(GitHubError::NotFound(_)) => Err(bad_request("Unknown GitHub user or organization"))?,
+        Err(err) => Err(err)?,
+    };
+
+    // Save the new GitHub OIDC config to the database
+
+    let new_config = NewGitHubConfig {
+        crate_id: krate.id,
+        // Use the normalized owner name as provided by GitHub.
+        repository_owner: &github_user.login,
+        repository_owner_id: github_user.id,
+        repository_name: &json_config.repository_name,
+        workflow_filename: &json_config.workflow_filename,
+        environment: json_config.environment.as_deref(),
+    };
+
+    let saved_config = new_config.insert(&mut conn).await?;
+
+    // Send notification emails to crate owners
+
+    let recipients = user_owners
+        .into_iter()
+        .filter(|(_, _, _, verified)| *verified)
+        .map(|(_, login, email, _)| (login, email))
+        .collect::<Vec<_>>();
+
+    for (recipient, email_address) in &recipients {
+        let email = ConfigCreatedEmail {
+            recipient,
+            user: &auth_user.gh_login,
+            krate: &krate.name,
+            repository_owner: &saved_config.repository_owner,
+            repository_name: &saved_config.repository_name,
+            workflow_filename: &saved_config.workflow_filename,
+            environment: saved_config.environment.as_deref().unwrap_or("(not set)"),
+        };
+
+        if let Err(err) = state.emails.send(email_address, email).await {
+            warn!("Failed to send trusted publishing notification to {email_address}: {err}")
+        }
+    }
+
+    let github_config = json::GitHubConfig {
+        id: saved_config.id,
+        krate: krate.name,
+        repository_owner: saved_config.repository_owner,
+        repository_owner_id: saved_config.repository_owner_id,
+        repository_name: saved_config.repository_name,
+        workflow_filename: saved_config.workflow_filename,
+        environment: saved_config.environment,
+        created_at: saved_config.created_at,
+    };
+
+    Ok(Json(json::CreateResponse { github_config }))
+}

src/controllers/trustpub/github_configs/create/snapshots/crates_io__controllers__trustpub__github_configs__create__tests__happy_path-2.snap

@@ -0,0 +1,29 @@
+---
+source: src/controllers/trustpub/github_configs/create/tests.rs
+expression: app.emails_snapshot().await
+---
+To: foo@example.com
+From: crates.io <noreply@crates.io>
+Subject: crates.io: Trusted Publishing configration added to foo
+Content-Type: text/plain; charset=utf-8
+Content-Transfer-Encoding: quoted-printable
+
+Hello foo!
+
+crates.io user foo has added a new "Trusted Publishing" configuration for G=
+itHub Actions to a crate that you manage (foo). Trusted publishers act as t=
+rusted users and can publish new versions of the crate automatically.
+
+Trusted Publishing configuration:
+
+- Repository owner: rust-lang
+- Repository name: foo-rs
+- Workflow filename: publish.yml
+- Environment: (not set)
+
+If you did not make this change and you think it was made maliciously, you =
+can remove the configuration from the crate via the "Settings" tab on the c=
+rate's page.
+
+If you are unable to revert the change and need to do so, you can email hel=
+p@crates.io to communicate with the crates.io support team.

src/controllers/trustpub/github_configs/create/snapshots/crates_io__controllers__trustpub__github_configs__create__tests__happy_path.snap

@@ -0,0 +1,16 @@
+---
+source: src/controllers/trustpub/github_configs/create/tests.rs
+expression: response.json()
+---
+{
+  "github_config": {
+    "crate": "foo",
+    "created_at": "[datetime]",
+    "environment": null,
+    "id": 1,
+    "repository_name": "foo-rs",
+    "repository_owner": "rust-lang",
+    "repository_owner_id": 42,
+    "workflow_filename": "publish.yml"
+  }
+}

src/controllers/trustpub/github_configs/create/snapshots/crates_io__controllers__trustpub__github_configs__create__tests__happy_path_with_environment.snap

@@ -0,0 +1,16 @@
+---
+source: src/controllers/trustpub/github_configs/create/tests.rs
+expression: response.json()
+---
+{
+  "github_config": {
+    "crate": "foo",
+    "created_at": "[datetime]",
+    "environment": "production",
+    "id": 1,
+    "repository_name": "foo-rs",
+    "repository_owner": "rust-lang",
+    "repository_owner_id": 42,
+    "workflow_filename": "publish.yml"
+  }
+}