btm 3.0.1

Blockchain Time Machine
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

//!
//! Logic of `btm daemon ...`
//!

use crate::{
    BtmCfg,
    api::model::{Req, Resp, SERVER_US_ADDR},
};
use ruc::{uau::UauSock, *};

/// Run `btm daemon ...` server
pub fn run_daemon(cfg: BtmCfg) -> Result<()> {
    let s = UauSock::new(SERVER_US_ADDR, None).c(d!())?;
    loop {
        // errors are logged but never kill the daemon loop: a corrupt
        // datagram or a vanished client must not stop future snapshots
        if let Ok((msg, peer)) = info!(s.recv_buf::<128>())
            && let Ok(r) = info!(serde_json::from_slice::<Req>(&msg))
        {
            let success = info!(cfg.snapshot(r.idx())).is_ok();
            info_omit!(s.send(&Resp::new(r.idx(), success).to_bytes(), &peer));
        }
    }
}