use std::error::Error;
mod config;
mod message;
#[cfg(feature = "async")]
mod async_impl;
#[cfg(feature = "async")]
pub use self::async_impl::{Blynk, Client, Event, Protocol};
#[cfg(not(feature = "async"))]
mod blocking;
#[cfg(not(feature = "async"))]
pub use self::blocking::{Blynk, Client, Event, Protocol};
pub use self::config::Config;
pub enum ConnectionState {
Disconnected,
Connecting,
Authentiacting,
Authenticated,
}
impl Default for ConnectionState {
fn default() -> Self {
ConnectionState::Disconnected
}
}
mod conf {
use std::time::Duration;
pub const SOCK_MAX_TIMEOUT: Duration = Duration::from_secs(5);
pub const SOCK_TIMEOUT: Duration = Duration::from_millis(1000);
pub const RETRIES_TX_DELAY: Duration = Duration::from_millis(2);
pub const RETRIES_TX_MAX_NUM: u8 = 3;
pub const RECONNECT_SLEEP: Duration = Duration::from_secs(1);
pub const HEARTBEAT_PERIOD: Duration = Duration::from_secs(5);
}
pub struct DefaultHandler {}
use std::result;
use std::{fmt, io};
#[derive(Debug)]
pub enum BlynkError {
Io(io::Error),
Dns,
MessageSend,
EmptyBuffer,
Redirection,
HeartbeatSet(message::ProtocolStatus),
InvalidAuthToken,
InvalidMessageId,
InvalidMessageHeader,
InvalidMessageBody,
StreamIsNone,
ReaderNotAvailable,
}
impl fmt::Display for BlynkError {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
match *self {
BlynkError::Io(ref err) => err.fmt(f),
BlynkError::Dns => write!(f, "Problem resolving host"),
BlynkError::MessageSend => write!(f, "Problem sending message"),
BlynkError::EmptyBuffer => write!(f, "No message to process"),
BlynkError::Redirection => write!(f, "Redirection problem"),
BlynkError::HeartbeatSet(ref ps) => write!(f, "Problem setting heartbeat {:?}", ps),
BlynkError::InvalidAuthToken => write!(f, "Invalid auth token"),
BlynkError::InvalidMessageId => write!(f, "Message id is zero"),
BlynkError::InvalidMessageHeader => write!(f, "Problem parsing message header"),
BlynkError::InvalidMessageBody => write!(f, "Malformed message body"),
BlynkError::StreamIsNone => write!(f, "Stream not available"),
BlynkError::ReaderNotAvailable => write!(f, "Unable to access reader"),
}
}
}
impl Error for BlynkError {}
impl From<io::Error> for BlynkError {
fn from(err: io::Error) -> BlynkError {
BlynkError::Io(err)
}
}
type Result<T> = result::Result<T, BlynkError>;