upleb.uk

Public git repos — served from a NIP-34 GRASP relay at git.upleb.uk

summaryrefslogtreecommitdiff
path: root/src/sync/mod.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/sync/mod.rs')
-rw-r--r--src/sync/mod.rs12
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