Nostr contact resolver (#509)

* Nostr contact helper functions

* Revert default config

* Nostr contact store

* Use Nostr contacts, fix all tests

* Use Nostr contacts

* Resolve contacts on bill event

* Global trusted contact config flag

* Review fixes

* Review fixes

Author: tompro

.cargo/config.toml

@@ -0,0 +1,6 @@
+[env]
+# our dev nostr relay
+NOSTR_RELAY = "ws://bitcr-cloud-run-05-550030097098.europe-west1.run.app"
+
+# more detailed logs
+RUST_LOG = "info"

.gitignore

@@ -1,7 +1,7 @@
 /target
 /contacts/*
 /esplora/.docker_data/
-./data/
+/data
 /frontend_build/*
 /identity/*
 /bills/*

Cargo.toml

@@ -9,9 +9,9 @@ members = [
 ]
 
 [profile.release]
-opt-level = "s"      # Optimize for size ("z" can be used for even more aggressive size reduction)
-lto = true           # Enable Link-Time Optimization
-codegen-units = 1    # Reduces binary size at the cost of compile time
+opt-level = "s"   # Optimize for size ("z" can be used for even more aggressive size reduction)
+lto = true        # Enable Link-Time Optimization
+codegen-units = 1 # Reduces binary size at the cost of compile time
 
 [workspace.dependencies]
 sha2 = { version = "0.10", default-features = false }
@@ -36,8 +36,8 @@ uuid = { version = "1", default-features = false, features = ["v4", "js"] }
 bitcoin = { version = "0.32", default-features = false }
 bip39 = { version = "2.1", features = ["rand"] }
 ecies = { version = "0.2", default-features = false, features = ["pure"] }
-nostr = { version = "0.40"}
-nostr-sdk = { version = "0.40", features = ["nip04", "nip59"] }
+nostr = { version = "0.41" }
+nostr-sdk = { version = "0.41", features = ["nip04", "nip59"] }
 getrandom = { version = "0.3.1", features = ["wasm_js"] }
 async-broadcast = "0.7.2"
 rstest = "0.25.0"

crates/bcr-ebill-api/Cargo.toml

@@ -21,6 +21,7 @@ thiserror.workspace = true
 uuid.workspace = true
 bitcoin.workspace = true
 nostr-sdk.workspace = true
+nostr.workspace = true
 futures.workspace = true
 infer = { version = "0.19.0", default-features = false }
 bcr-ebill-core = { path = "../bcr-ebill-core" }
@@ -37,7 +38,7 @@ reqwest = { workspace = true, features = ["default", "json"] }
 
 [dev-dependencies]
 mockall = "0.13.1"
-nostr-relay-builder = "0.40"
+nostr-relay-builder = "0.41"
 tokio.workspace = true
 async-broadcast.workspace = true
 

crates/bcr-ebill-api/src/lib.rs

@@ -24,9 +24,9 @@ pub use persistence::notification::NotificationFilter;
 pub struct Config {
     pub bitcoin_network: String,
     pub esplora_base_url: String,
-    pub nostr_relays: Vec<String>,
     pub db_config: SurrealDbConfig,
     pub data_dir: String,
+    pub nostr_config: NostrConfig,
 }
 
 static CONFIG: OnceLock<Config> = OnceLock::new();
@@ -43,6 +43,15 @@ impl Config {
     }
 }
 
+/// Nostr specific configuration
+#[derive(Debug, Clone, Default)]
+pub struct NostrConfig {
+    /// Only known contacts can message us via DM.
+    pub only_known_contacts: bool,
+    /// All relays we want to publish our messages to and receive messages from.
+    pub relays: Vec<String>,
+}
+
 pub fn init(conf: Config) -> Result<()> {
     CONFIG
         .set(conf)

crates/bcr-ebill-api/src/persistence/mod.rs

@@ -6,11 +6,14 @@ use bcr_ebill_persistence::{
     SurrealNostrEventOffsetStore, SurrealNotificationStore,
     bill::{BillChainStoreApi, BillStoreApi},
     company::{CompanyChainStoreApi, CompanyStoreApi},
-    db::nostr_send_queue::SurrealNostrEventQueueStore,
+    db::{
+        nostr_contact_store::SurrealNostrContactStore,
+        nostr_send_queue::SurrealNostrEventQueueStore,
+    },
     file_upload::FileUploadStoreApi,
     get_surreal_db,
     identity::{IdentityChainStoreApi, IdentityStoreApi},
-    nostr::NostrQueuedMessageStoreApi,
+    nostr::{NostrContactStoreApi, NostrQueuedMessageStoreApi},
 };
 use log::error;
 use std::sync::Arc;
@@ -42,6 +45,7 @@ pub struct DbContext {
     pub notification_store: Arc<dyn NotificationStoreApi>,
     pub backup_store: Arc<dyn BackupStoreApi>,
     pub queued_message_store: Arc<dyn NostrQueuedMessageStoreApi>,
+    pub nostr_contact_store: Arc<dyn NostrContactStoreApi>,
 }
 
 /// Creates a new instance of the DbContext with the given SurrealDB configuration.
@@ -80,6 +84,7 @@ pub async fn get_db_context(conf: &Config) -> bcr_ebill_persistence::Result<DbCo
     let notification_store = Arc::new(SurrealNotificationStore::new(db.clone()));
     let backup_store = Arc::new(SurrealBackupStore::new(db.clone()));
     let queued_message_store = Arc::new(SurrealNostrEventQueueStore::new(db.clone()));
+    let nostr_contact_store = Arc::new(SurrealNostrContactStore::new(db.clone()));
 
     Ok(DbContext {
         contact_store,
@@ -94,5 +99,6 @@ pub async fn get_db_context(conf: &Config) -> bcr_ebill_persistence::Result<DbCo
         notification_store,
         backup_store,
         queued_message_store,
+        nostr_contact_store,
     })
 }