logcast 0.1.9

Simple helper to send logs via TCP
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

use std::sync::mpsc::{self, Sender};
use std::thread;
use std::net::TcpStream;
use std::io::Write;
use chrono::Local;

pub struct Logger {
    tx: Sender<String>,
}

impl Logger {
    pub fn new(address: &str) -> Self {
        let (tx, rx) = mpsc::channel::<String>();
        let addr = address.to_string();

        thread::spawn(move || {
            while let Ok(msg) = rx.recv() {
                match TcpStream::connect(&addr) {
                    Ok(mut stream) => {
                        let timestamp = Local::now().format("[%Y-%m-%d %H:%M:%S]").to_string();
                        let formatted = format!("\x1b[90m{}\x1b[0m {}\n", timestamp, msg);
                        if let Err(e) = stream.write_all(formatted.as_bytes()) {
                            eprintln!("Error sending log: {}", e);
                        }
                    }
                    Err(e) => eprintln!("Error connecting to server: {}", e),
                }
            }
        });

        Self { tx }
    }

    pub fn log(&self, message: &str) {
        if let Err(e) = self.tx.send(message.to_string()) {
            eprintln!("Error sending message to queue: {}", e);
        }
    }
}