toast/Kon
toast/Kon
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Activity

Attempt to fix timing issue
All checks were successful
Build and push container image / build (push) Successful in 12m32s
Details
Build and push container image / deploy (push) Successful in 34s
Details

Browse Source
This commit is contained in:
toast 2024-08-17 10:46:29 +10:00
parent cb660d13f4
commit 0713a82dc4
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/internals/tasks/rss/processor.rs
View File

@ -1,5 +1,4 @@
use super::{ use super::{
task_info,
task_err, task_err,
TASK_NAME, TASK_NAME,
BINARY_PROPERTIES, BINARY_PROPERTIES,
@ -11,6 +10,10 @@ use super::{
}; };
use regex::Regex; use regex::Regex;
use tokio::time::{
Duration,
sleep
};
use poise::serenity_prelude::{ use poise::serenity_prelude::{
Context, Context,
ChannelId, ChannelId,
@ -57,8 +60,9 @@ pub async fn feed_processor(ctx: &Context) {
message.edit(&ctx.http, EditMessage::new().embed(embed)).await.unwrap(); 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) { 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(); message.reply(&ctx.http, "This incident has been marked as resolved!").await.unwrap();
redis.del(&rkey).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(); 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) { 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(); message.reply(&ctx.http, "This incident has been marked as resolved!").await.unwrap();
redis.del(&rkey).await.unwrap(); redis.del(&rkey).await.unwrap();
} }