Gossip

CHANGELOG.md

@@ -61,13 +61,17 @@
 * pool: deprecate auto adjustment of retry seconds for relays ([Yuki Kishimoto])
 * pool: avoid unnecessary `Url` and `Relay` clone in `RelayPool` methods ([Yuki Kishimoto])
 * pool: avoid `Relay` clone in `RelayPool::connect_relay` method ([Yuki Kishimoto])
+* pool: `RelayPool::send_event` and `RelayPool::batch_event` send only to relays with `WRITE` flag ([Yuki Kishimoto])
+* pool: `RelayPool::subscribe_with_id`, `RelayPool::get_events_of` and `RelayPool::stream_events_of` REQ events only to relays with `READ` flag ([Yuki Kishimoto])
 * signer: update NIP-04 and NIP-44 methods signature ([Yuki Kishimoto])
 * webln: bump `webln` to `v0.3` ([Yuki Kishimoto])
 * sqlite: deprecate `SQLiteDatabase` in favor of LMDB ([Yuki Kishimoto])
 * sdk: bump `lnurl-pay` to `v0.6` ([Yuki Kishimoto])
 * sdk: update `Client::gift_wrap` and `Client::gift_wrap_to` methods signature ([Yuki Kishimoto])
 * sdk: document and rename `Client::metadata` to `Client::fetch_metadata` ([Janek])
 * sdk: update `Client::shutdown` method fingerprint ([Yuki Kishimoto])
+* sdk: deprecate `Client::add_relay_with_opts` and `Client::add_relays` ([Yuki Kishimoto])
+* sdk: deprecate `RelayPool::send_msg` and `RelayPool::batch_msg` ([Yuki Kishimoto])
 * ffi(nostr): impl `Display` for `Coordinate` ([Yuki Kishimoto])
 * ffi(sdk): change `Connection::embedded_tor` fingerprint for `android` and `ios` targets ([Yuki Kishimoto])
 
@@ -82,11 +86,21 @@
 * nostr: add `Timestamp::from_secs` ([Yuki Kishimoto])
 * nostr: add `EventId::from_byte_array` ([Yuki Kishimoto])
 * nostr: add `Timestamp::min` and `Timestamp::max` ([Yuki Kishimoto])
+* nostr: add `nip65::extract_owned_relay_list` ([Yuki Kishimoto])
 * database: add `DatabaseHelper::fast_query` ([Yuki Kishimoto])
 * database: add `NostrDatabase::check_id` ([Yuki Kishimoto])
+* database: add `NostrDatabaseExt::relay_lists` ([Yuki Kishimoto])
 * lmdb: add LMDB storage backend ([Yuki Kishimoto])
 * relay-builder: add `MockRelay` ([Yuki Kishimoto])
 * pool: add `RelayPool::disconnect_relay` method ([Yuki Kishimoto])
+* pool: add `RelayPool::relays_with_flag` and `RelayPool::all_relays` ([Yuki Kishimoto])
+* sdk: add `Client::add_discovery_relay` ([Yuki Kishimoto])
+* sdk: add `Client::add_read_relay` and `Client::add_write_relay` ([Yuki Kishimoto])
+* sdk: add `Client::stream_events_targeted` ([Yuki Kishimoto])
+* sdk: add `Client::subscribe_targeted` ([Yuki Kishimoto])
+* sdk: add gossip support to `Client::send_event` ([Yuki Kishimoto])
+* sdk: add gossip support to `Client::get_events_of` and `Client::stream_events_of` ([Yuki Kishimoto])
+* sdk: add gossip support to `Client::subscribe` and `Client::subscribe_with_id` ([Yuki Kishimoto])
 * bindings(nostr): expose `as_pretty_json` for some structs ([Yuki Kishimoto])
 * bindings(sdk): expose `Client::fetch_metadata` ([Yuki Kishimoto])
 * bindings(sdk): expose `Client::pool` method ([Yuki Kishimoto])
@@ -95,6 +109,7 @@
 * js(nostr): add `Kind` object ([Yuki Kishimoto])
 * js(nostr): expose `getNip05Profile` function ([Yuki Kishimoto])
 * js(nostr): expose missing methods to `JsCoordinate` ([Yuki Kishimoto])
+* js(sdk): expose `RelayPool::relays` ([Yuki Kishimoto])
 * book: add some python examples ([RydalWater])
 
 ### Fixed

bindings/nostr-ffi/src/nips/nip65.rs

