System Initiative

use axum::extract::{ Host, OriginalUri, Path, }; use dal::{ ChangeSet, ChangeSetId, Func, FuncId, WorkspacePk, WsEvent, func::binding::FuncBinding, }; use serde::{ Deserialize, Serialize, }; use si_events::audit_log::AuditLogKind; use super::{ FuncAPIError, FuncAPIResult, }; use crate::{ extract::{ HandlerContext, PosthogClient, }, service::{ force_change_set_response::ForceChangeSetResponse, v2::AccessBuilder, }, track, }; #[derive(Deserialize, Serialize, Debug)] #[serde(rename_all = "camelCase")] pub struct DeleteFuncResponse { pub success: bool, pub name: String, } pub async fn delete_func( HandlerContext(builder): HandlerContext, AccessBuilder(access_builder): AccessBuilder, PosthogClient(posthog_client): PosthogClient, OriginalUri(original_uri): OriginalUri, Host(host_name): Host, Path((_workspace_pk, change_set_id, func_id)): Path<(WorkspacePk, ChangeSetId, FuncId)>, ) -> FuncAPIResult<ForceChangeSetResponse<DeleteFuncResponse>> { let mut ctx = builder .build(access_builder.build(change_set_id.into())) .await?; let func = Func::get_by_id(&ctx, func_id).await?; if func.is_locked { return Err(FuncAPIError::CannotDeleteLockedFunc(func_id)); } let force_change_set_id = ChangeSet::force_new(&mut ctx).await?; // first detach func from everywhere FuncBinding::delete_all_bindings_for_func_id(&ctx, func_id).await?; // then delete func let func_name = Func::delete_by_id(&ctx, func_id).await?; WsEvent::func_deleted(&ctx, func_id) .await? .publish_on_commit(&ctx) .await?; track( &posthog_client, &ctx, &original_uri, &host_name, "deleted_func", serde_json::json!({ "how": "/func/deleted_func", "func_id": func_id, "func_name": func.name.clone(), "func_kind": func.kind.clone(), }), ); ctx.write_audit_log( AuditLogKind::DeleteFunc { func_id, func_display_name: func.display_name, func_kind: func.kind.into(), }, func.name.clone(), ) .await?; ctx.commit().await?; Ok(ForceChangeSetResponse::new( force_change_set_id, DeleteFuncResponse { success: true, name: func_name, }, )) }