hashtree-network 0.2.51

Mesh networking stack for hashtree: routing, signaling, peer links, and stores
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

use anyhow::Result;
use async_trait::async_trait;
use nostr_sdk::nostr::{ClientMessage, Event, Filter, SubscriptionId};
use std::sync::Arc;
use tokio::sync::mpsc;

#[async_trait]
pub trait MeshEventStore: Send + Sync {
    async fn ingest_trusted_event(&self, event: Event) -> Result<()>;

    async fn query_events(&self, filter: &Filter, limit: usize) -> Vec<Event>;
}

pub type SharedMeshEventStore = Arc<dyn MeshEventStore>;

#[async_trait]
pub trait MeshRelayClient: MeshEventStore {
    fn next_client_id(&self) -> u64;

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

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

    async fn handle_client_message(&self, client_id: u64, msg: ClientMessage);

    async fn register_subscription_query(
        &self,
        client_id: u64,
        subscription_id: SubscriptionId,
        filters: Vec<Filter>,
    ) -> std::result::Result<Vec<Event>, &'static str>;

    async fn ingest_trusted_event_from_peer(
        &self,
        event: Event,
        _peer_id: Option<String>,
    ) -> Result<()> {
        self.ingest_trusted_event(event).await
    }
}

pub type SharedMeshRelayClient = Arc<dyn MeshRelayClient>;