degenbot-cli 0.6.0-alpha.14

//! The telemetry sinks + boot order (ADR-043, ADR-051 D2/D9).
//!
//! The `#[pymodule]` init registers symbols only; the Python driver installs
//! its subscriber in `driver_boot()`. This module installs the console's
//! subscriber with the standalone-Rust-consumer default, so a one-shot
//! command is silent at `info` unless an explicit `RUST_LOG` says otherwise:
//!
//! 1. **Typed config first.** `BotConfigLoader` (schema defaults + the
//!    standard file layer + `DEGENBOT_*` env) is installed into the typed
//!    holder BEFORE any subscriber exists, so `telemetry.log_level` /
//!    `telemetry.diag` are the values the filter resolution actually sees. An
//!    invalid config is a loud boot refusal (exit 2), exactly as Python's
//!    module init refuses.
//! 2. **The tracing registry.** A `fmt` layer on stderr filtered by
//!    [`resolve_filters`](degenbot_bot::telemetry::resolve_filters) with the
//!    Python-driver wiring default (`info`) - the same resolution the binding
//!    boots, so an explicit `RUST_LOG` wins verbatim on this sink too - plus
//!    the [`progress`](crate::progress) bar layer (ADR-051 D9).
//! 3. **The shared ADR-043 contracts**: `warn_retired_env_names`,
//!    `install_panic_hook`. The worker-census boot table is NOT dumped here —
//!    it belongs to the drivers' boot prelude, not a one-shot command.
//!
//! OTLP/metrics are deliberately NOT booted here: a console invocation is a
//! short-lived process, not a scrape target, and the Python driver's OTLP layer
//! belongs to the long-running bot process. `telemetry.otel` is still honored as
//! config (the typed loader refuses a bad value) - it just has no sink to gate.

use std::sync::Arc;

use degenbot_bot::telemetry as bot_telemetry;
use tracing_subscriber::layer::{Layer as _, SubscriberExt as _};
use tracing_subscriber::EnvFilter;

use crate::progress::{self, Layer as ProgressLayer, Painter};

/// The process-lifetime telemetry handles. Dropping it clears the progress bar.
#[derive(Debug)]
#[must_use = "the boot guard must outlive the command run"]
pub struct TelemetryBoot {
    painter: Arc<Painter>,
}

impl Drop for TelemetryBoot {
    fn drop(&mut self) {
        self.painter.finish();
    }
}

/// Boot the console's telemetry sinks (see the module docs for the order).
///
/// # Errors
///
/// The refusal message when the typed configuration is invalid - the process
/// cannot honor a policy it does not have, so the boot is refused exactly as
/// the Python module init refuses it.
pub fn boot() -> Result<TelemetryBoot, String> {
    // Step 1: the typed config. The loader is the ONE env-reading site.
    match degenbot_config::BotConfigLoader::new()
        .with_standard_file_paths()
        .load()
    {
        Ok(loaded) => {
            // First-wins, mirroring the Python boot path.
            let _ = degenbot_substrate::stance::install(Arc::new(loaded.config));
        }
        Err(error) => return Err(format!("invalid configuration - boot refused: {error}")),
    }

    // Step 2: the console filter. The module init no longer installs a
    // subscriber, so THIS install is the process's one telemetry surface and
    // it resolves with the standalone-Rust-consumer default (ADR-043 §6):
    // silent at `info`, loud through an explicit RUST_LOG. The Python driver
    // resolves ITS console filter in driver_boot() with its own default.
    let plan = bot_telemetry::resolve_filters(bot_telemetry::CONSOLE_WIRING_DEFAULT_RUST);
    let painter = Arc::new(Painter::from_draw_target(progress::stderr_opt()));
    let console_filter = EnvFilter::new(&plan.console);
    let subscriber = tracing_subscriber::registry()
        .with(
            tracing_subscriber::fmt::layer()
                .compact()
                .with_writer(std::io::stderr)
                .with_filter(console_filter.clone()),
        )
        .with(ProgressLayer::new(Arc::clone(&painter)).with_filter(console_filter));
    let installed = tracing::subscriber::set_global_default(subscriber).is_ok();

    // Step 3: the shared ADR-043 section 2/5 contracts. The census boot
    // table belongs to the drivers' boot prelude — a one-shot command arms
    // BOOT_DUMPED by dumping it, which would re-classify every later
    // registration as a late-registration notice; the register() entries
    // still document this process's spawn sites either way.
    degenbot_core::telemetry::warn_retired_env_names();
    degenbot_core::telemetry::install_panic_hook();

    // The substrate's telemetry port delegates to this crate's instruments
    // registry (see `degenbot_bot::instruments`).
    degenbot_bot::instruments::install_substrate_telemetry_port();

    degenbot_core::op_debug!(
        domain = pump,
        console = %plan.console,
        "telemetry boot complete"
    );
    if !installed {
        degenbot_core::op_warn!(
            domain = pump,
            "global tracing subscriber already installed; console wiring left untouched"
        );
    }

    Ok(TelemetryBoot { painter })
}