diff --git a/src/service/core.rs b/src/service/core.rs index 7a5e042..00f755f 100644 --- a/src/service/core.rs +++ b/src/service/core.rs @@ -30,6 +30,13 @@ impl Service { println!("Queue item Id: {:?}", queue_item.id); + if self.is_schedulable(&queue_item) { + println!("Can schedule"); + } else { + println!("Not schedulable"); + return; + } + todo!( r#" Need to finish this @@ -50,4 +57,16 @@ impl Service { "# ); } + + fn is_schedulable( + &self, + queue_item: &textsender_models::message::scheduling::ScheduledMessage, + ) -> bool { + let now = time::OffsetDateTime::now_utc(); + + match queue_item.scheduled { + Some(date) => date <= now, + None => false, + } + } }