Kieran/nostr-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Print filters json

Browse Source
This commit is contained in:
kieran 2024-09-05 10:40:18 +01:00
parent ae107978f7
commit 52ec0d7b5a
No known key found for this signature in database
GPG Key ID: DE71CEB3925BE941
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/fetch.rs
View File

@ -3,7 +3,7 @@ use std::sync::Arc;
use std::time::Duration; use std::time::Duration;
use nostr::prelude::Nip19; use nostr::prelude::Nip19;
use nostr::{Event, EventId, Filter, Kind, Url}; use nostr::{serde_json, Event, EventId, Filter, Kind, Url};
use nostr_sdk::{FilterOptions, RelayOptions, RelayPool}; use nostr_sdk::{FilterOptions, RelayOptions, RelayPool};
use tokio::sync::{oneshot, Mutex}; use tokio::sync::{oneshot, Mutex};
@ -59,7 +59,7 @@ impl FetchQueue {
batch.iter().map(move |x| Self::nip19_to_filter(&x.request).unwrap()).collect(); batch.iter().map(move |x| Self::nip19_to_filter(&x.request).unwrap()).collect();
let pool_lock = self.pool.lock().await; let pool_lock = self.pool.lock().await;
info!("Sending filters: {:?}", &filters); info!("Sending filters: {}", serde_json::to_string(&filters).unwrap());
if let Ok(evs) = pool_lock if let Ok(evs) = pool_lock
.get_events_of(filters, Duration::from_secs(2), FilterOptions::ExitOnEOSE) .get_events_of(filters, Duration::from_secs(2), FilterOptions::ExitOnEOSE)
.await .await