//! /admin/log: read and replace the log filter of the running node.

use axum::{body::Bytes, http::StatusCode};
use tracing::{info, warn};

use crate::logging;

/// `GET /admin/log`: the filter in effect, as plain text in `RUST_LOG` syntax.
pub(crate) async fn get_log_filter() -> Result<String, StatusCode> {
    logging::filter().map_err(|error| {
        warn!(error = %format!("{error:#}"), "Cannot read the log filter");
        StatusCode::INTERNAL_SERVER_ERROR
    })
}

/// `PUT /admin/log`: replace the filter; the body is plain text in `RUST_LOG` syntax,
/// e.g. `info,continuum::swarm::sync=trace`. Answers with the filter now in effect;
/// 400 (with the reason) if the body doesn't parse, and the old filter stays.
pub(crate) async fn put_log_filter(body: Bytes) -> Result<String, (StatusCode, String)> {
    let directives = std::str::from_utf8(&body)
        .map_err(|_| (StatusCode::BAD_REQUEST, "The filter must be UTF-8\n".to_owned()))?
        .trim();
    let applied = logging::set_filter(directives)
        .map_err(|error| (StatusCode::BAD_REQUEST, format!("{error:#}\n")))?;
    info!(filter = %applied, "Log filter replaced");
    Ok(applied + "\n")
}