From 0713a82dc44deec66865c51bc2f8de1605f49fef Mon Sep 17 00:00:00 2001
From: toast <toast@toast-server.net>
Date: Sat, 17 Aug 2024 10:46:29 +1000
Subject: [PATCH] Attempt to fix timing issue

---
 src/internals/tasks/rss/processor.rs | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/src/internals/tasks/rss/processor.rs b/src/internals/tasks/rss/processor.rs
index 31f3efd..a36990d 100644
--- a/src/internals/tasks/rss/processor.rs
+++ b/src/internals/tasks/rss/processor.rs
@@ -1,5 +1,4 @@
 use super::{
-  task_info,
   task_err,
   TASK_NAME,
   BINARY_PROPERTIES,
@@ -11,6 +10,10 @@ use super::{
 };
 
 use regex::Regex;
+use tokio::time::{
+  Duration,
+  sleep
+};
 use poise::serenity_prelude::{
   Context,
   ChannelId,
@@ -57,8 +60,9 @@ pub async fn feed_processor(ctx: &Context) {
                 message.edit(&ctx.http, EditMessage::new().embed(embed)).await.unwrap();
               }
 
+              sleep(Duration::from_secs(25)).await;
+
               if Regex::new(r"(?i)\bresolved\b").unwrap().is_match(&new_desc) {
-                task_info(TASK_NAME, &format!("GPortal func, replying to message id: {}", msg_id));
                 message.reply(&ctx.http, "This incident has been marked as resolved!").await.unwrap();
                 redis.del(&rkey).await.unwrap();
               }
@@ -103,8 +107,9 @@ pub async fn feed_processor(ctx: &Context) {
                 message.edit(&ctx.http, EditMessage::new().embed(embed)).await.unwrap();
               }
 
+              sleep(Duration::from_secs(25)).await;
+
               if Regex::new(r"(?i)\bresolved\b").unwrap().is_match(&new_desc) {
-                task_info(TASK_NAME, &format!("GitHub func, replying to message id: {}", msg_id));
                 message.reply(&ctx.http, "This incident has been marked as resolved!").await.unwrap();
                 redis.del(&rkey).await.unwrap();
               }