Struct NostrRelay 

pub struct NostrRelay { /* private fields */ }

Implementations

impl NostrRelay

pub fn new( trusted_store: Arc<dyn SocialGraphBackend>, data_dir: PathBuf, public_pubkeys: HashSet<String>, social_graph: Option<Arc<SocialGraphAccessControl>>, config: NostrRelayConfig, ) -> Result<Self>

pub fn next_client_id(&self) -> u64

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

pub async fn ingest_trusted_event_from_bluetooth( &self, event: Event, peer_id: Option<String>, ) -> Result<()>

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

pub async fn bluetooth_received_events( &self, limit: usize, ) -> Vec<BluetoothReceivedEventRecord>

pub async fn query_events( &self, filter: &NostrFilter, limit: usize, ) -> Vec<Event>

pub async fn register_client( &self, client_id: u64, sender: UnboundedSender<String>, pubkey: Option<String>, )

pub async fn unregister_client(&self, client_id: u64)

pub async fn handle_client_message( &self, client_id: u64, msg: NostrClientMessage, )

pub async fn register_subscription_query( &self, client_id: u64, subscription_id: SubscriptionId, filters: Vec<NostrFilter>, ) -> Result<Vec<Event>, &'static str>

Trait Implementations

impl MeshEventStore for NostrRelay

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

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

fn query_events<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 NostrFilter, limit: usize, ) -> Pin<Box<dyn Future<Output = Vec<Event>> + Send + 'async_trait>>

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

impl MeshRelayClient for NostrRelay

fn next_client_id(&self) -> u64

fn register_client<'life0, 'async_trait>( &'life0 self, client_id: u64, sender: UnboundedSender<String>, pubkey: Option<String>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

fn unregister_client<'life0, 'async_trait>( &'life0 self, client_id: u64, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

fn handle_client_message<'life0, 'async_trait>( &'life0 self, client_id: u64, msg: NostrClientMessage, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

fn register_subscription_query<'life0, 'async_trait>( &'life0 self, client_id: u64, subscription_id: SubscriptionId, filters: Vec<NostrFilter>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, &'static str>> + Send + 'async_trait>>

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

fn ingest_trusted_event_from_peer<'life0, 'async_trait>( &'life0 self, event: Event, peer_id: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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