mockforge-http 0.3.234

HTTP/REST protocol support for MockForge
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

//! Compatibility state for drift handlers implemented in Intelligence.
#![allow(deprecated)]

use mockforge_core::contract_drift::DriftBudgetEngine;
use mockforge_core::incidents::IncidentManager;
pub use mockforge_intelligence::handlers::drift_budget::*;
use std::sync::Arc;

/// State for drift budget handlers. Existing fields and struct literals remain valid.
#[derive(Clone)]
pub struct DriftBudgetState {
    /// Drift budget engine
    pub engine: Arc<DriftBudgetEngine>,
    /// Incident manager
    pub incident_manager: Arc<IncidentManager>,
    /// GitOps handler (optional)
    pub gitops_handler: Option<Arc<mockforge_core::drift_gitops::DriftGitOpsHandler>>,
}

impl DriftBudgetStateProvider for DriftBudgetState {
    type Engine = DriftBudgetEngine;
    type Incidents = IncidentManager;
    type GitOps = mockforge_core::drift_gitops::DriftGitOpsHandler;
    fn engine(&self) -> &Self::Engine {
        self.engine.as_ref()
    }
    fn incident_manager(&self) -> &Self::Incidents {
        self.incident_manager.as_ref()
    }
    fn gitops_handler(&self) -> Option<&Self::GitOps> {
        self.gitops_handler.as_deref()
    }
    fn publish_drift_threshold(
        &self,
        _workspace: uuid::Uuid,
        _endpoint: String,
        _exceeded: i32,
        _total: i32,
    ) {
        #[cfg(feature = "pipelines")]
        {
            let event = mockforge_pipelines::PipelineEvent::drift_threshold_exceeded(
                _workspace, _endpoint, _exceeded, _total,
            );
            if let Err(error) = mockforge_pipelines::publish_event(event) {
                tracing::warn!("Failed to publish drift threshold exceeded event: {}", error);
            }
        }
    }
}