feat(raygun): use MessageOptions.limit when fetching messages

extensions/warp-ipfs/src/store/conversation.rs

@@ -376,8 +376,11 @@ impl ConversationDocument {
 
         let ipfs = ipfs.clone();
         let stream = async_stream::stream! {
-
+            let mut remaining: Option<i64> = option.limit();
             for (index, document) in messages.iter().enumerate() {
+                if remaining.as_ref().map(|x| *x == 0).unwrap_or_default() {
+                    break;
+                }
                 if let Some(range) = option.range() {
                     if range.start > index || range.end < index {
                         continue
@@ -388,20 +391,22 @@ impl ConversationDocument {
                         continue
                     }
                 }
-
                 if let Ok(message) = document.resolve(&ipfs, &did, keystore.as_ref()).await {
                     if option.pinned() && !message.pinned() {
                         continue;
                     }
-                    if let Some(keyword) = option.keyword() {
-                        if message
+                    let should_yield = if let Some(keyword) = option.keyword() {
+                         message
                             .value()
                             .iter()
                             .any(|line| line.to_lowercase().contains(&keyword.to_lowercase()))
-                        {
-                            yield message;
-                        }
                     } else {
+                        true
+                    };
+                    if should_yield {
+                        if let Some(remaining) = remaining.as_mut() {
+                            *remaining = remaining.saturating_sub(1);
+                        }
                         yield message;
                     }
                 }