@@ -39,6 +39,6 @@ impl From<nip65::RelayMetadata> for RelayMetadata {
 #[uniffi::export]
 pub fn extract_relay_list(event: &Event) -> HashMap<String, Option<RelayMetadata>> {
     nip65::extract_relay_list(event.deref())
-        .map(|(s, r)| (s.to_string(), r.clone().map(|r| r.into())))
+        .map(|(s, r)| (s.to_string(), r.map(|r| r.into())))
         .collect()
 }

bindings/nostr-js/src/nips/nip65.rs

@@ -29,7 +29,7 @@ pub fn extract_relay_list(event: &JsEvent) -> Vec<JsRelayListItem> {
     nip65::extract_relay_list(event.deref())
         .map(|(s, r)| JsRelayListItem {
             url: s.to_string(),
-            metadata: r.clone().map(|r| r.into()),
+            metadata: r.map(|r| r.into()),
         })
         .collect()
 }

bindings/nostr-sdk-ffi/bindings-python/README.md

@@ -42,7 +42,8 @@ async def main():
     client = Client(signer)
 
     # Add relays and connect
-    await client.add_relays(["wss://relay.damus.io", "wss://nos.lol"])
+    await client.add_relay("wss://relay.damus.io")
+    await client.add_relay("wss://nos.lol")
     await client.connect()
 
     # Send an event using the Nostr Signer
@@ -96,4 +97,4 @@ Learn more about `rust-nostr` at <https://rust-nostr.org>.
 
 ## License
 
-This project is distributed under the MIT software license - see the [LICENSE](https://github.com/rust-nostr/nostr/blob/master/LICENSE) file for details
+This project is distributed under the MIT software license - see the [LICENSE](https://github.com/rust-nostr/nostr/blob/master/LICENSE) file for details

bindings/nostr-sdk-ffi/bindings-python/examples/blacklist.py

@@ -9,7 +9,8 @@ async def main():
 
     # Init client
     client = Client()
-    await client.add_relays(["wss://relay.damus.io", "wss://nos.lol"])
+    await client.add_relay("wss://relay.damus.io")
+    await client.add_relay("wss://nos.lol")
     await client.connect()
 
     muted_public_key = PublicKey.parse("npub1l2vyh47mk2p0qlsku7hg0vn29faehy9hy34ygaclpn66ukqp3afqutajft")

bindings/nostr-sdk-ffi/bindings-python/examples/client-with-opts.py

@@ -17,10 +17,8 @@ async def main():
             .proxy(proxy))
     client = Client.with_opts(None, opts)
 
-    await client.add_relays([
-        "wss://relay.damus.io",
-        "ws://oxtrdevav64z64yb7x6rjg4ntzqjhedm5b5zjqulugknhzr46ny2qbad.onion"
-    ])
+    await client.add_relay("wss://relay.damus.io")
+    await client.add_relay("ws://oxtrdevav64z64yb7x6rjg4ntzqjhedm5b5zjqulugknhzr46ny2qbad.onion")
     await client.connect()
 
     event = EventBuilder.text_note("Hello from Rust Nostr Python bindings!", []).to_event(keys)

bindings/nostr-sdk-ffi/bindings-python/examples/client.py

@@ -23,7 +23,8 @@ async def main():
     client = Client(signer)
 
     # Add relays and connect
-    await client.add_relays(["wss://relay.damus.io", "wss://nos.lol", "wss://nostr.wine"])
+    await client.add_relay("wss://relay.damus.io")
+    await client.add_relay("wss://nos.lol")
     await client.connect()
 
     # Send an event using the Nostr Signer

bindings/nostr-sdk-ffi/bindings-python/examples/tor.py

@@ -16,11 +16,9 @@ async def main():
     opts = Options().connection(connection).connection_timeout(timedelta(seconds=60))
     client = Client.with_opts(signer, opts)
 
-    await client.add_relays([
-        "wss://relay.damus.io",
-        "ws://oxtrdevav64z64yb7x6rjg4ntzqjhedm5b5zjqulugknhzr46ny2qbad.onion",
-        "ws://2jsnlhfnelig5acq6iacydmzdbdmg7xwunm4xl6qwbvzacw4lwrjmlyd.onion",
-    ])
+    await client.add_relay("wss://relay.damus.io")
+    await client.add_relay("ws://oxtrdevav64z64yb7x6rjg4ntzqjhedm5b5zjqulugknhzr46ny2qbad.onion")
+    await client.add_relay("ws://2jsnlhfnelig5acq6iacydmzdbdmg7xwunm4xl6qwbvzacw4lwrjmlyd.onion")
     await client.connect()
 
     event = EventBuilder.text_note("Hello from rust-nostr Python bindings!", [])