From b28a356cb41077ccee12a9c52f4ef2054e76cac6 Mon Sep 17 00:00:00 2001 From: DanConwayDev Date: Fri, 9 Jan 2026 19:58:41 +0000 Subject: chore: cargo fmt --- src/nostr/builder.rs | 20 ++++++++++++-------- src/nostr/policy/state.rs | 8 +++++--- 2 files changed, 17 insertions(+), 11 deletions(-) (limited to 'src/nostr') diff --git a/src/nostr/builder.rs b/src/nostr/builder.rs index acaac71..c010854 100644 --- a/src/nostr/builder.rs +++ b/src/nostr/builder.rs @@ -102,11 +102,11 @@ impl Nip34WritePolicy { } tracing::debug!("Accepted repository announcement: {}", event_id_str); - + // Check purgatory for state events that might now be authorized self.check_purgatory_state_events_for_identifier(&announcement.identifier) .await; - + WritePolicyResult::Accept } Err(e) => { @@ -130,11 +130,11 @@ impl Nip34WritePolicy { announcement.identifier ); // Don't create bare repository for external announcements - + // Check purgatory for state events that might now be authorized self.check_purgatory_state_events_for_identifier(&announcement.identifier) .await; - + WritePolicyResult::Accept } Err(e) => { @@ -324,20 +324,24 @@ impl Nip34WritePolicy { /// 4. Keeps unauthorized events in purgatory (will expire naturally) async fn check_purgatory_state_events_for_identifier(&self, identifier: &str) { let state_events = self.ctx.purgatory.find_state(identifier); - + if state_events.is_empty() { return; } - + tracing::debug!( identifier = %identifier, count = state_events.len(), "Checking purgatory state events after announcement acceptance" ); - + for entry in state_events { // Re-evaluate authorization with the new announcement - match self.state_policy.process_state_event(&entry.event, false).await { + match self + .state_policy + .process_state_event(&entry.event, false) + .await + { Ok(WritePolicyResult::Accept) => { tracing::info!( event_id = %entry.event.id, diff --git a/src/nostr/policy/state.rs b/src/nostr/policy/state.rs index d26b5ec..b850e7b 100644 --- a/src/nostr/policy/state.rs +++ b/src/nostr/policy/state.rs @@ -93,9 +93,11 @@ impl StatePolicy { }); } - let authorized_owners = - crate::git::authorization::pubkey_authorised_for_repo_owners(&event.pubkey, &db_repo_data); - + let authorized_owners = crate::git::authorization::pubkey_authorised_for_repo_owners( + &event.pubkey, + &db_repo_data, + ); + if authorized_owners.is_empty() { tracing::warn!( event_id = %event.id, -- cgit v1.2.3