feat(Rust API): Implement Rust Cron Module

.config/dictionaries/project.dic

@@ -68,6 +68,7 @@ miniprotocols
 mithril
 mitigations
 mkcron
+mkdelay
 mkdirat
 moderations
 multiera

hermes/Cargo.toml

@@ -59,3 +59,4 @@ anyhow = "1.0.71"
 blake2b_simd = "1.0.2"
 hex-literal = "0.4.1"
 thiserror = "1.0.56"
+time = "0.3.34"

hermes/bin/Cargo.toml

@@ -19,3 +19,4 @@ anyhow = { workspace = true }
 blake2b_simd = { workspace = true }  
 hex-literal = { workspace = true }  
 thiserror = { workspace = true }
+time = { workspace = true }

hermes/bin/src/runtime_extensions/hermes/cron/host.rs

@@ -1,9 +1,12 @@
 //! Cron host implementation for WASM runtime.
 
 use crate::{
-    runtime_extensions::bindings::{
-        hermes::cron::api::{CronEventTag, CronSched, CronTagged, CronTime, Host},
-        wasi::clocks::monotonic_clock::Instant,
+    runtime_extensions::{
+        bindings::{
+            hermes::cron::api::{CronEventTag, CronSched, CronTagged, CronTime, Host},
+            wasi::clocks::monotonic_clock::Instant,
+        },
+        hermes::cron::{mkcron_impl, mkdelay_crontab, CronTab},
     },
     state::HermesState,
 };
@@ -33,8 +36,12 @@ impl Host for HermesState {
     /// If the crontab entry already exists, the retrigger flag can be changed by calling
     /// this function.  This could be useful where a retriggering crontab event is desired
     /// to be stopped, but ONLY after it has triggered once more.
-    fn add(&mut self, _entry: CronTagged, _retrigger: bool) -> wasmtime::Result<bool> {
-        todo!()
+    fn add(&mut self, entry: CronTagged, retrigger: bool) -> wasmtime::Result<bool> {
+        self.hermes
+            .cron
+            .crontabs
+            .insert(entry.tag.clone(), CronTab { entry, retrigger });
+        Ok(true)
     }
 
     /// # Schedule A Single cron event after a fixed delay.
@@ -60,8 +67,10 @@ impl Host for HermesState {
     /// It is added as a non-retriggering event.
     /// Listing the crontabs after this call will list the delay in addition to all other
     /// crontab entries.
-    fn delay(&mut self, _duration: Instant, _tag: CronEventTag) -> wasmtime::Result<bool> {
-        todo!()
+    fn delay(&mut self, duration: Instant, tag: CronEventTag) -> wasmtime::Result<bool> {
+        let crontab = mkdelay_crontab(duration, tag)?;
+        self.add(crontab, false)?;
+        Ok(true)
     }
 
     /// # List currently active cron schedule.
@@ -81,8 +90,21 @@ impl Host for HermesState {
     /// may times before a later one.
     /// - `0` - `cron-tagged` - The Tagged crontab event.
     /// - `1` - `bool` - The state of the retrigger flag.
-    fn ls(&mut self, _tag: Option<CronEventTag>) -> wasmtime::Result<Vec<(CronTagged, bool)>> {
-        todo!()
+    fn ls(&mut self, tag: Option<CronEventTag>) -> wasmtime::Result<Vec<(CronTagged, bool)>> {
+        if let Some(tag) = tag {
+            match self.hermes.cron.crontabs.get(&tag) {
+                Some(cron) => Ok(vec![(cron.entry.clone(), cron.retrigger)]),
+                None => Ok(vec![]),
+            }
+        } else {
+            Ok(self
+                .hermes
+                .cron
+                .crontabs
+                .values()
+                .map(|cron| (cron.entry.clone(), cron.retrigger))
+                .collect())
+        }
     }
 
     /// # Remove the requested crontab.
@@ -98,13 +120,16 @@ impl Host for HermesState {
     ///
     /// - `true`: The requested crontab was deleted and will not trigger.
     /// - `false`: The requested crontab does not exist.
-    fn rm(&mut self, _entry: CronTagged) -> wasmtime::Result<bool> {
-        todo!()
+    fn rm(&mut self, entry: CronTagged) -> wasmtime::Result<bool> {
+        match self.hermes.cron.crontabs.remove(&entry.tag) {
+            Some(_) => Ok(true),
+            None => Ok(false),
+        }
     }
 
     /// # Make a crontab entry from individual time values.
     ///
-    /// Crates the properly formatted cron entry
+    /// Creates the properly formatted cron entry
     /// from numeric cron time components.
     /// Convenience function to make building cron strings simpler when they are
     /// calculated from data.
@@ -129,9 +154,8 @@ impl Host for HermesState {
     /// - For example specifying a `month` as `3` and `2-4` will
     /// remove the individual month and only produce the range.
     fn mkcron(
-        &mut self, _dow: CronTime, _month: CronTime, _day: CronTime, _hour: CronTime,
-        _minute: CronTime,
+        &mut self, dow: CronTime, month: CronTime, day: CronTime, hour: CronTime, minute: CronTime,
     ) -> wasmtime::Result<CronSched> {
-        todo!()
+        Ok(mkcron_impl(&dow, &month, &day, &hour, &minute))
     }
 }