shardcache-client-rs 0.3.2

Blocking Rust client for shardcache's native SCNP protocol
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

use std::io::Write;

use crate::commands::ScnpCommand;
use crate::connection::ScnpConnection;
use crate::error::Result;

pub(crate) struct RespCommand<'parts, 'out> {
    parts: &'parts [&'parts [u8]],
    out: &'out mut Vec<u8>,
}

impl<'parts, 'out> RespCommand<'parts, 'out> {
    pub(crate) fn new(parts: &'parts [&'parts [u8]], out: &'out mut Vec<u8>) -> Self {
        Self { parts, out }
    }
}

impl ScnpCommand for RespCommand<'_, '_> {
    type Output = bool;

    const NAME: &'static str = "RESP";
    const OPCODE: u8 = 200;

    fn body_len(&self) -> usize {
        4 + self
            .parts
            .iter()
            .map(|part| 4usize.saturating_add(part.len()))
            .sum::<usize>()
    }

    fn write_body<W: Write>(&self, w: &mut W) -> Result<()> {
        w.write_all(&(self.parts.len() as u32).to_le_bytes())?;
        for part in self.parts {
            w.write_all(&(part.len() as u32).to_le_bytes())?;
            w.write_all(part)?;
        }
        Ok(())
    }

    fn read_response(self, conn: &mut ScnpConnection) -> Result<Self::Output> {
        conn.read_value(Self::NAME, self.out)
    }
}