hpx 2.4.10

High Performance HTTP Client
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

use std::{
    fs::OpenOptions,
    io::{Result, Write},
    path::Path,
    sync::{
        Arc,
        mpsc::{self, Sender},
    },
};

/// Handle for writing to a key log file.
#[derive(Debug, Clone)]
pub struct Handle {
    #[allow(unused)]
    filepath: Arc<Path>,
    sender: Sender<String>,
}

impl Handle {
    /// Create a new [`Handle`] with the specified path and sender.
    pub fn new(filepath: Arc<Path>) -> Result<Self> {
        if let Some(parent) = filepath.parent() {
            std::fs::create_dir_all(parent)?;
        }

        let mut file = OpenOptions::new()
            .create(true)
            .append(true)
            .open(&filepath)?;

        let (sender, receiver) = mpsc::channel::<String>();

        let _path_name = filepath.clone();
        std::thread::spawn(move || {
            trace!(
                file = ?_path_name,
                "Handle: receiver task up and running",
            );
            while let Ok(line) = receiver.recv() {
                if let Err(_err) = file.write_all(line.as_bytes()) {
                    error!(
                        file = ?_path_name,
                        error = %_err,
                        "Handle: failed to write file",
                    );
                }
            }
        });

        Ok(Handle { filepath, sender })
    }

    /// Write a line to the keylogger.
    pub fn write(&self, line: &str) {
        let line = format!("{line}\n");
        if let Err(_err) = self.sender.send(line) {
            error!(
                file = ?self.filepath,
                error = %_err,
                "Handle: failed to send log line for writing",
            );
        }
    }
}