Struct SyncService

pub struct SyncService { /* private fields */ }

Implementations

impl SyncService

pub fn new( yrs_manager: Arc<YrsManager>, ws_server: Arc<WebSocketServer>, ) -> Self

pub fn init_room_from_tree(&self, room_id: &str, _tree: &Tree) -> Result<()>

将 ModuForge 的 Tree 初始化为房间快照

pub fn get_room_snapshot(&self, room_id: &str, tree: &Tree) -> RoomSnapshot

获取房间的完整快照（用于前端首次加载）

pub async fn handle_transaction_applied( &self, room_id: &str, transactions: &[Transaction], _new_state: &State, client_id: Option<String>, ) -> Result<()>

🚀 内部方法：处理事务变更并以二进制格式批量推送到前端

pub fn remove_room(&self, room_id: &str)

移除房间

pub fn get_status(&self) -> SyncServiceStatus

获取服务状态

pub fn yrs_manager(&self) -> &Arc<YrsManager>

获取 YrsManager 的引用（用于高级操作）

pub fn ws_server(&self) -> &Arc<WebSocketServer>

获取 WebSocketServer 的引用（用于高级操作）

pub fn broadcast_message_to_room( &self, room_id: &str, message: String, ) -> Result<()>

🚀 主动推送消息到房间的所有客户端

pub fn broadcast_data_to_room(&self, room_id: &str, data: Vec<u8>) -> Result<()>

🚀 主动推送二进制数据到房间的所有客户端

pub fn send_message_to_client( &self, client_id: &str, message: String, ) -> Result<()>

🚀 主动推送消息到特定客户端

pub fn send_data_to_client(&self, client_id: &str, data: Vec<u8>) -> Result<()>

🚀 主动推送二进制数据到特定客户端

pub fn notify_room_change( &self, room_id: &str, change_description: String, ) -> Result<()>

🚀 主动推送 ModuForge 变更通知到房间

pub async fn handle_sync_request( &self, room_id: &str, tree: &Tree, client_state_vector: &[u8], ) -> Result<Vec<u8>>

🚀 为新加入的客户端处理同步请求

1. 从权威State生成一个临时的Doc快照
2. 将当前房间的增量更新应用到快照上
3. 根据客户端的状态向量计算并返回最终的diff

pub fn broadcast_json_sync_to_room( &self, room_id: &str, operation: &str, data: Value, ) -> Result<()>

🚀 主动推送 JSON 格式的状态同步消息到房间

Trait Implementations

impl Clone for SyncService

fn clone(&self) -> SyncService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncService

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

Formats the value using the given formatter.

impl Default for SyncService

fn default() -> Self

Returns the “default value” for a type.