src/service/core.rs

@@ -37,6 +37,25 @@ impl Service {
 
         println!("Can schedule");
 
+        let events_req = super::event::Event {
+            app: self.app.clone(),
+            token: self.token.clone()
+        };
+
+        let scheduled_message_id = queue_item.id;
+        let events = match events_req.get(&scheduled_message_id).await {
+            Ok(events) => Some(events),
+            Err(err) => {
+                eprintln!("Error: {err:?}");
+                None
+            }
+        };
+
+        // for event in &events {
+        while let Some(event) = &events {
+            println!("Event: {event:?}");
+        }
+
         todo!(
             r#"
         Need to finish this
@@ -65,7 +84,7 @@ impl Service {
         let now = time::OffsetDateTime::now_utc();
 
         match queue_item.scheduled {
-            Some(date) => date <= now,
+            Some(date) => date > now,
             None => false,
         }
     }