easy_esp 0.5.0

Wrapper around socket functionality to make using devices safer and easier
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

use easy_esp::{Request, RequestHandler, Server, Response, ServerCMD};
use std::net::SocketAddr;


// Creating a obj that implements request handler for chat room
struct ChatRoomHandler {
    clients: Vec<SocketAddr>,
}
impl ChatRoomHandler {
    fn new() -> Self {
        ChatRoomHandler {
            clients: vec![],
        }
    }
}
impl RequestHandler for ChatRoomHandler {
    fn handle_request(&mut self, request: Request, origin: SocketAddr) -> (Response, Option<ServerCMD>) {

        let response = format!("Ok");

        let cmd = ServerCMD::SendAll(format!("{}: {}", origin, request));
        (response, Some(cmd))
    }
    
    fn client_connect(&mut self, addr: SocketAddr) -> Option<ServerCMD> {
        // Adds client to client list
        self.clients.push(addr);
        
        Some(ServerCMD::SendAll(format!("{} Connected to chat", addr)))
    }
    
    fn client_disconnect(&mut self, addr: SocketAddr) -> Option<ServerCMD> {
        // Removes addr if it matches disconnected one
        self.clients.retain(|&x| x != addr);

        Some(ServerCMD::SendAll(format!("{} Disconnect from chat", addr)))
    }
}

#[tokio::main]
async fn main() {
    // Getting a socket addr obj
    let addr: SocketAddr = "127.0.0.1:5555".parse().expect("Could not parse ip addr");

    // Creating instance of a handler
    let handler = ChatRoomHandler::new();

    // Creating a server obj
    let mut server = Server::new(addr, handler);

    // Start server listener
    server.listen().await;
}