merge scheduler from private prototype repo.

Author: TheHeroBrine422

Cargo.lock

@@ -1,6 +1,6 @@
 [workspace]
 resolver = "3"
-members = ["odorobo-agent", "odoroboctl", "shared"]
+members = ["odorobo-agent", "odoroboctl", "odorobo-scheduler", "odorobo-shared"]
 
 [workspace.dependencies]
 stable-eyre = "0.2.2"

Cargo.toml

@@ -0,0 +1,28 @@
+[package]
+name = "odorobo-scheduler"
+version = "0.1.0"
+edition = "2024"
+
+[[bin]]
+name = "odorobo-scheduler"
+
+[[bin]]
+name = "gen_openapi_spec"
+
+[dependencies]
+kameo = { version = "0.19.2", features = ["remote"] }
+axum = { version = "0.8.8", features = ["tracing", "macros"] }
+env = "1.0.1"
+serde = { version = "1.0.228", features = ["derive"] }
+serde_json = "1.0.149"
+tokio = { version = "1.50.0", features = ["full"] } # TODO (june): tracing is only in tokio unstable?      NOTE (caleb): I think that just refers to tokio logging tracing events, we can still make our own and look at other crate's events if necessary.
+tower-http = { version = "0.6.1", features = ["trace"] }
+tracing = "0.1.44"
+optional_struct = "0.5.2"
+tracing-subscriber = { version = "0.3.2", features = ["env-filter"] }
+uuid = { version = "1.23.0", features = ["serde"]}
+libp2p = { version = "0.56.0", features = ["yamux", "serde", "mdns"] }
+reqwest = { version = "0.13", features = ["json"] }
+ahash = { version = "0.8.12", features = ["serde"] }
+utoipa = { version = "5.4.0", features=["uuid"] }
+odorobo-shared = { path = "../odorobo-shared" }

odorobo-scheduler/Cargo.toml

@@ -0,0 +1,7 @@
+use std::fs;
+use odorobo_scheduler::scheduler_actor::gen_openapi_spec;
+
+fn main() -> std::io::Result<()> {
+    let doc = gen_openapi_spec();
+    fs::write("./openapi_spec.json", doc)
+}

odorobo-scheduler/src/bin/gen_openapi_spec.rs

@@ -0,0 +1,16 @@
+use kameo::prelude::*;
+use odorobo_shared::utils::DynError;
+use odorobo_scheduler::scheduler_actor::SchedulerActor;
+use odorobo_shared::connect_to_swarm;
+
+#[tokio::main]
+async fn main() -> Result<(), DynError> {
+    let _local_peer_id = connect_to_swarm()?;
+
+    let actor_ref = SchedulerActor::spawn(SchedulerActor {});
+    actor_ref.register("scheduler").await?;
+
+    actor_ref.wait_for_shutdown().await;
+
+    Ok(())
+}

odorobo-scheduler/src/bin/odorobo-scheduler.rs

@@ -0,0 +1,2 @@
+
+pub mod scheduler_actor;