Struct GroupManager 

pub struct GroupManager {
    pub(crate) groups: Arc<RwLock<HashMap<MessageId, GroupSession>>>,
    broadcast_channel: Arc<Sender<GroupDataUpdate>>,
    _broadcast_keeper: Arc<InactiveReceiver<GroupDataUpdate>>,
}

Digital Group Assistant - manages encrypted groups using the wire protocol

Fields

groups: Arc<RwLock<HashMap<MessageId, GroupSession>>>

All group states managed by this DGA instance Key is the Blake3 hash of the CreateGroup message (which serves as both group ID and root event ID)

broadcast_channel: Arc<Sender<GroupDataUpdate>>

_broadcast_keeper: Arc<InactiveReceiver<GroupDataUpdate>>

Keeper receiver to prevent broadcast channel closure (not actively used) Arc-wrapped to ensure channel stays open even when GroupManager instances are cloned and dropped

Implementations

impl GroupManager

pub fn generate_group_key(timestamp: u64) -> EncryptionKey

Generate a new encryption key for a group (ChaCha20-Poly1305)

pub async fn group_state(&self, group_id: &MessageId) -> Option<GroupState>

Get a group’s current state

pub async fn group_session(&self, group_id: &MessageId) -> Option<GroupSession>

Get a group session (state + encryption)

pub async fn all_group_sessions(&self) -> HashMap<MessageId, GroupSession>

Get all managed group sessions

pub async fn all_groups(&self) -> HashMap<MessageId, GroupState>

Get all managed groups (state only, for backward compatibility)

pub async fn is_member(&self, group_id: &MessageId, user: &VerifyingKey) -> bool

Check if a user is a member of a specific group

pub async fn member_role( &self, group_id: &MessageId, user: &VerifyingKey, ) -> Option<GroupRole>

Get a user’s role in a specific group

impl GroupManager

pub fn builder() -> GroupManagerBuilder

Create a new DGA instance builder

pub fn create_key_from_mnemonic( mnemonic: &MnemonicPhrase, passphrase: &str, group_name: &str, timestamp: u64, ) -> GroupResult<EncryptionKey>

Create a group key from a mnemonic phrase

pub fn recover_key_from_mnemonic( mnemonic: &MnemonicPhrase, passphrase: &str, group_name: &str, salt: &[u8; 32], timestamp: u64, ) -> GroupResult<EncryptionKey>

Recover a group key from a mnemonic phrase with specific salt

pub async fn create_group( &self, create_group: CreateGroup, encryption_key: Option<EncryptionKey>, creator: &KeyPair, timestamp: u64, ) -> GroupResult<CreateGroupResult>

Create a new encrypted group, returning the root event message to be sent

pub async fn create_group_event_message<T>( &self, group_id: MessageId, event: GroupActivityEvent<T>, sender: &KeyPair, timestamp: u64, ) -> GroupResult<MessageFull>

where T: Serialize,

Create an encrypted message for a group activity event The group_id parameter should be the Blake3 hash of the CreateGroup message

pub async fn process_group_event( &self, message_full: &MessageFull, ) -> GroupResult<()>

Process an incoming group event message

async fn find_group_by_event_tag(&self, tags: &[Tag]) -> GroupResult<MessageId>

Find a group by looking for Event tags in the message

pub async fn user_groups(&self, user: &VerifyingKey) -> Vec<GroupState>

List all groups a user is a member of

pub async fn add_group_session( &self, group_id: MessageId, session: GroupSession, )

Add a complete group session

pub async fn remove_group_session( &self, group_id: &MessageId, ) -> Option<GroupSession>

Remove a group session

pub async fn rotate_group_key( &self, group_id: &MessageId, new_key: EncryptionKey, ) -> GroupResult<()>

Update a group session’s encryption key (for key rotation)

pub fn subscribe_to_updates(&self) -> Receiver<GroupDataUpdate>

Subscribe to group updates

pub async fn create_group_subscription_filter( &self, group_id: &MessageId, ) -> GroupResult<Tag>

Create a subscription filter for a specific group This returns the Event tag that should be used to subscribe to group events

Trait Implementations

impl Clone for GroupManager

fn clone(&self) -> GroupManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for GroupManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for GroupManager

fn default() -> Self

Returns the “default value” for a type.