fastsync 0.10.1

A fast, safe one-way directory synchronization tool for local folders and network transfers.
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

use quinn::{RecvStream, SendStream};

use crate::error::Result;

use super::{MAX_MESSAGE_SIZE, protocol::WireMessage, util::other, util::other_message};

pub(super) async fn write_message(send: &mut SendStream, message: &WireMessage) -> Result<()> {
    let payload =
        serde_json::to_vec(message).map_err(|error| other("encode network message", error))?;
    if payload.len() > MAX_MESSAGE_SIZE {
        return Err(other_message(
            "encode network message",
            "message is too large",
        ));
    }
    send.write_all(&(payload.len() as u32).to_be_bytes())
        .await
        .map_err(|error| other("write network message length", error))?;
    send.write_all(&payload)
        .await
        .map_err(|error| other("write network message payload", error))?;
    Ok(())
}

pub(super) async fn read_message(recv: &mut RecvStream) -> Result<WireMessage> {
    let mut len = [0_u8; 4];
    recv.read_exact(&mut len)
        .await
        .map_err(|error| other("read network message length", error))?;
    let len = u32::from_be_bytes(len) as usize;
    if len > MAX_MESSAGE_SIZE {
        return Err(other_message(
            "read network message",
            "message is too large",
        ));
    }
    let mut payload = vec![0_u8; len];
    recv.read_exact(&mut payload)
        .await
        .map_err(|error| other("read network message payload", error))?;
    serde_json::from_slice(&payload).map_err(|error| other("decode network message", error))
}