use async_std::task;
use paperplane::tungstenite::Message;
use paperplane::{Event, Server};

fn main() {
    let server = Server::new(10);

    task::block_on(async {
        server.listen("0.0.0.0:8000").await.unwrap();

        while let Some(event) = server.next::<Message>().await {
            let server = server.clone();

            task::spawn(async move {
                match event {
                    Event::Connected(id) => {
                        server.send(None, format!("{} connected", id)).await.ok();
                        server.send(Some(id), "Welcome!").await.ok()
                    }

                    Event::Disconnected(id) => {
                        server.send(None, format!("{} disconnected", id)).await.ok()
                    }

                    Event::Kicked(id, reason) => server
                        .send(None, format!("{} kicked: '{}'", id, reason))
                        .await
                        .ok(),

                    Event::Message(id, msg) => match msg.to_text() {
                        Ok("close") => server.close().await.ok(),
                        Ok("exit") => server.kick(Some(id), "exit").await.ok(),
                        Ok("kickall") => server.kick(None, "kickall".into()).await.ok(),
                        _ => server.send(None, format!("{}: {}", id, msg)).await.ok(),
                    },
                }
            });
        }
    });
}