birdc 0.4.2

Library to talk to the BIRD BGP server for administrative and instrumentation purposes
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

use std::{fmt, num::ParseIntError, str::Utf8Error};

use super::Message;

pub type Result<T> = std::result::Result<T, Error>;

#[derive(Debug)]
pub enum Error {
    /// Simple wrapper over all I/O related errors
    IoError(std::io::Error),
    /// We received an error [Message] from the server
    ProtocolError(Message),
    /// If a new request is made on a connection before the
    /// response of the previous one has been fully read.
    OperationInProgress,
    /// If we received a token which was not what we were
    /// supposed to get [String]
    InvalidToken(InvalidTokenError),
    /// We were unable to semantically parse the message,
    /// and the contained value represents the list of
    /// messages we'd received
    ParseError(Vec<Message>),
}

impl fmt::Display for Error {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            Error::IoError(text) => write!(f, "IO operation failed: {}", text),
            Error::ProtocolError(msg) => {
                write!(f, "received an error message from server")?;
                match msg {
                    Message::ReplyTooLong(text) => write!(f, ": reply too long: {}", text),
                    Message::RouteNotFound(text) => write!(f, ": route not found: {}", text),
                    Message::ConfigurationFileError(text) => {
                        write!(f, ": configuration file error: {}", text)
                    }
                    Message::NoProtocolsMatch(text) => write!(f, ": no protocols match: {}", text),
                    Message::StoppedDueToReconfiguration(text) => {
                        write!(f, ": stopped due to reconfiguration: {}", text)
                    }
                    Message::ProtocolDown(text) => {
                        write!(f, ": protocol is down => connot dump: {}", text)
                    }
                    Message::ReloadFailed(text) => write!(f, ": reload failed: {}", text),
                    Message::AccessDenied(text) => write!(f, ": access denied: {}", text),
                    Message::RuntimeError(code, text) => {
                        write!(f, ": evaluation runtime error: {} {}", code, text)
                    }
                    _ => Ok(()),
                }
            }
            Error::OperationInProgress => write!(f, "another request is already in progress"),
            Error::InvalidToken(error) => write!(f, "received invalid token: {}", error),
            Error::ParseError(messages) => {
                write!(f, "failed to parse server response {:?}", messages)
            }
        }
    }
}

impl std::error::Error for Error {
    fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
        match self {
            Self::IoError(err) => Some(err),
            _ => None,
        }
    }
}

impl Error {
    pub fn eof(err: &str) -> Self {
        Self::IoError(std::io::Error::new(std::io::ErrorKind::UnexpectedEof, err))
    }
}

impl From<std::io::Error> for Error {
    fn from(err: std::io::Error) -> Self {
        Error::IoError(err)
    }
}

impl From<Message> for Error {
    fn from(message: Message) -> Self {
        Error::ProtocolError(message)
    }
}

impl From<Utf8Error> for Error {
    fn from(cause: Utf8Error) -> Self {
        Error::InvalidToken(InvalidTokenError::NotUtf8(cause))
    }
}

impl From<ParseIntError> for Error {
    fn from(cause: ParseIntError) -> Self {
        Error::InvalidToken(InvalidTokenError::NotAnInt(cause))
    }
}

#[derive(Debug)]
pub enum InvalidTokenError {
    NotUtf8(Utf8Error),
    NotAnInt(ParseIntError),
    Other(String),
}

impl fmt::Display for InvalidTokenError {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            Self::NotUtf8(err) => err.fmt(f),
            Self::NotAnInt(err) => err.fmt(f),
            Self::Other(text) => text.fmt(f),
        }
    }
}