pub mod condition;
pub mod interface;

use chrono::NaiveDateTime;
use condition::ConditionFind;
use crossbeam_channel::Sender;
use interface::network_loop;
use karlcommon::{ClientboundPacket, Condition, Instance, Property, ServerboundPacket, Task};
use log::{debug, info};
use std::{collections::HashMap, sync::RwLock};

fn main() {
    env_logger::init();
    info!("logging");
    TASKS.write().unwrap().insert(
        0,
        Task {
            id: 0,
            name: "blub".to_string(),
            description: "blob".to_string(),
            tags: vec![],
            priority: 69.0,
            completed: None,
            scheduled: None,
            occurence: Some(Condition::And(vec![
                Condition::Equal {
                    modulus: None,
                    prop: Property::Monthofyear,
                    value: 1,
                },
                Condition::Equal {
                    modulus: None,
                    prop: Property::Hour,
                    value: 12,
                },
            ])),
            deadline: None,
        },
    );
    network_loop();
}

lazy_static::lazy_static! {
    static ref TASKS: RwLock<HashMap<u64, Task>> = RwLock::new(HashMap::new());
}

pub fn handle_packet(client: u32, packet: ServerboundPacket, responder: Sender<ClientboundPacket>) {
    match packet {
        ServerboundPacket::ListTasks => {
            let _ = responder.send(ClientboundPacket::TaskList(
                TASKS.read().unwrap().values().map(|e| e.clone()).collect(),
            ));
        }
        ServerboundPacket::UpdateTask(t) => {
            TASKS.write().unwrap().insert(t.id, t);
        }
        ServerboundPacket::RemoveTask(i) => {
            TASKS.write().unwrap().remove(&i);
        }
        ServerboundPacket::Handshake { version } => {
            debug!("{client}: version {version}");
        }
        ServerboundPacket::ListInstances { range, task, limit } => {
            let t = match TASKS.read().unwrap().get(&task).cloned() {
                Some(t) => t,
                None => {
                    let _ =
                        responder.send(ClientboundPacket::Error("task does not exist".to_string()));
                    return;
                }
            };

            let mut ocs = vec![];
            if let Some(o) = &t.occurence {
                let mut time = NaiveDateTime::from_timestamp(range.start.unwrap_or(0), 0);
                let end_time = range.end.map(|e| NaiveDateTime::from_timestamp(e, 0));
                for _ in 0..limit {
                    let start = o.find(condition::Edge::Start, condition::Direction::Forward, time);
                    let end = o.find(condition::Edge::End, condition::Direction::Forward, time);
                    ocs.push(Instance {
                        of: t.id,
                        at: start.map(|e| e.timestamp())..end.map(|e| e.timestamp()),
                    });
                    if let Some(s) = end {
                        if let Some(e) = end_time {
                            if s > e {
                                break;
                            }
                        }
                        time = s;
                    } else {
                        break;
                    }
                }
            }
            let _ = responder.send(ClientboundPacket::InstanceList(ocs));
        }
    }
}