soth-mitm 0.3.3

Rust intercepting proxy crate with deterministic handler/event contracts for SOTH.
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

use crate::engine::MitmEngine;
use crate::observe::EventConsumer;
use crate::policy::{FlowAction, PolicyEngine};
use crate::types::{FlowId, ProcessInfo};
use dashmap::DashMap;

#[derive(Debug, Clone)]
pub(crate) struct FlowPolicySnapshot {
    pub(crate) flow_id: FlowId,
    pub(crate) action: FlowAction,
    pub(crate) reason: String,
    pub(crate) override_state: crate::policy::PolicyOverrideState,
}

#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
struct FlowPolicySnapshotKey {
    engine_instance_id: u64,
    flow_id: FlowId,
}

static FLOW_POLICY_SNAPSHOTS: std::sync::OnceLock<
    DashMap<FlowPolicySnapshotKey, FlowPolicySnapshot>,
> = std::sync::OnceLock::new();

fn flow_policy_snapshots() -> &'static DashMap<FlowPolicySnapshotKey, FlowPolicySnapshot> {
    FLOW_POLICY_SNAPSHOTS.get_or_init(DashMap::new)
}

pub(crate) fn resolve_flow_policy_snapshot<P, S>(
    engine: &MitmEngine<P, S>,
    flow_id: FlowId,
    client_addr: String,
    server_host: String,
    server_port: u16,
    path: Option<String>,
    process_info: Option<ProcessInfo>,
) -> FlowPolicySnapshot
where
    P: PolicyEngine + Send + Sync + 'static,
    S: EventConsumer + Send + Sync + 'static,
{
    let snapshot_key = FlowPolicySnapshotKey {
        engine_instance_id: engine.instance_id(),
        flow_id,
    };
    if let Some(snapshot) = flow_policy_snapshots().get(&snapshot_key) {
        return snapshot.clone();
    }
    let outcome = engine.decide_connect(
        flow_id,
        client_addr,
        server_host,
        server_port,
        path,
        process_info,
    );
    let snapshot = FlowPolicySnapshot {
        flow_id: outcome.flow_id,
        action: outcome.action,
        reason: outcome.reason,
        override_state: outcome.override_state,
    };
    flow_policy_snapshots().insert(snapshot_key, snapshot.clone());
    snapshot
}

pub(crate) fn clear_flow_policy_snapshot(engine_instance_id: u64, flow_id: FlowId) {
    let snapshot_key = FlowPolicySnapshotKey {
        engine_instance_id,
        flow_id,
    };
    let _ = flow_policy_snapshots().remove(&snapshot_key);
}