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

Skip empty batch
All checks were successful
continuous-integration/drone Build is passing
Details

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

26
src/fetch.rs
View File

@ -55,19 +55,21 @@ impl FetchQueue {
while let Some(q) = q_lock.pop_front() {
batch.push(q);
}
let filters: Vec<Filter> =
batch.iter().map(move |x| Self::nip19_to_filter(&x.request).unwrap()).collect();
if batch.len() > 0 {
let filters: Vec<Filter> =
batch.iter().map(move |x| Self::nip19_to_filter(&x.request).unwrap()).collect();
let pool_lock = self.pool.lock().await;
info!("Sending filters: {}", serde_json::to_string(&filters).unwrap());
if let Ok(evs) = pool_lock
.get_events_of(filters, Duration::from_secs(2), FilterOptions::ExitOnEOSE)
.await
{
for b in batch {
let f = Self::nip19_to_filter(&b.request).unwrap();
let ev = evs.iter().find(|e| f.match_event(e));
b.handler.send(ev.cloned()).unwrap()
let pool_lock = self.pool.lock().await;
info!("Sending filters: {}", serde_json::to_string(&filters).unwrap());
if let Ok(evs) = pool_lock
.get_events_of(filters, Duration::from_secs(2), FilterOptions::ExitOnEOSE)
.await
{
for b in batch {
let f = Self::nip19_to_filter(&b.request).unwrap();
let ev = evs.iter().find(|e| f.match_event(e));
b.handler.send(ev.cloned()).unwrap()
}
}
}
}