diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2025-12-22 21:02:03 +0000 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2025-12-22 21:02:03 +0000 |
| commit | 1df90c609399c675e629b97294aee81a0b1e66dd (patch) | |
| tree | 8482cdd0ea87cc0df5a86672bf99399aa0aa1a3d /src/sync/mod.rs | |
| parent | 5d3d96c7f0397a079384b7291ff21df76029b126 (diff) | |
chore: bump rust-nostr to latest master
so we can more easily support grasp purgatory feature
Diffstat (limited to 'src/sync/mod.rs')
| -rw-r--r-- | src/sync/mod.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/sync/mod.rs b/src/sync/mod.rs index d315939..6ec39e8 100644 --- a/src/sync/mod.rs +++ b/src/sync/mod.rs | |||
| @@ -260,11 +260,11 @@ async fn run_daily_timer( | |||
| 260 | sync_manager: Arc<Mutex<SyncManager>>, | 260 | sync_manager: Arc<Mutex<SyncManager>>, |
| 261 | mut shutdown_rx: broadcast::Receiver<()>, | 261 | mut shutdown_rx: broadcast::Receiver<()>, |
| 262 | ) { | 262 | ) { |
| 263 | use rand::Rng; | 263 | use ::rand::Rng; |
| 264 | 264 | ||
| 265 | loop { | 265 | loop { |
| 266 | // Random interval between 23-25 hours | 266 | // Random interval between 23-25 hours |
| 267 | let hours = 23.0 + rand::thread_rng().gen::<f64>() * 2.0; | 267 | let hours = 23.0 + ::rand::thread_rng().gen::<f64>() * 2.0; |
| 268 | let seconds = (hours * 3600.0) as u64; | 268 | let seconds = (hours * 3600.0) as u64; |
| 269 | 269 | ||
| 270 | tracing::info!( | 270 | tracing::info!( |
| @@ -1599,7 +1599,7 @@ impl SyncManager { | |||
| 1599 | write_policy: &Nip34WritePolicy, | 1599 | write_policy: &Nip34WritePolicy, |
| 1600 | local_relay: &LocalRelay, | 1600 | local_relay: &LocalRelay, |
| 1601 | ) -> ProcessResult { | 1601 | ) -> ProcessResult { |
| 1602 | use nostr_relay_builder::prelude::{PolicyResult, WritePolicy}; | 1602 | use nostr_relay_builder::prelude::{WritePolicyResult, WritePolicy}; |
| 1603 | use std::net::{IpAddr, Ipv4Addr, SocketAddr}; | 1603 | use std::net::{IpAddr, Ipv4Addr, SocketAddr}; |
| 1604 | // Check if event already exists | 1604 | // Check if event already exists |
| 1605 | match database.event_by_id(&event.id).await { | 1605 | match database.event_by_id(&event.id).await { |
| @@ -1619,7 +1619,7 @@ impl SyncManager { | |||
| 1619 | let result = write_policy.admit_event(event, &dummy_addr).await; | 1619 | let result = write_policy.admit_event(event, &dummy_addr).await; |
| 1620 | 1620 | ||
| 1621 | match result { | 1621 | match result { |
| 1622 | PolicyResult::Accept => { | 1622 | WritePolicyResult::Accept => { |
| 1623 | // Save event to database | 1623 | // Save event to database |
| 1624 | if let Err(e) = database.save_event(event).await { | 1624 | if let Err(e) = database.save_event(event).await { |
| 1625 | tracing::error!( | 1625 | tracing::error!( |
| @@ -1644,11 +1644,11 @@ impl SyncManager { | |||
| 1644 | ); | 1644 | ); |
| 1645 | ProcessResult::Saved | 1645 | ProcessResult::Saved |
| 1646 | } | 1646 | } |
| 1647 | PolicyResult::Reject(reason) => { | 1647 | WritePolicyResult::Reject { message, .. } => { |
| 1648 | tracing::debug!( | 1648 | tracing::debug!( |
| 1649 | event_id = %event.id, | 1649 | event_id = %event.id, |
| 1650 | relay = %relay_url, | 1650 | relay = %relay_url, |
| 1651 | reason = %reason, | 1651 | reason = %message, |
| 1652 | "Event rejected by write policy" | 1652 | "Event rejected by write policy" |
| 1653 | ); | 1653 | ); |
| 1654 | ProcessResult::Rejected | 1654 | ProcessResult::Rejected |