de-mls 3.0.0

Decentralized MLS — end-to-end encrypted group messaging with consensus-based membership management over gossipsub-like networks
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
48
49
50
51
52
53
54
55
56
57
58

//! [`ConsensusContext`] — User-level consensus-plugin state.
//!
//! Holds the shared storage handle + signer once on the User; mints fresh
//! per-conversation [`PluginConsensus`] services on demand and tears down a
//! conversation's scope on leave. Each per-conv service gets its own
//! private event bus (per upstream "service shape" recommendation).

use hashgraph_like_consensus::storage::ConsensusStorage;

use crate::core::{ConsensusPlugin, PluginConsensus};

pub struct ConsensusContext<P: ConsensusPlugin> {
    storage: P::ConsensusStorage,
    signer: P::Signer,
}

impl<P: ConsensusPlugin> ConsensusContext<P> {
    /// Build a fresh context. `P::new_storage` creates the shared backing
    /// once; `signer` is supplied by the integrator (typically wraps the
    /// user's wallet / account key).
    pub fn new(signer: P::Signer) -> Self {
        Self {
            storage: P::new_storage(),
            signer,
        }
    }

    /// Build a fresh per-conversation `ConsensusService`. Clones the shared
    /// storage handle so all per-conv services share one underlying
    /// persistence (scope-keyed); clones the signer; mints a fresh private
    /// event bus.
    pub fn build_service(&self) -> PluginConsensus<P> {
        PluginConsensus::<P>::new_with_components(
            self.storage.clone(),
            P::new_event_bus(),
            self.signer.clone(),
            10,
        )
    }

    /// Drop a conversation's scope from the shared consensus storage.
    /// Called on conversation leave.
    pub async fn delete_scope(
        &self,
        scope: &P::Scope,
    ) -> Result<(), hashgraph_like_consensus::error::ConsensusError> {
        self.storage.delete_scope(scope).await
    }
}

impl<P: ConsensusPlugin> Clone for ConsensusContext<P> {
    fn clone(&self) -> Self {
        Self {
            storage: self.storage.clone(),
            signer: self.signer.clone(),
        }
    }
}