System Initiative

use axum::extract::{ Host, OriginalUri, Path, }; use dal::{ ChangeSet, ChangeSetId, Func, FuncId, WorkspacePk, func::authoring::FuncAuthoringClient, }; use si_events::audit_log::AuditLogKind; use super::FuncAPIResult; use crate::{ extract::{ HandlerContext, PosthogClient, }, service::{ force_change_set_response::ForceChangeSetResponse, v2::AccessBuilder, }, track, }; pub async fn execute_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<()>> { let mut ctx = builder .build(access_builder.build(change_set_id.into())) .await?; let force_change_set_id = ChangeSet::force_new(&mut ctx).await?; FuncAuthoringClient::execute_func(&ctx, func_id).await?; let func = Func::get_by_id(&ctx, func_id).await?; ctx.write_audit_log( AuditLogKind::ExecuteFunc { func_id, func_display_name: func.display_name, }, func.name.to_owned(), ) .await?; track( &posthog_client, &ctx, &original_uri, &host_name, "execute_func", serde_json::json!({ "how": "/func/execute_func", "func_id": func_id, "func_name": func.name.clone(), }), ); ctx.commit().await?; Ok(ForceChangeSetResponse::empty(force_change_set_id)) }