Struct GroupManager 

pub struct GroupManager { /* private fields */ }

Implementations

impl GroupManager

pub fn new(local_device_id: DeviceId, router: Arc<Router>) -> Self

pub fn register_device_key( &self, device_id: DeviceId, public_key: PublicKey, ) -> Result<()>

注册设备公钥到 TreeKEM 引擎

pub async fn create_group( &self, name: String, initial_members: Vec<DeviceId>, ) -> Result<Group>

pub async fn add_member( &self, group_id: GroupId, device_id: DeviceId, ) -> Result<()>

pub async fn join_group(&self, group: Group) -> Result<()>

pub async fn leave_group(&self, group_id: GroupId) -> Result<()>

pub async fn get_group(&self, group_id: GroupId) -> Option<Group>

pub fn clear_groups(&self)

清理所有群组信息，防止内存泄漏 - use proper entry removal to avoid DashMap fragmentation

pub async fn broadcast( &self, group_id: GroupId, payload: MessagePayload, ) -> Result<Uuid>

pub async fn mark_device_success(&self, msg_id: Uuid, device_id: DeviceId)

标记设备为成功接收（收到ACK）

pub async fn mark_device_failed(&self, msg_id: Uuid, device_id: DeviceId)

标记设备为失败（无法送达或超时）

pub async fn get_ack_status( &self, msg_id: Uuid, ) -> Option<(usize, usize, usize)>

获取消息ACK状态

pub async fn rotate_group_key(&self, group_id: GroupId) -> Result<()>

执行群组密钥更新（前向保密性）

pub fn encrypt_group_message( &self, group_id: GroupId, payload: &MessagePayload, ) -> Result<MessagePayload>

pub fn decrypt_group_message( &self, group_id: GroupId, encrypted_payload: &MessagePayload, ) -> Result<MessagePayload>

pub async fn handle_key_update( &self, group_id: GroupId, epoch: u64, _update_path: Vec<u8>, ) -> Result<()>

处理群组密钥更新

pub async fn handle_ack(&self, original_msg_id: Uuid, responder: DeviceId)

处理ACK消息

pub async fn cleanup_expired_broadcast_results(&self)

清理过期的广播结果通道，防止内存泄漏

pub fn cleanup_expired_invites(&self, max_age_hours: u64)

清理过期的邀请记录，防止内存泄漏

pub async fn update_member_state( &self, group_id: GroupId, device_id: DeviceId, status: MemberStatus, ) -> Result<()>

更新群组成员状态

pub async fn notify_group_state_change(&self, group_id: GroupId)

通知群组状态变更

pub async fn broadcast_large_group( &self, group_id: GroupId, payload: MessagePayload, ) -> Result<Vec<Uuid>>

大规模群组性能优化 - 分层广播

pub async fn handle_incoming_group_message( &self, message: &Message, ) -> Result<()>