use axum::{Json, extract::State};
use chrono::Utc;
use k256::ecdsa::SigningKey;
use serde::{Deserialize, Serialize};
use serde_json::Value;
use std::collections::HashMap;
use tracing::{error, info};
use tranquil_pds::api::ApiError;
use tranquil_pds::api::error::DbResultExt;
use tranquil_pds::auth::{Auth, Permissive};
use tranquil_pds::circuit_breaker::with_circuit_breaker;
use tranquil_pds::plc::{
    PlcError, PlcService, create_update_op, missing_required_rotation_key, sign_operation,
    signing_key_to_did_key,
};
use tranquil_pds::state::AppState;

#[derive(Debug, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct SignPlcOperationInput {
    pub token: Option<String>,
    pub rotation_keys: Option<Vec<String>>,
    pub also_known_as: Option<Vec<String>>,
    pub verification_methods: Option<HashMap<String, String>>,
    pub services: Option<HashMap<String, PlcService>>,
}

#[derive(Debug, Serialize)]
pub struct SignPlcOperationOutput {
    pub operation: Value,
}

pub async fn sign_plc_operation(
    State(state): State<AppState>,
    auth: Auth<Permissive>,
    Json(input): Json<SignPlcOperationInput>,
) -> Result<Json<SignPlcOperationOutput>, ApiError> {
    tranquil_pds::auth::scope_check::check_identity_scope(
        &auth.auth_source,
        auth.scope.as_deref(),
        tranquil_pds::oauth::scopes::IdentityAttr::Wildcard,
    )?;
    let did = &auth.did;
    if did.starts_with("did:web:") {
        return Err(ApiError::InvalidRequest(
            "PLC operations are only valid for did:plc identities".into(),
        ));
    }
    let raw_token = input.token.as_ref().ok_or_else(|| {
        ApiError::InvalidRequest("Email confirmation token required to sign PLC operations".into())
    })?;
    let token = &tranquil_pds::util::normalize_token_code(raw_token);

    let user_id = state
        .repos
        .user
        .get_id_by_did(did)
        .await
        .log_db_err("fetching user id")?
        .ok_or(ApiError::AccountNotFound)?;

    let token_expiry = state
        .repos
        .infra
        .get_plc_token_expiry(user_id, token)
        .await
        .log_db_err("fetching PLC token expiry")?
        .ok_or_else(|| ApiError::InvalidToken(Some("Invalid or expired token".into())))?;

    if Utc::now() > token_expiry {
        let _ = state.repos.infra.delete_plc_token(user_id, token).await;
        return Err(ApiError::ExpiredToken(Some("Token has expired".into())));
    }
    let key_row = state
        .repos
        .user
        .get_user_key_by_id(user_id)
        .await
        .log_db_err("fetching user key")?
        .ok_or_else(|| ApiError::InternalError(Some("User signing key not found".into())))?;

    let key_bytes =
        tranquil_pds::config::decrypt_key(&key_row.key_bytes, key_row.encryption_version).map_err(
            |e| {
                error!("Failed to decrypt user key: {}", e);
                ApiError::InternalError(None)
            },
        )?;

    let signing_key = SigningKey::from_slice(&key_bytes).map_err(|e| {
        error!("Failed to create signing key: {:?}", e);
        ApiError::InternalError(None)
    })?;

    let plc_client = state.plc_client();
    let did_clone = did.clone();
    let last_op = with_circuit_breaker(&state.circuit_breakers.plc_directory, || async {
        plc_client.get_last_op(&did_clone).await
    })
    .await
    .map_err(ApiError::from)?;

    if last_op.is_tombstone() {
        return Err(ApiError::from(PlcError::Tombstoned));
    }
    let unsigned_op = create_update_op(
        &last_op,
        input.rotation_keys,
        input.verification_methods,
        input.also_known_as,
        input.services,
    )
    .map_err(|e| match e {
        PlcError::Tombstoned => ApiError::InvalidRequest("Cannot update tombstoned DID".into()),
        _ => {
            error!("Failed to create PLC operation: {:?}", e);
            ApiError::InternalError(None)
        }
    })?;

    let signed_op = sign_operation(&unsigned_op, &signing_key).map_err(|e| {
        error!("Failed to sign PLC operation: {:?}", e);
        ApiError::InternalError(None)
    })?;

    let _ = state.repos.infra.delete_plc_token(user_id, token).await;
    info!("Signed PLC operation for user {}", did);
    Ok(Json(SignPlcOperationOutput {
        operation: signed_op,
    }))
}
