refactor(filamento): handle_online logic

1 files changed, 4 insertions, 11 deletions

diff --git a/filamento/src/logic/process_stanza.rs b/filamento/src/logic/process_stanza.rs
index 94257aa..660da16 100644
--- a/filamento/src/logic/process_stanza.rs
+++ b/filamento/src/logic/process_stanza.rs
@@ -169,21 +169,14 @@ pub async fn recv_iq(
     }
     match iq.r#type {
         stanza::client::iq::IqType::Error | stanza::client::iq::IqType::Result => {
-            let send;
-            {
-                send = logic.pending().lock().await.remove(&iq.id);
-            }
             let from = iq
                 .from
                 .clone()
                 .unwrap_or_else(|| connection.server().clone());
-            if let Some(send) = send {
-                debug!("received iq result from {}", from);
-                let _ = send.send(Ok(Stanza::Iq(iq)));
-                Ok(None)
-            } else {
-                Err(IqError::NoMatchingId(iq.id))
-            }
+            let id = iq.id.clone();
+            debug!("received iq result with id `{}` from {}", id, from);
+            logic.pending().respond(Stanza::Iq(iq), id).await?;
+            Ok(None)
         }
         stanza::client::iq::IqType::Get => {
             let from = iq