io-timer 0.0.1

#![cfg(feature = "client")]
#![cfg(feature = "server")]

use std::{
    env,
    net::{TcpListener, TcpStream},
    sync::{
        mpsc::{channel, Receiver, Sender},
        Arc, Mutex,
    },
    thread::{sleep, spawn},
    time::Duration,
};

use io_stream::runtimes::std::handle;
use io_timer::{
    client::coroutines::{get::GetTimer, send::SendRequestResult, start::StartTimer},
    server::coroutines::handle::{HandleRequest, HandleRequestResult},
    timer::{TimerConfig, TimerCycles, TimerEvent, TimerLoop},
    Timer,
};
use log::{debug, info, trace};

fn main() {
    if let Err(_) = env::var("RUST_LOG") {
        unsafe {
            env::set_var("RUST_LOG", "debug");
        }
    }

    env_logger::init();

    let host = match env::var("HOST") {
        Ok(host) => host,
        Err(_) => String::from("localhost"),
    };

    let port = match env::var("PORT") {
        Ok(port) => port.parse::<u16>().unwrap(),
        Err(_) => 0,
    };

    let timer = Arc::new(Mutex::new(Timer::new(TimerConfig {
        cycles: TimerCycles::from([("Work", 2).into(), ("Rest", 3).into()]),
        cycles_count: TimerLoop::Infinite,
    })));

    // used for receiving timer notifications
    let (tx, rx) = channel();

    // used for client <-> server communication
    let listener = TcpListener::bind((host.as_str(), port)).unwrap();
    let addr = listener.local_addr().unwrap();

    spawn_event_notifier(rx);
    spawn_timer_tick(timer.clone(), tx.clone());
    spawn_server(timer.clone(), tx.clone(), listener);

    sleep(Duration::from_secs(3));

    debug!("connect to {addr}");
    let mut stream = TcpStream::connect(addr).unwrap();

    let mut arg = None;
    let mut start = StartTimer::new();

    loop {
        match start.resume(arg.take()) {
            SendRequestResult::Ok(_) => break,
            SendRequestResult::Io(io) => arg = Some(handle(&mut stream, io).unwrap()),
            SendRequestResult::Err(err) => panic!("{err}"),
        }
    }

    sleep(Duration::from_secs(3));

    let mut arg = None;
    let mut get = GetTimer::new();

    let timer = loop {
        match get.resume(arg.take()) {
            SendRequestResult::Ok(timer) => break timer,
            SendRequestResult::Io(io) => arg = Some(handle(&mut stream, io).unwrap()),
            SendRequestResult::Err(err) => panic!("{err}"),
        }
    };

    debug!("{timer:#?}");
}

fn spawn_event_notifier(mpsc: Receiver<TimerEvent>) {
    info!("start event notifier");
    spawn(move || loop {
        let event = mpsc.recv().unwrap();
        debug!("received event {event:?}");
    });
}

fn spawn_timer_tick(timer: Arc<Mutex<Timer>>, mpsc: Sender<TimerEvent>) {
    info!("start timer tick");
    spawn(move || loop {
        let mut timer = timer.lock().unwrap();
        let events = timer.update();
        debug!("timer: tick");
        trace!("{timer:?}");
        drop(timer);

        for event in events {
            mpsc.send(event).unwrap();
        }

        sleep(Duration::from_secs(1));
    });
}

fn spawn_server(timer: Arc<Mutex<Timer>>, mpsc: Sender<TimerEvent>, listener: TcpListener) {
    spawn(move || {
        info!("start server");
        let (mut stream, _) = listener.accept().unwrap();

        debug!("server received tcp connection");
        loop {
            let mut arg = None;
            let mut handler = HandleRequest::new();

            let events = loop {
                let mut timer = timer.lock().unwrap();
                let res = handler.resume(&mut timer, arg.take());
                drop(timer);

                match res {
                    HandleRequestResult::Ok(events) => break events,
                    HandleRequestResult::Io(io) => arg = Some(handle(&mut stream, io).unwrap()),
                    HandleRequestResult::Err(err) => panic!("{err}"),
                }
            };

            for event in events {
                mpsc.send(event).unwrap();
            }
        }
    });
}