feat(trogon-cron): move scheduling to native NATS

Author: yordis

devops/docker/compose/compose.yml

@@ -2,11 +2,14 @@ name: trogonai
 
 services:
   nats:
-    image: nats:2.11-alpine
+    image: synadia/nats-server:nightly
     command:
       - "--jetstream"
       - "--store_dir=/data"
       - "--http_port=8222"
+    ports:
+      - "127.0.0.1:14222:4222"
+      - "127.0.0.1:18222:8222"
     volumes:
       - nats_data:/data
     restart: unless-stopped

rsworkspace/Cargo.lock

@@ -6,6 +6,7 @@ pub enum ServiceName {
     AcpNatsStdio,
     AcpNatsWs,
     TrogonCron,
+    TrogonCronSpawnAdapter,
     TrogonGateway,
     TrogonSourceDiscord,
     TrogonSourceGithub,
@@ -21,6 +22,7 @@ impl ServiceName {
             Self::AcpNatsStdio => "acp-nats-stdio",
             Self::AcpNatsWs => "acp-nats-ws",
             Self::TrogonCron => "trogon-cron",
+            Self::TrogonCronSpawnAdapter => "trogon-cron-spawn-adapter",
             Self::TrogonGateway => "trogon-gateway",
             Self::TrogonSourceDiscord => "trogon-source-discord",
             Self::TrogonSourceGithub => "trogon-source-github",
@@ -47,6 +49,10 @@ mod tests {
         assert_eq!(ServiceName::AcpNatsStdio.as_str(), "acp-nats-stdio");
         assert_eq!(ServiceName::AcpNatsWs.as_str(), "acp-nats-ws");
         assert_eq!(ServiceName::TrogonCron.as_str(), "trogon-cron");
+        assert_eq!(
+            ServiceName::TrogonCronSpawnAdapter.as_str(),
+            "trogon-cron-spawn-adapter"
+        );
         assert_eq!(ServiceName::TrogonGateway.as_str(), "trogon-gateway");
         assert_eq!(
             ServiceName::TrogonSourceDiscord.as_str(),
@@ -79,6 +85,10 @@ mod tests {
         assert_eq!(format!("{}", ServiceName::AcpNatsStdio), "acp-nats-stdio");
         assert_eq!(format!("{}", ServiceName::AcpNatsWs), "acp-nats-ws");
         assert_eq!(format!("{}", ServiceName::TrogonCron), "trogon-cron");
+        assert_eq!(
+            format!("{}", ServiceName::TrogonCronSpawnAdapter),
+            "trogon-cron-spawn-adapter"
+        );
         assert_eq!(format!("{}", ServiceName::TrogonGateway), "trogon-gateway");
         assert_eq!(
             format!("{}", ServiceName::TrogonSourceDiscord),

rsworkspace/crates/acp-telemetry/src/service_name.rs

@@ -0,0 +1,28 @@
+[package]
+name = "trogon-cron-spawn-adapter"
+version = "0.1.0"
+edition = "2024"
+
+[lints]
+workspace = true
+
+[dependencies]
+acp-telemetry = { workspace = true }
+async-nats = { workspace = true }
+clap = { workspace = true, features = ["env"] }
+confique = { workspace = true }
+futures = { workspace = true }
+serde = { workspace = true, features = ["derive"] }
+serde_json = { workspace = true }
+tokio = { workspace = true, features = ["macros", "process", "rt-multi-thread", "signal", "sync", "time"] }
+tracing = { workspace = true }
+trogon-nats = { workspace = true }
+trogon-service-config = { workspace = true }
+trogon-std = { workspace = true, features = ["clap"] }
+
+[dev-dependencies]
+tempfile = { workspace = true }
+
+[[bin]]
+name = "trogon-cron-spawn-adapter"
+path = "src/main.rs"