Add collab host handlers

Author: SomeoneToIgnore

crates/language_tools/src/lsp_log.rs

@@ -442,6 +442,14 @@ impl LogStore {
                                     }
                                 }
                             }
+                            project::Event::ToggleLspLogs { server_id, enabled } => {
+                                // we do not support any other log toggling yet
+                                if *enabled {
+                                    log_store.enable_rpc_trace_for_language_server(*server_id);
+                                } else {
+                                    log_store.disable_rpc_trace_for_language_server(*server_id);
+                                }
+                            }
                             _ => {}
                         }
                     }),

crates/project/src/project.rs

@@ -282,6 +282,10 @@ pub enum Event {
         buffer_abs_path: PathBuf,
         name: Option<LanguageServerName>,
     },
+    ToggleLspLogs {
+        server_id: LanguageServerId,
+        enabled: bool,
+    },
     Toast {
         notification_id: SharedString,
         message: String,
@@ -1002,6 +1006,7 @@ impl Project {
         client.add_entity_request_handler(Self::handle_open_buffer_by_path);
         client.add_entity_request_handler(Self::handle_open_new_buffer);
         client.add_entity_message_handler(Self::handle_create_buffer_for_peer);
+        client.add_entity_message_handler(Self::handle_toggle_lsp_logs);
 
         WorktreeStore::init(&client);
         BufferStore::init(&client);
@@ -4699,6 +4704,20 @@ impl Project {
         })?
     }
 
+    async fn handle_toggle_lsp_logs(
+        project: Entity<Self>,
+        envelope: TypedEnvelope<proto::ToggleLspLogs>,
+        mut cx: AsyncApp,
+    ) -> Result<()> {
+        project.update(&mut cx, |_, cx| {
+            cx.emit(Event::ToggleLspLogs {
+                server_id: LanguageServerId::from_proto(envelope.payload.server_id),
+                enabled: envelope.payload.enabled,
+            })
+        })?;
+        Ok(())
+    }
+
     async fn handle_synchronize_buffers(
         this: Entity<Self>,
         envelope: TypedEnvelope<proto::SynchronizeBuffers>,