Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
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
112 changes: 112 additions & 0 deletions src/controllers/trustpub/gitlab_configs/delete.rs
Original file line number Diff line number Diff line change
@@ -0,0 +1,112 @@
use crate::app::AppState;
use crate::auth::AuthCheck;
use crate::controllers::trustpub::emails::{ConfigDeletedEmail, ConfigType};
use crate::util::errors::{AppResult, bad_request, not_found};
use anyhow::Context;
use axum::extract::Path;
use crates_io_database::models::token::EndpointScope;
use crates_io_database::models::trustpub::GitLabConfig;
use crates_io_database::models::{Crate, OwnerKind};
use crates_io_database::schema::{crate_owners, crates, emails, trustpub_configs_gitlab, users};
use diesel::prelude::*;
use diesel_async::RunQueryDsl;
use http::StatusCode;
use http::request::Parts;
use tracing::warn;

/// Delete Trusted Publishing configuration for GitLab CI/CD.
#[utoipa::path(
delete,
path = "/api/v1/trusted_publishing/gitlab_configs/{id}",
params(
("id" = i32, Path, description = "ID of the Trusted Publishing configuration"),
),
security(("cookie" = []), ("api_token" = [])),
tag = "trusted_publishing",
responses((status = 204, description = "Successful Response")),
)]
pub async fn delete_trustpub_gitlab_config(
state: AppState,
Path(id): Path<i32>,
parts: Parts,
) -> AppResult<StatusCode> {
let mut conn = state.db_write().await?;

// First, find the config and crate to get the crate name for scope validation
let (config, krate) = trustpub_configs_gitlab::table
.inner_join(crates::table)
.filter(trustpub_configs_gitlab::id.eq(id))
.select((GitLabConfig::as_select(), Crate::as_select()))
.first::<(GitLabConfig, Crate)>(&mut conn)
.await
.optional()?
.ok_or_else(not_found)?;

let auth = AuthCheck::default()
.with_endpoint_scope(EndpointScope::TrustedPublishing)
.for_crate(&krate.name)
.check(&parts, &mut conn)
.await?;
let auth_user = auth.user();

// Load all crate owners for the given crate ID
let user_owners = crate_owners::table
.filter(crate_owners::crate_id.eq(config.crate_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?;

// Check if the authenticated user is an owner of the crate
if !user_owners.iter().any(|owner| owner.0 == auth_user.id) {
return Err(bad_request("You are not an owner of this crate"));
}

// Delete the configuration from the database
diesel::delete(trustpub_configs_gitlab::table.filter(trustpub_configs_gitlab::id.eq(id)))
.execute(&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 config = ConfigType::GitLab(&config);

let context = ConfigDeletedEmail {
recipient,
auth_user,
krate: &krate,
config,
};

if let Err(err) = send_notification_email(&state, email_address, context).await {
warn!("Failed to send trusted publishing notification to {email_address}: {err}");
}
}

Ok(StatusCode::NO_CONTENT)
}

async fn send_notification_email(
state: &AppState,
email_address: &str,
context: ConfigDeletedEmail<'_>,
) -> anyhow::Result<()> {
let email = context.render();
let email = email.context("Failed to render email template")?;

state
.emails
.send(email_address, email)
.await
.context("Failed to send email")
}
1 change: 1 addition & 0 deletions src/controllers/trustpub/gitlab_configs/mod.rs
Original file line number Diff line number Diff line change
@@ -1,2 +1,3 @@
pub mod create;
pub mod delete;
pub mod json;
1 change: 1 addition & 0 deletions src/router.rs
Original file line number Diff line number Diff line change
Expand Up @@ -100,6 +100,7 @@ pub fn build_axum_router(state: AppState) -> Router<()> {
))
.routes(routes!(
trustpub::gitlab_configs::create::create_trustpub_gitlab_config,
trustpub::gitlab_configs::delete::delete_trustpub_gitlab_config,
))
.split_for_parts();

Expand Down
Loading