use repository::OpenRepositories;

use crate::event_loop::Event;
use crate::repository::OpenRepositories;

mod event_loop;

    event_loop::start();

use std::sync::OnceLock;
use tokio::sync::mpsc::{UnboundedReceiver, UnboundedSender};
static EVENT_SENDER: OnceLock<UnboundedSender<Event>> = OnceLock::new();
const EVENT_BATCH_LIMIT: usize = 8;
#[derive(Debug)]
pub enum Event {}
#[tokio::main]
#[tracing::instrument(skip_all)]
async fn event_loop(mut receiver: UnboundedReceiver<Event>) {
    tracing::info!("Starting event loop");
    let mut event_buffer = Vec::with_capacity(EVENT_BATCH_LIMIT);
    loop {
        let events_received = receiver
            .recv_many(&mut event_buffer, EVENT_BATCH_LIMIT)
            .await;
        if events_received == 0 {
            // Channel has been closed, stop event loop
            tracing::info!("Shutting down event loop");
            break;
        };
        tracing::debug!(?event_buffer);
        event_buffer.clear();
    }
}
#[tracing::instrument]
pub fn start() {
    let (sender, receiver) = tokio::sync::mpsc::unbounded_channel();
    if let Err(_existing_value) = EVENT_SENDER.set(sender) {
        tracing::error!("Event sender has already been initialized");
    }
    std::thread::spawn(|| event_loop(receiver));
}
pub fn send(event: Event) {
    EVENT_SENDER
        .get()
        .expect("EVENT_SENDER should be set")
        .send(event)
        .expect("Receiver should be open");
}

tokio.workspace = true

tokio = { version = "1.48", features = ["full"] }

 "tokio",

[[package]]
name = "signal-hook-registry"
version = "1.4.7"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "7664a098b8e616bdfcc2dc0e9ac44eb231eedf41db4e9fe95d8d32ec728dedad"
dependencies = [
 "libc",
]

 "parking_lot 0.12.5",

 "signal-hook-registry",

 "tokio-macros",

]
[[package]]
name = "tokio-macros"
version = "2.6.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "af407857209536a95c8e56f8231ef2c2e2aff839b22e07a1ffcbc617e9db9fa5"
dependencies = [
 "proc-macro2",
 "quote",
 "syn",