use futures::prelude::*;

const SERVER_IDENTITY_SEED: [u8; 32] = [5u8; 32];
const SOCKET_ADDR: &str = "localhost:5555";
const NETWORK_IDENTIFIER: [u8; 32] = [1u8; 32];

#[async_std::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let server_identity_seed =
        sodiumoxide::crypto::sign::ed25519::Seed::from_slice(&SERVER_IDENTITY_SEED).unwrap();
    let server_identity = sodiumoxide::crypto::sign::keypair_from_seed(&server_identity_seed);

    let listener = async_std::net::TcpListener::bind(SOCKET_ADDR).await?;
    println!("Started server with identity {:?}", server_identity.0);
    let (stream, _) = listener.accept().await?;
    let server =
        ssb_box_stream::Server::new(&NETWORK_IDENTIFIER, &server_identity.0, &server_identity.1);
    let (mut sender, mut receiver, client_key) = server.accept(stream).await?;
    println!("Connected to client {:?}", client_key);

    while let Some(data) = receiver.try_next().await? {
        println!("<- {}", String::from_utf8_lossy(&data));
        sender.send(data).await?
    }

    sender.close().await?;

    Ok(())
}