logcast 0.2.4

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
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
114
115
116
117
118
119
120
121

//! # logcast
//! 
//! ![rust](https://img.shields.io/badge/Rust-000000?style=for-the-badge&logo=rust&logoColor=white)
//! 
//! A simple helper that sends logs over TCP, for programs without terminal output, such as TUIs.
//! 
//! ## Example
//! 
//! ![logcast](https://raw.githubusercontent.com/matheus-git/logcast/main/screenshots/logcast.gif)
//! 
//! ## Usage
//! 
//! ### Add logcast and once_cell
//! 
//!     cargo add logcast once_cell
//! 
//! ### Create Macro
//! This code defines a global, thread-safe TCP logger using a singleton (LOGGER) initialized lazily with once_cell::sync::Lazy.
//! 
//! ```rust
//! // src/macros/log/mod.rs
//! use logcast::Logger;
//! use once_cell::sync::Lazy;
//! 
//! pub static LOGGER: Lazy<Logger> = Lazy::new(|| Logger::new("127.0.0.1:8080"));
//! 
//! #[macro_export]
//! macro_rules! log {
//!     ($($arg:tt)*) => {{
//!         $crate::LOGGER.log(&format!($($arg)*));
//!     }};
//! }
//! ```
//! 
//! ### Import LOGGER
//! Import LOGGER in main.rs to allow the macro to access it from any module.
//! 
//! ```rust
//! // src/main.rs
//! use macros::log::LOGGER;
//! ```
//! 
//! ### Import macro
//! 
//! ```rust
//! use crate::log;
//! 
//! log!("Test");
//! log!("{:?}", service);
//! ```
//! 
//! ### Output
//! To view the logs, open another terminal and run a program that listens for TCP connections, such as ```ncat -l --keep-open 8080```, as shown in the example below.
//! 
//!     └─$ ncat -l --keep-open 8080 
//!     [2025-11-10 20:55:04] Test
//!     [2025-11-10 20:55:04] Service { name: "cron.service", description: "Regular background program processing daemon", state: ServiceState { load: "loaded", active: "active", sub: "running", file: "enabled" } }
//! 
//! ## 📝 License
//! 
//! This project is open-source under the MIT License.

use std::sync::mpsc::{self, Sender};
use std::thread;
use std::net::TcpStream;
use std::io::Write;
use std::time::Duration;
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 || {
            let mut stream = loop {
                match TcpStream::connect(&addr) {
                    Ok(s) => break s,
                    Err(e) => {
                        eprintln!("Error connecting to server: {}, retrying in 1s...", e);
                        thread::sleep(Duration::from_secs(1));
                    }
                }
            };

            while let Ok(msg) = rx.recv() {
                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: {}, reconnecting...", e);
                    stream = loop {
                        match TcpStream::connect(&addr) {
                            Ok(s) => break s,
                            Err(e) => {
                                eprintln!("Error reconnecting to server: {}, retrying in 1s...", e);
                                thread::sleep(Duration::from_secs(1));
                            }
                        }
                    };
                    // Após reconectar, tenta enviar novamente
                    if let Err(e) = stream.write_all(formatted.as_bytes()) {
                        eprintln!("Failed to send log after reconnect: {}", 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);
        }
    }
}