GeneralBots/botserver
2
1
Fork 0
Code Issues Pull requests Projects Releases 323 Packages Wiki Activity Actions

Fix Redis BLPOP return type: handle (key, value) tuple
All checks were successful
BotServer CI / build (push) Successful in 13m52s
Details

Browse source
This commit is contained in:
Rodrigo Rodriguez (Pragmatismo) 2026-03-09 19:43:47 -03:00
parent 5d3174b24e
commit 47e1013700
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/core/bot/channels/whatsapp_queue.rs
View file

@ -76,9 +76,10 @@ impl WhatsAppMessageQueue {
async fn process_next(&self) -> Result<(), Box<dyn std::error::Error + Send + Sync>> { async fn process_next(&self) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
let mut conn = self.redis_client.get_multiplexed_async_connection().await?; let mut conn = self.redis_client.get_multiplexed_async_connection().await?;
let result: Option<String> = conn.blpop(Self::QUEUE_KEY, 5.0).await?; // BLPOP returns (key, value) tuple
let result: Option<(String, String)> = conn.blpop(Self::QUEUE_KEY, 5.0).await?;
if let Some(json) = result { if let Some((_key, json)) = result {
let msg: QueuedWhatsAppMessage = serde_json::from_str(&json)?; let msg: QueuedWhatsAppMessage = serde_json::from_str(&json)?;
// Check and enforce rate limit for this recipient // Check and enforce rate limit for this recipient