meilies 0.2.0

The RESP and MeiliES protocol types
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

use std::error::Error;

use super::{EventName, EventData};

#[derive(Debug, PartialEq, Eq, PartialOrd, Ord, Hash)]
pub struct RawEvent<T>(T);

impl<T: AsRef<[u8]>> RawEvent<T> {
    pub fn new(content: T) -> RawEvent<T> {
        RawEvent(content)
    }

    fn name_size(&self) -> usize {
        // FIXME: prefer using TryFrom
        let mut event_name_size: [u8; 8] = [0; 8];
        for (i, b) in self.0.as_ref().iter().enumerate() {
            if i == 8 {
                break
            }
            event_name_size[i] = *b;
        }
        usize::from_be_bytes(event_name_size)
    }

    // FIXME: Prefer using a typed Error
    pub fn name(&self) -> Result<EventName, Box<Error>> {
        let name_size = self.name_size();
        let raw_name = &self.0.as_ref()[8..(8 + name_size)];
        let name = String::from_utf8(raw_name.to_owned())?;

        Ok(EventName::new(name)?)
    }

    pub fn data(&self) -> EventData {
        let name_size = self.name_size();
        let raw_name = &self.0.as_ref()[(8 + name_size)..];

        EventData(raw_name.to_owned())
    }
}