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

use super::close_codes::CloseReasonCode;
use super::event_emitters::{emit_stream_closed, emit_tls_event_with_detail};
use super::flow_hooks::FlowHooks;
use super::tls_diagnostics::TlsDiagnostics;
use super::tls_learning::TlsLearningGuardrails;
use crate::engine::MitmEngine;
use crate::observe::{EventConsumer, EventType, FlowContext};
use crate::policy::PolicyEngine;
use std::io;
use std::sync::Arc;

pub(crate) async fn fail_tls_and_close<P, S>(
    engine: &Arc<MitmEngine<P, S>>,
    flow_hooks: &Arc<dyn FlowHooks>,
    tls_diagnostics: &Arc<TlsDiagnostics>,
    tls_learning: &Arc<TlsLearningGuardrails>,
    failure_context: FlowContext,
    tunnel_context: FlowContext,
    peer: &'static str,
    detail: String,
) -> io::Result<()>
where
    P: PolicyEngine + Send + Sync + 'static,
    S: EventConsumer + Send + Sync + 'static,
{
    flow_hooks
        .on_tls_failure(failure_context.clone(), detail.clone())
        .await;
    emit_tls_event_with_detail(
        engine,
        tls_diagnostics,
        tls_learning,
        EventType::TlsHandshakeFailed,
        failure_context,
        peer,
        detail.clone(),
    );
    emit_stream_closed(
        engine,
        tunnel_context,
        CloseReasonCode::TlsHandshakeFailed,
        Some(detail),
        None,
        None,
    );
    Ok(())
}