pvcrypt 1.0.0

System level data encryption using aes_gcm
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

use pvcrypt::{args::Args, read, stats, write}; // args::Args cus binary and lib have same name
use std::io::Result;

use crossbeam::channel::{bounded, unbounded};
use std::thread;
fn main() -> Result<()> {
    let args = Args::parse();
    let Args {
        infile,
        outfile,
        silent,
        decrypt,
    } = args;

    // transmitters and receivers
    let (stats_tx, stats_rx) = unbounded();
    let (write_tx, write_rx) = bounded(1024);

    let read_decrypt = decrypt.clone();
    let write_decrypt = decrypt.clone();

    let read_handle = thread::spawn(move || read::read_loop(&infile, stats_tx, write_tx, &read_decrypt)); // Both channels cuz it'll send to both
    let stats_handle = thread::spawn(move || stats::stats_loop(silent, stats_rx)); // {||} closure is a fn that can capture environment around it
    let write_handle = thread::spawn(move || write::write_loop(&outfile, write_rx, &write_decrypt)); // python equivalent of closure is lambda

    // Crash if any thread panics
    // .join returns a thread::Result<io::Result<()>>.
    let read_io_result = read_handle.join().unwrap();
    let stats_io_result = stats_handle.join().unwrap();
    let write_io_result = write_handle.join().unwrap();

    // Return error if any thread is an error
    read_io_result?;
    stats_io_result?;
    write_io_result?;

    Ok(())
}