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

extern crate protobuf;

use protobuf::error::ProtobufError;
use std::io::Error as IoError;

#[derive(Debug)]
pub enum ConnectionErr {
    NameTooLong,
    TcpConnectionFailure(IoError),
    HelloMessageFailed(IoError),
    NameMessageFailed(IoError),
    IdMessageFailed(IoError),
    IdMessageTooShort,
    OkMessageFailed(IoError),
    OkMessageWrong,
    RWCreationError(ProtobufError)
}
#[derive(Debug)]
pub enum TransceiverError {
    Protobuf(ProtobufError),
    Socket(IoError),
    ResponseHasError(String)
}
impl From<ProtobufError> for TransceiverError { fn from(i : ProtobufError) -> Self { TransceiverError::Protobuf(i) } }
impl From<IoError> for TransceiverError { fn from(i : IoError) -> Self { TransceiverError::Socket(i) } }

pub type Id = [u8; 16];
#[macro_use]
mod macros;
pub mod schema;
pub mod rpc;
pub mod stream;

#[macro_export]
macro_rules! invoke {
    ( $rpc : ident.$a : tt.$b : tt () ) => { $rpc.invoke(stringify!($a).to_owned(), stringify!($b).to_owned(), vec!()) };
    ( $rpc : ident.$a : tt.$b : tt ( $( $arg : expr ),+ ) ) => {{
        let mut args = vec!();
        $(
            args.push($arg);
        )+
        $rpc.invoke(stringify!($a).to_owned(), stringify!($b).to_owned(), args)
    }}
}