project_ares 0.12.0

Automated decoding tool, Ciphey but in Rust
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

use crossbeam::channel::{bounded, Receiver};
use std::sync::atomic::Ordering::Relaxed;
use std::{
    sync::atomic::AtomicBool,
    thread::{self, sleep},
    time::Duration,
};

use crate::cli_pretty_printing::{countdown_until_program_ends, display_top_results};
use crate::config::get_config;
use crate::storage::wait_athena_storage;

/// Indicate whether timer is paused
static PAUSED: AtomicBool = AtomicBool::new(false);

/// Start the timer with duration in seconds
pub fn start(duration: u32) -> Receiver<()> {
    let (sender, recv) = bounded(1);
    thread::spawn(move || {
        let mut time_spent = 0;

        while time_spent < duration {
            if !PAUSED.load(Relaxed) {
                sleep(Duration::from_secs(1));
                time_spent += 1;
                // Some pretty printing support
                countdown_until_program_ends(time_spent, duration);
            }
        }

        // When the timer expires, display all collected plaintext results
        // Only if we're in top_results mode
        let config = get_config();
        log::trace!("Timer expired. top_results mode: {}", config.top_results);

        if config.top_results {
            log::info!("Displaying all collected plaintext results");
            filter_and_display_results();
        } else {
            log::info!("Not in top_results mode, skipping display_wait_athena_results()");
        }

        sender.send(()).expect("Timer should send succesfully");
    });

    recv
}

/// Filter and display all plaintext results collected by WaitAthena
fn filter_and_display_results() {
    let results = wait_athena_storage::get_plaintext_results();

    log::trace!(
        "Retrieved {} results from wait_athena_storage",
        results.len()
    );

    // Use the cli_pretty_printing function to display the results
    display_top_results(&results);
}

/// Pause timer
pub fn pause() {
    PAUSED.store(true, Relaxed);
}

/// Resume timer
pub fn resume() {
    PAUSED.store(false, Relaxed);
}