From fd3da4eba07ad3686215446f46f6962153bb1904 Mon Sep 17 00:00:00 2001
From: phoenix <mail@kundeng.us>
Date: Wed, 24 Jun 2026 22:28:38 -0400
Subject: [PATCH] Fixed function issue

---
 src/service/core.rs | 21 ++++++++++++++++++++-
 1 file changed, 20 insertions(+), 1 deletion(-)

diff --git a/src/service/core.rs b/src/service/core.rs
index 9059578..b10166c 100644
--- a/src/service/core.rs
+++ b/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,
         }
     }