Struct RelayPool 

pub struct RelayPool { /* private fields */ }

Relay pool wrapper for managing Nostr relay connections.

Implementations

impl RelayPool

pub async fn new<T>(signer: T) -> Result<Self>

where T: IntoNostrSigner,

Create a new relay pool with the given signer.

pub async fn connect(&self, relay_urls: &[String]) -> Result<()>

Connect to the given relay URLs.

pub async fn disconnect(&self) -> Result<()>

Disconnect from all relays.

pub async fn publish_event(&self, event: &Event) -> Result<EventId>

Publish a pre-built event to relays.

pub async fn publish(&self, builder: EventBuilder) -> Result<EventId>

Build, sign, and publish an event from a builder.

pub async fn sign(&self, builder: EventBuilder) -> Result<Event>

Sign an event builder without publishing.

pub fn client(&self) -> &Arc<Client>

Get the underlying nostr-sdk Client.

pub fn notifications(&self) -> Receiver<RelayPoolNotification>

Get notifications receiver for event streaming.

pub async fn public_key(&self) -> Result<PublicKey>

Get the public key of the signer.

pub async fn subscribe(&self, filters: Vec<Filter>) -> Result<()>

Subscribe to events matching filters.

Trait Implementations

impl RelayPoolTrait for RelayPool

fn connect<'life0, 'life1, 'async_trait>( &'life0 self, relay_urls: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Connect to the given relay URLs.

fn disconnect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Disconnect from all relays.

fn publish_event<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 Event, ) -> Pin<Box<dyn Future<Output = Result<EventId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Publish a pre-built event to relays.

fn publish<'life0, 'async_trait>( &'life0 self, builder: EventBuilder, ) -> Pin<Box<dyn Future<Output = Result<EventId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Build, sign, and publish an event from a builder.

fn sign<'life0, 'async_trait>( &'life0 self, builder: EventBuilder, ) -> Pin<Box<dyn Future<Output = Result<Event>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sign an event builder without publishing.

fn signer<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn NostrSigner>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the signer associated with this relay pool.

fn notifications(&self) -> Receiver<RelayPoolNotification>

Get notifications receiver for event streaming.

fn public_key<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<PublicKey>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the public key of the signer.

fn subscribe<'life0, 'async_trait>( &'life0 self, filters: Vec<Filter>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Subscribe to events matching filters.