Struct epicbox::server::AsyncServer

pub struct AsyncServer {
    id: String,
    inner: Arc<Mutex<Server>>,
    nats_sender: UnboundedSender<BrokerRequest>,
    response_handlers_sender: UnboundedSender<BrokerResponseHandler>,
    subscriptions: HashMap<String, Subscription>,
    epicbox_domain: String,
    epicbox_port: u16,
    epicbox_protocol_unsecure: bool,
}

Fields

id: String

inner: Arc<Mutex<Server>>

nats_sender: UnboundedSender<BrokerRequest>

response_handlers_sender: UnboundedSender<BrokerResponseHandler>

subscriptions: HashMap<String, Subscription>

epicbox_domain: String

epicbox_port: u16

epicbox_protocol_unsecure: bool

Implementations

impl AsyncServer

pub fn new(
    out: Sender,
    nats_sender: UnboundedSender<BrokerRequest>,
    response_handlers_sender: UnboundedSender<BrokerResponseHandler>,
    epicbox_domain: &str,
    epicbox_port: u16,
    epicbox_protocol_unsecure: bool
) -> AsyncServer

pub fn init() -> UnboundedSender<BrokerResponseHandler>

fn error(kind: EpicboxError) -> EpicboxResponse

fn ok() -> EpicboxResponse

fn get_challenge_raw(&self) -> &str

fn get_challenge(&self) -> EpicboxResponse

fn verify_signature(
    &self,
    public_key: &str,
    challenge: &str,
    signature: &str
) -> Result<()>

fn subscribe(&mut self, address: String, signature: String) -> EpicboxResponse

fn unsubscribe(&mut self, address: String) -> EpicboxResponse

fn post_slate(
    &self,
    from: String,
    to: String,
    str: String,
    signature: String,
    message_expiration_in_seconds: Option<u32>
) -> EpicboxResponse

fn post_slate_federated(
    &self,
    from_address: &EpicboxAddress,
    to_address: &EpicboxAddress,
    str: String,
    signature: String,
    message_expiration_in_seconds: Option<u32>
) -> EpicboxResponse

Trait Implementations

impl Drop for AsyncServer

fn drop(&mut self)

Executes the destructor for this type.

impl Handler for AsyncServer

fn on_request(&mut self, req: &Request) -> WsResult<Response>

A method for handling the low-level workings of the request portion of the WebSocket handshake.

fn on_open(&mut self, _: Handshake) -> WsResult<()>

Called when the WebSocket handshake is successful and the connection is open for sending and receiving messages.

fn on_message(&mut self, msg: Message) -> WsResult<()>

Called on incoming messages.

fn on_close(&mut self, code: CloseCode, _reason: &str)

Called any time this endpoint receives a close control frame. This may be because the other endpoint is initiating a closing handshake, or it may be the other endpoint confirming the handshake initiated by this endpoint.

fn on_error(&mut self, err: Error)

Called when an error occurs on the WebSocket.

fn on_shutdown(&mut self)

Called when a request to shutdown all connections has been received.

fn on_response(&mut self, res: &Response) -> Result<(), Error>

A method for handling the low-level workings of the response portion of the WebSocket handshake.

fn on_timeout(&mut self, event: Token) -> Result<(), Error>

Called when a timeout is triggered.

fn on_new_timeout(&mut self, Token, Timeout) -> Result<(), Error>

Called when a timeout has been scheduled on the eventloop.

fn on_frame(&mut self, frame: Frame) -> Result<Option<Frame>, Error>

A method for handling incoming frames.

fn on_send_frame(&mut self, frame: Frame) -> Result<Option<Frame>, Error>

A method for handling outgoing frames.

fn build_request(&mut self, url: &Url) -> Result<Request, Error>

A method for creating the initial handshake request for WebSocket clients.

fn upgrade_ssl_client(
    &mut self,
    stream: TcpStream,
    url: &Url
) -> Result<SslStream<TcpStream>, Error>

A method for wrapping a client TcpStream with Ssl Authentication machinery

fn upgrade_ssl_server(
    &mut self,
    TcpStream
) -> Result<SslStream<TcpStream>, Error>

A method for wrapping a server TcpStream with Ssl Authentication machinery