|
@@ -26,27 +26,28 @@ pub struct ClientTextBlockEditor {
|
|
|
#[allow(dead_code)]
|
|
|
rev_manager: Arc<RevisionManager>,
|
|
|
#[cfg(feature = "sync")]
|
|
|
- ws_manager: Arc<RevisionWebSocketManager>,
|
|
|
+ ws_manager: Arc<flowy_revision::RevisionWebSocketManager>,
|
|
|
edit_cmd_tx: EditorCommandSender,
|
|
|
}
|
|
|
|
|
|
impl ClientTextBlockEditor {
|
|
|
+ #[allow(unused_variables)]
|
|
|
pub(crate) async fn new(
|
|
|
doc_id: &str,
|
|
|
user: Arc<dyn TextBlockUser>,
|
|
|
mut rev_manager: RevisionManager,
|
|
|
- _rev_web_socket: Arc<dyn RevisionWebSocket>,
|
|
|
+ rev_web_socket: Arc<dyn RevisionWebSocket>,
|
|
|
cloud_service: Arc<dyn RevisionCloudService>,
|
|
|
) -> FlowyResult<Arc<Self>> {
|
|
|
let document_info = rev_manager.load::<TextBlockInfoBuilder>(Some(cloud_service)).await?;
|
|
|
let delta = document_info.delta()?;
|
|
|
let rev_manager = Arc::new(rev_manager);
|
|
|
let doc_id = doc_id.to_string();
|
|
|
- let _user_id = user.user_id()?;
|
|
|
+ let user_id = user.user_id()?;
|
|
|
|
|
|
let edit_cmd_tx = spawn_edit_queue(user, rev_manager.clone(), delta);
|
|
|
#[cfg(feature = "sync")]
|
|
|
- let ws_manager = make_block_ws_manager(
|
|
|
+ let ws_manager = crate::web_socket::make_block_ws_manager(
|
|
|
doc_id.clone(),
|
|
|
user_id.clone(),
|
|
|
edit_cmd_tx.clone(),
|