id_effect_opentelemetry 0.3.0

//! Capability DI provider for an installed OpenTelemetry runtime handle.

use std::sync::Arc;

use id_effect::{CapabilityId, CapabilityKey, Env, ProviderBox, ProviderError, ProviderNode};

use crate::starter::OtelStarterGuard;

/// Capability key for a process-wide OpenTelemetry runtime handle (flush/shutdown + meter access).
#[derive(Clone, Copy, Debug, Default)]
pub struct OtelRuntimeKey;

impl CapabilityKey for OtelRuntimeKey {
  type Value = Arc<OtelStarterGuard>;
}

/// Register `guard` in the capability environment for domain programs that need OTEL flush/shutdown.
#[inline]
pub fn provide_otel_runtime(guard: Arc<OtelStarterGuard>) -> ProviderBox {
  struct Node(Arc<OtelStarterGuard>);

  impl ProviderNode for Node {
    fn id(&self) -> &str {
      "opentelemetry/runtime"
    }

    fn requires(&self) -> &[CapabilityId] {
      &[]
    }

    fn provides(&self) -> CapabilityId {
      OtelRuntimeKey::id()
    }

    fn cap_name(&self) -> &str {
      "OtelRuntimeKey"
    }

    fn build(&self, deps: &Env) -> Result<Env, ProviderError> {
      let mut out = deps.clone();
      out.insert::<OtelRuntimeKey>(Arc::clone(&self.0));
      Ok(out)
    }
  }

  ProviderBox(Arc::new(Node(guard)))
}