gotatun 0.1.1

an implementation of the WireGuard® protocol designed for portability and speed
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

// Copyright (c) 2025 Mullvad VPN AB. All rights reserved.
// SPDX-License-Identifier: BSD-3-Clause

//! # NOTES
//!
//! This module is an implementation of DAITA version 3 for GotaTun.
//!
//! DAITA (Defense Against AI-guided Traffic Analysis) is MullvadVPN's implementation of
//! an anti-fingerprinting protocol based on the [maybenot] crate.
//!
//! ## TODO
//!
//! - Support mocked time for tests (this is supported in other parts of GotaTun using `mock_instant` crate)

mod actions;
mod events;
mod hooks;
mod types;

use std::str::FromStr;

pub use hooks::DaitaHooks;
use maybenot::Machine;

pub mod api {
    #[derive(Debug, Clone)]
    pub struct DaitaSettings {
        /// The maybenot machines to use.
        pub maybenot_machines: Vec<String>,
        /// Maximum fraction of bandwidth that may be used for padding packets.
        pub max_padding_frac: f64,
        /// Maximum fraction of bandwidth that may be used for blocking packets.
        pub max_blocking_frac: f64,
        /// Maximum number of packets that may be blocked at any time.
        pub max_blocked_packets: usize,
        /// Minimum number of free slots in the blocking queue to continue blocking.
        pub min_blocking_capacity: usize,
    }
}

#[derive(Debug, Clone)]
pub struct DaitaSettings {
    /// The maybenot machines to use.
    pub maybenot_machines: Vec<Machine>,
    /// Maximum fraction of bandwidth that may be used for padding packets.
    pub max_padding_frac: f64,
    /// Maximum fraction of bandwidth that may be used for blocking packets.
    pub max_blocking_frac: f64,
    /// Maximum number of packets that may be blocked at any time.
    pub max_blocked_packets: usize,
    /// Minimum number of free slots in the blocking queue to continue blocking.
    pub min_blocking_capacity: usize,
}

impl TryFrom<api::DaitaSettings> for DaitaSettings {
    type Error = crate::device::Error;

    fn try_from(value: api::DaitaSettings) -> Result<Self, Self::Error> {
        Ok(DaitaSettings {
            maybenot_machines: value
                .maybenot_machines
                .iter()
                .map(|s| Machine::from_str(s))
                .collect::<Result<Vec<_>, _>>()?,
            max_padding_frac: value.max_padding_frac,
            max_blocking_frac: value.max_blocking_frac,
            max_blocked_packets: value.max_blocked_packets,
            min_blocking_capacity: value.min_blocking_capacity,
        })
    }
}