Something went wrong. Try again.
A lexicon-driven AppView for ATProto. forked from gamesgamesgamesgames.games/happyview
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273use axum::{Json, extract::State, http::StatusCode};
use crate::AppState;use crate::error::AppError;use crate::event_log::{EventLog, Severity, log_event};use crate::service_identity::{IdentityMode, get_identity, upsert_identity};
use super::auth::UserAuth;use super::permissions::Permission;
/// GET /admin/service-identity — return current identity config (or null).pub(super) async fn get( State(state): State<AppState>, auth: UserAuth,) -> Result<Json<serde_json::Value>, AppError> { auth.require(Permission::SettingsManage).await?;
let identity = get_identity(&state.db, state.db_backend).await?;
Ok(Json(match identity { Some(id) => serde_json::to_value(id) .map_err(|e| AppError::Internal(format!("failed to serialize identity: {e}")))?, None => serde_json::Value::Null, }))}
#[derive(Debug, serde::Deserialize)]pub(super) struct UpdateIdentityBody { pub mode: String, pub did: Option<String>, pub signing_key_enc: Option<String>, pub rotation_key_enc: Option<String>, pub attached_account_did: Option<String>,}
/// PUT /admin/service-identity — update identity config.pub(super) async fn update( State(state): State<AppState>, auth: UserAuth, Json(body): Json<UpdateIdentityBody>,) -> Result<StatusCode, AppError> { auth.require(Permission::SettingsManage).await?;
let mode = IdentityMode::parse(&body.mode) .ok_or_else(|| AppError::BadRequest(format!("invalid identity mode: {}", body.mode)))?;
upsert_identity( &state.db, state.db_backend, &mode, body.did.as_deref(), body.signing_key_enc.as_deref(), body.rotation_key_enc.as_deref(), body.attached_account_did.as_deref(), ) .await?;
log_event( &state.db, EventLog { event_type: "service_identity.updated".to_string(), severity: Severity::Info, actor_did: Some(auth.did.clone()), subject: None, detail: serde_json::json!({ "mode": body.mode }), }, state.db_backend, ) .await;
Ok(StatusCode::NO_CONTENT)}