Function admin_cleanup_api_behavior

crates/backend/src/handlers.rs:1629–1668

(
    State(state): State<AppState>,
    headers: HeaderMap,
    Json(request): Json<AdminApiBehaviorCleanupRequest>,
)

}

pub async fn admin_cleanup_api_behavior(
    State(state): State<AppState>,
    headers: HeaderMap,
    Json(request): Json<AdminApiBehaviorCleanupRequest>,
) -> Result<Json<AdminApiBehaviorCleanupResponse>, (StatusCode, Json<ErrorResponse>)> {
    ensure_admin_access(&state, &headers)?;
    let config = state.api_behavior_runtime_config.read().clone();
    let retention_days = request.retention_days.unwrap_or(config.retention_days);
    if retention_days <= 0 || retention_days > MAX_CONFIGURABLE_API_BEHAVIOR_RETENTION_DAYS {
        return Err(bad_request(
            "`retention_days` must be between 1 and 3650 for api behavior cleanup",
        ));
    }

    let before_ms = chrono::Utc::now().timestamp_millis() - retention_days * 24 * 60 * 60 * 1000;
    let deleted = state
        .store
        .cleanup_api_behavior_before(before_ms)
        .await
        .map_err(|e| internal_error("Failed to cleanup api behavior events", e))?;

    if deleted > 0 {
        let action = state
            .store
            .compact_api_behavior_table()
            .await
            .map_err(|e| internal_error("Failed to compact api behavior events", e))?;
        tracing::info!(
            action = action.as_str(),
            deleted_events = deleted,
            "Compacted api_behavior_events after cleanup"
        );
    }

    Ok(Json(AdminApiBehaviorCleanupResponse {
        deleted_events: deleted,
        before_ms,
        retention_days,
    }))
}

pub async fn admin_compact_api_behavior(
    State(state): State<AppState>,