Public chain handling (#534)

* Refactor handlers and subscriptions

* Structured subscriptions

* Docs

* Chain key resolver

* Update crates/bcr-ebill-transport/src/chain_keys.rs

Co-authored-by: Copilot <[email protected]>

* Review fixes

---------

Co-authored-by: Copilot <[email protected]>

Author: tompro

crates/bcr-ebill-api/src/service/contact_service.rs

@@ -99,9 +99,11 @@ pub trait ContactServiceApi: ServiceTraitBounds {
     ) -> Result<Contact>;
 
     /// Returns whether a given npub (as hex) is in our contact list.
-    #[allow(dead_code)]
     async fn is_known_npub(&self, npub: &PublicKey) -> Result<bool>;
 
+    /// Returns the Npubs we want to subscribe to on Nostr.
+    async fn get_nostr_npubs(&self) -> Result<Vec<PublicKey>>;
+
     /// opens and decrypts the attached file from the given contact
     async fn open_and_decrypt_file(
         &self,
@@ -533,6 +535,14 @@ impl ContactServiceApi for ContactService {
                 .unwrap_or(false))
     }
 
+    /// Returns the Npubs we want to subscribe to on Nostr.
+    async fn get_nostr_npubs(&self) -> Result<Vec<PublicKey>> {
+        Ok(self
+            .nostr_contact_store
+            .get_npubs(vec![TrustLevel::Trusted, TrustLevel::Participant])
+            .await?)
+    }
+
     async fn open_and_decrypt_file(
         &self,
         id: &str,

crates/bcr-ebill-api/src/service/notification_service/default_service.rs

@@ -662,9 +662,10 @@ mod tests {
     };
     use super::*;
     use crate::tests::tests::{
-        MockBillChainStoreApiMock, MockBillStoreApiMock, MockNostrChainEventStore,
-        MockNostrContactStore, MockNostrEventOffsetStoreApiMock, MockNostrQueuedMessageStore,
-        MockNotificationStoreApiMock, TEST_BILL_ID, TEST_PRIVATE_KEY_SECP, TEST_PUB_KEY_SECP,
+        MockBillChainStoreApiMock, MockBillStoreApiMock, MockChainKeyService,
+        MockNostrChainEventStore, MockNostrContactStore, MockNostrEventOffsetStoreApiMock,
+        MockNostrQueuedMessageStore, MockNotificationStoreApiMock, TEST_BILL_ID,
+        TEST_PRIVATE_KEY_SECP, TEST_PUB_KEY_SECP,
     };
 
     fn check_chain_payload(event: &EventEnvelope, bill_event_type: BillEventType) -> bool {
@@ -1893,6 +1894,7 @@ mod tests {
         let bill_store = Arc::new(MockBillStoreApiMock::new());
         let bill_blockchain_store = Arc::new(MockBillChainStoreApiMock::new());
         let nostr_contact_store = Arc::new(MockNostrContactStore::new());
+        let chain_key_store = Arc::new(MockChainKeyService::new());
         let _ = create_nostr_consumer(
             clients,
             contact_service,
@@ -1902,6 +1904,7 @@ mod tests {
             bill_blockchain_store,
             bill_store,
             nostr_contact_store,
+            chain_key_store,
         )
         .await;
     }

crates/bcr-ebill-api/src/service/notification_service/mod.rs

@@ -10,6 +10,7 @@ use bcr_ebill_persistence::company::CompanyStoreApi;
 use bcr_ebill_persistence::nostr::{
     NostrChainEventStoreApi, NostrContactStoreApi, NostrQueuedMessageStoreApi,
 };
+use bcr_ebill_transport::chain_keys::ChainKeyServiceApi;
 use bcr_ebill_transport::handler::{
     BillChainEventHandler, LoggingEventHandler, NotificationHandlerApi,
 };
@@ -50,6 +51,7 @@ pub async fn create_nostr_clients(
         keys,
         config.nostr_config.relays.clone(),
         nostr_name,
+        true,
     )];
 
     // optionally collect all company accounts
@@ -67,6 +69,7 @@ pub async fn create_nostr_clients(
                 keys,
                 config.nostr_config.relays.clone(),
                 company.name.clone(),
+                false,
             ));
         }
     }
@@ -119,6 +122,7 @@ pub async fn create_nostr_consumer(
     bill_blockchain_store: Arc<dyn BillChainStoreApi>,
     bill_store: Arc<dyn BillStoreApi>,
     nostr_contact_store: Arc<dyn NostrContactStoreApi>,
+    chain_key_service: Arc<dyn ChainKeyServiceApi>,
 ) -> Result<NostrConsumer> {
     // we need one nostr client for nostr interactions
     let transport = match clients.first() {
@@ -141,6 +145,12 @@ pub async fn create_nostr_consumer(
         )),
     ];
     debug!("initializing nostr consumer for {} clients", clients.len());
-    let consumer = NostrConsumer::new(clients, contact_service, handlers, nostr_event_offset_store);
+    let consumer = NostrConsumer::new(
+        clients,
+        contact_service,
+        handlers,
+        nostr_event_offset_store,
+        chain_key_service,
+    );
     Ok(consumer)
 }