Something went wrong. Try again.
PDS software with bells & whistles you didn’t even know you needed. will move this to its own account when ready.
Something went wrong. Try again.
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374use crate::api::EmptyResponse;use crate::api::error::ApiError;use crate::auth::BearerAuthAllowDeactivated;use crate::state::AppState;use axum::{ extract::State, response::{IntoResponse, Response},};use chrono::{Duration, Utc};use tracing::{error, info, warn};
fn generate_plc_token() -> String { crate::util::generate_token_code()}
pub async fn request_plc_operation_signature( State(state): State<AppState>, auth: BearerAuthAllowDeactivated,) -> Response { let auth_user = auth.0; if let Err(e) = crate::auth::scope_check::check_identity_scope( auth_user.is_oauth, auth_user.scope.as_deref(), crate::oauth::scopes::IdentityAttr::Wildcard, ) { return e; } let user = match sqlx::query!("SELECT id FROM users WHERE did = $1", &auth_user.did) .fetch_optional(&state.db) .await { Ok(Some(row)) => row, Ok(None) => return ApiError::AccountNotFound.into_response(), Err(e) => { error!("DB error: {:?}", e); return ApiError::InternalError(None).into_response(); } }; let _ = sqlx::query!( "DELETE FROM plc_operation_tokens WHERE user_id = $1 OR expires_at < NOW()", user.id ) .execute(&state.db) .await; let plc_token = generate_plc_token(); let expires_at = Utc::now() + Duration::minutes(10); if let Err(e) = sqlx::query!( r#" INSERT INTO plc_operation_tokens (user_id, token, expires_at) VALUES ($1, $2, $3) "#, user.id, plc_token, expires_at ) .execute(&state.db) .await { error!("Failed to create PLC token: {:?}", e); return ApiError::InternalError(None).into_response(); } let hostname = std::env::var("PDS_HOSTNAME").unwrap_or_else(|_| "localhost".to_string()); if let Err(e) = crate::comms::enqueue_plc_operation(&state.db, user.id, &plc_token, &hostname).await { warn!("Failed to enqueue PLC operation notification: {:?}", e); } info!( "PLC operation signature requested for user {}", auth_user.did ); EmptyResponse::ok().into_response()}