superseedr 1.0.5

A BitTorrent Client in your Terminal.
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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

// SPDX-FileCopyrightText: 2025 The superseedr Contributors
// SPDX-License-Identifier: GPL-3.0-or-later

use crate::app::TorrentMetrics;
use std::time::Duration;

#[derive(Debug, Default)]
pub struct ManagerTelemetry {
    last_sent_metrics: Option<TorrentMetrics>,
}

impl ManagerTelemetry {
    pub fn should_emit(&mut self, metrics: &TorrentMetrics) -> bool {
        let force_emit =
            metrics.bytes_downloaded_this_tick > 0 || metrics.bytes_uploaded_this_tick > 0;

        if !force_emit {
            let current_norm = Self::normalized_for_compare(metrics);
            if let Some(previous) = &self.last_sent_metrics {
                let previous_norm = Self::normalized_for_compare(previous);
                if current_norm == previous_norm {
                    return false;
                }
            }
        }

        self.last_sent_metrics = Some(metrics.clone());
        true
    }

    fn normalized_for_compare(metrics: &TorrentMetrics) -> TorrentMetrics {
        let mut normalized = metrics.clone();
        normalized.next_announce_in = Duration::ZERO;
        normalized.eta = Duration::ZERO;
        normalized
    }
}

#[cfg(test)]
mod tests {
    use super::ManagerTelemetry;
    use crate::app::TorrentMetrics;
    use std::time::Duration;

    fn sample_metrics() -> TorrentMetrics {
        TorrentMetrics {
            info_hash: vec![1; 20],
            torrent_name: "example".to_string(),
            number_of_pieces_total: 100,
            number_of_pieces_completed: 20,
            download_speed_bps: 1024,
            upload_speed_bps: 0,
            bytes_downloaded_this_tick: 0,
            bytes_uploaded_this_tick: 0,
            eta: Duration::from_secs(120),
            activity_message: "Downloading".to_string(),
            next_announce_in: Duration::from_secs(10),
            total_size: 1_000_000,
            bytes_written: 200_000,
            ..Default::default()
        }
    }

    #[test]
    fn emits_first_snapshot() {
        let mut telemetry = ManagerTelemetry::default();
        let metrics = sample_metrics();
        assert!(telemetry.should_emit(&metrics));
    }

    #[test]
    fn suppresses_identical_snapshot() {
        let mut telemetry = ManagerTelemetry::default();
        let metrics = sample_metrics();

        assert!(telemetry.should_emit(&metrics));
        assert!(!telemetry.should_emit(&metrics));
    }

    #[test]
    fn ignores_countdown_only_drift() {
        let mut telemetry = ManagerTelemetry::default();
        let first = sample_metrics();
        let mut second = first.clone();
        second.next_announce_in = Duration::from_secs(5);
        second.eta = Duration::from_secs(110);

        assert!(telemetry.should_emit(&first));
        assert!(!telemetry.should_emit(&second));
    }

    #[test]
    fn forces_emit_when_bytes_nonzero() {
        let mut telemetry = ManagerTelemetry::default();
        let first = sample_metrics();
        let mut second = first.clone();
        second.bytes_downloaded_this_tick = 4096;

        assert!(telemetry.should_emit(&first));
        assert!(telemetry.should_emit(&second));
    }

    #[test]
    fn emits_on_meaningful_change() {
        let mut telemetry = ManagerTelemetry::default();
        let first = sample_metrics();
        let mut second = first.clone();
        second.number_of_pieces_completed += 1;

        assert!(telemetry.should_emit(&first));
        assert!(telemetry.should_emit(&second));
    }
}