feat(backend/lsp): Send lsp request to client

Author: Brayan-724

backend/src/project/project_lsp.rs

@@ -315,6 +315,17 @@ impl StreamHandler<Stdout> for ProjectLsp {
             }
             LspOutput::Request(req) => {
                 local_log::request::trace!(target: self.project_id, "{req:?}");
+                match serde_json::to_value(req) {
+                    Ok(data) => {
+                        _ = self.broadcast.send(InternalMessage::Lsp {
+                            client_id: None,
+                            data,
+                        });
+                    }
+                    Err(err) => {
+                        local_log::request::error!(target: self.project_id, "Cannot serialize {err:?}");
+                    }
+                }
             }
             LspOutput::Notify(noti) => {
                 local_log::notify::trace!(target: self.project_id, "{noti:?}");

backend/src/project/routes.rs

@@ -85,8 +85,6 @@ pub async fn create_project(
 
     project.permit_access(user_info.id.clone(), AccessLevel::Editor);
 
-    project.start_lsp().await;
-
     Ok(HttpResponse::Created().json(json!({
         "id": project.id
     })))

backend/src/utils/mod.rs

@@ -9,7 +9,7 @@ pub use async_default::AsyncDefault;
 pub use async_from::AsyncInto;
 pub use expect_var::expect_var;
 pub(crate) use logger::define_local_logger;
-pub use printers::{Truncate, Truncated};
+pub use printers::Truncate;
 pub use to_stream::ToStream;
 
 use std::sync::{Arc, LazyLock};

backend/src/ws/messages.rs

@@ -9,7 +9,7 @@ use uuid::Uuid;
 
 use crate::collab::{Document, DocumentInfo, UserOperation};
 use crate::project::AccessLevel;
-use crate::utils::{ArcStr, Truncate, Truncated};
+use crate::utils::{ArcStr, Truncate};
 
 #[derive(Serialize, Deserialize)]
 #[serde(tag = "action", rename_all = "snake_case")]

backend/src/ws/websocket.rs

@@ -40,10 +40,16 @@ impl RgWebsocket {
             };
             let mut project = project.write().await;
 
+            let access = project.join_project(user_info.id.clone(), password)?;
+
+            if access.can_read() {
+                project.start_lsp().await;
+            }
+
             (
                 project.internal.subscribe(),
                 project.broadcast.subscribe(),
-                project.join_project(user_info.id.clone(), password)?,
+                access,
             )
         };