diff --git a/src/main.rs b/src/main.rs index 34d8390..4fbd0c9 100644 --- a/src/main.rs +++ b/src/main.rs @@ -55,13 +55,26 @@ impl EventHandler for Handler { let mut msgs = channel .messages(&ctx, |messages| messages.after(after)) .await - .unwrap(); + .unwrap() + .into_iter() + .filter(|message| message.id <= msg.id) + .rev() + .collect::>(); tokio::time::sleep(Duration::from_millis(250)).await; - let current_id = ctx.http.get_current_user().await.unwrap().id; + msgs.append( + &mut channel + .messages(&ctx, |messages| messages.after(msg.id)) + .await + .unwrap() + .into_iter() + .filter(|message| message.webhook_id.is_some()) + .rev() + .collect::>(), + ); - msgs.reverse(); + let current_id = ctx.http.get_current_user().await.unwrap().id; for pk_msg in msgs .clone() @@ -220,27 +233,4 @@ async fn main() { if let Err(why) = client.start().await { println!("Client error: {:?}", why); } - - // let messages = vec![openai::Message { - // role: openai::Role::User, - // content: String::from("Say this is a test!"), - // }]; - - // let chat_completion = openai::ChatCompletion { - // model: String::from("gpt-3.5-turbo"), - // messages, - // ..Default::default() - // }; - - // match client.create_chat_completion(chat_completion).await { - // Ok(response) => { - // println!( - // "Chat completion response: {:?}", - // response.choices.first().unwrap().message.content - // ); - // } - // Err(error) => { - // eprintln!("Error: {}", error); - // } - // } }