Kirill Bulatov
01266d10d6
Follow-up https://github.com/zed-industries/zed/pull/37083 Noisy RPC LSP logs were functioning this way already, but to keep Collab loaded even less, do not send any kind of logs to the client if the client has a corresponding log tab not opened. This change is pretty raw and does not fully cover scenarious with multiple clients: if one client has a log tab open and another opens tab with another kind of log, the 2nd kind of logs will be streamed only. Also, it should be possible to forward the host logs to the client on enabling — that is not done to keep the change smaller. Release Notes: - N/A
1332 lines
53 KiB
Rust
1332 lines
53 KiB
Rust
use collections::VecDeque;
|
|
use copilot::Copilot;
|
|
use editor::{Editor, EditorEvent, actions::MoveToEnd, scroll::Autoscroll};
|
|
use gpui::{
|
|
AnyView, App, Context, Corner, Entity, EventEmitter, FocusHandle, Focusable, IntoElement,
|
|
ParentElement, Render, Styled, Subscription, WeakEntity, Window, actions, div,
|
|
};
|
|
use itertools::Itertools;
|
|
use language::{LanguageServerId, language_settings::SoftWrap};
|
|
use lsp::{
|
|
LanguageServer, LanguageServerBinary, LanguageServerName, LanguageServerSelector, MessageType,
|
|
SetTraceParams, TraceValue, notification::SetTrace,
|
|
};
|
|
use project::{
|
|
Project,
|
|
lsp_store::log_store::{self, Event, LanguageServerKind, LogKind, LogStore, Message},
|
|
search::SearchQuery,
|
|
};
|
|
use proto::toggle_lsp_logs::LogType;
|
|
use std::{any::TypeId, borrow::Cow, sync::Arc};
|
|
use ui::{Button, Checkbox, ContextMenu, Label, PopoverMenu, ToggleState, prelude::*};
|
|
use util::ResultExt as _;
|
|
use workspace::{
|
|
SplitDirection, ToolbarItemEvent, ToolbarItemLocation, ToolbarItemView, Workspace, WorkspaceId,
|
|
item::{Item, ItemHandle},
|
|
searchable::{Direction, SearchEvent, SearchableItem, SearchableItemHandle},
|
|
};
|
|
|
|
use crate::get_or_create_tool;
|
|
|
|
pub fn open_server_trace(
|
|
log_store: &Entity<LogStore>,
|
|
workspace: WeakEntity<Workspace>,
|
|
server: LanguageServerSelector,
|
|
window: &mut Window,
|
|
cx: &mut App,
|
|
) {
|
|
log_store.update(cx, |_, cx| {
|
|
cx.spawn_in(window, async move |log_store, cx| {
|
|
let Some(log_store) = log_store.upgrade() else {
|
|
return;
|
|
};
|
|
workspace
|
|
.update_in(cx, |workspace, window, cx| {
|
|
let project = workspace.project().clone();
|
|
let tool_log_store = log_store.clone();
|
|
let log_view = get_or_create_tool(
|
|
workspace,
|
|
SplitDirection::Right,
|
|
window,
|
|
cx,
|
|
move |window, cx| LspLogView::new(project, tool_log_store, window, cx),
|
|
);
|
|
log_view.update(cx, |log_view, cx| {
|
|
let server_id = match server {
|
|
LanguageServerSelector::Id(id) => Some(id),
|
|
LanguageServerSelector::Name(name) => {
|
|
log_store.read(cx).language_servers.iter().find_map(
|
|
|(id, state)| {
|
|
if state.name.as_ref() == Some(&name) {
|
|
Some(*id)
|
|
} else {
|
|
None
|
|
}
|
|
},
|
|
)
|
|
}
|
|
};
|
|
if let Some(server_id) = server_id {
|
|
log_view.show_rpc_trace_for_server(server_id, window, cx);
|
|
}
|
|
});
|
|
})
|
|
.ok();
|
|
})
|
|
.detach();
|
|
})
|
|
}
|
|
|
|
pub struct LspLogView {
|
|
pub(crate) editor: Entity<Editor>,
|
|
editor_subscriptions: Vec<Subscription>,
|
|
log_store: Entity<LogStore>,
|
|
current_server_id: Option<LanguageServerId>,
|
|
active_entry_kind: LogKind,
|
|
project: Entity<Project>,
|
|
focus_handle: FocusHandle,
|
|
_log_store_subscriptions: Vec<Subscription>,
|
|
}
|
|
|
|
pub struct LspLogToolbarItemView {
|
|
log_view: Option<Entity<LspLogView>>,
|
|
_log_view_subscription: Option<Subscription>,
|
|
}
|
|
|
|
#[derive(Clone, Debug, PartialEq)]
|
|
pub(crate) struct LogMenuItem {
|
|
pub server_id: LanguageServerId,
|
|
pub server_name: LanguageServerName,
|
|
pub worktree_root_name: String,
|
|
pub rpc_trace_enabled: bool,
|
|
pub selected_entry: LogKind,
|
|
pub trace_level: lsp::TraceValue,
|
|
pub server_kind: LanguageServerKind,
|
|
}
|
|
|
|
actions!(
|
|
dev,
|
|
[
|
|
/// Opens the language server protocol logs viewer.
|
|
OpenLanguageServerLogs
|
|
]
|
|
);
|
|
|
|
pub fn init(on_headless_host: bool, cx: &mut App) {
|
|
let log_store = log_store::init(on_headless_host, cx);
|
|
|
|
log_store.update(cx, |_, cx| {
|
|
Copilot::global(cx).map(|copilot| {
|
|
let copilot = &copilot;
|
|
cx.subscribe(copilot, |log_store, copilot, edit_prediction_event, cx| {
|
|
if let copilot::Event::CopilotLanguageServerStarted = edit_prediction_event
|
|
&& let Some(server) = copilot.read(cx).language_server()
|
|
{
|
|
let server_id = server.server_id();
|
|
let weak_lsp_store = cx.weak_entity();
|
|
log_store.copilot_log_subscription =
|
|
Some(server.on_notification::<copilot::request::LogMessage, _>(
|
|
move |params, cx| {
|
|
weak_lsp_store
|
|
.update(cx, |lsp_store, cx| {
|
|
lsp_store.add_language_server_log(
|
|
server_id,
|
|
MessageType::LOG,
|
|
¶ms.message,
|
|
cx,
|
|
);
|
|
})
|
|
.ok();
|
|
},
|
|
));
|
|
|
|
let name = LanguageServerName::new_static("copilot");
|
|
log_store.add_language_server(
|
|
LanguageServerKind::Global,
|
|
server.server_id(),
|
|
Some(name),
|
|
None,
|
|
Some(server.clone()),
|
|
cx,
|
|
);
|
|
}
|
|
})
|
|
.detach();
|
|
})
|
|
});
|
|
|
|
cx.observe_new(move |workspace: &mut Workspace, _, cx| {
|
|
log_store.update(cx, |store, cx| {
|
|
store.add_project(workspace.project(), cx);
|
|
});
|
|
|
|
let log_store = log_store.clone();
|
|
workspace.register_action(move |workspace, _: &OpenLanguageServerLogs, window, cx| {
|
|
let log_store = log_store.clone();
|
|
let project = workspace.project().clone();
|
|
get_or_create_tool(
|
|
workspace,
|
|
SplitDirection::Right,
|
|
window,
|
|
cx,
|
|
move |window, cx| LspLogView::new(project, log_store, window, cx),
|
|
);
|
|
});
|
|
})
|
|
.detach();
|
|
}
|
|
|
|
impl LspLogView {
|
|
pub fn new(
|
|
project: Entity<Project>,
|
|
log_store: Entity<LogStore>,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) -> Self {
|
|
let server_id = log_store
|
|
.read(cx)
|
|
.language_servers
|
|
.iter()
|
|
.find(|(_, server)| server.kind.project() == Some(&project.downgrade()))
|
|
.map(|(id, _)| *id);
|
|
|
|
let weak_project = project.downgrade();
|
|
let model_changes_subscription =
|
|
cx.observe_in(&log_store, window, move |this, store, window, cx| {
|
|
let first_server_id_for_project =
|
|
store.read(cx).server_ids_for_project(&weak_project).next();
|
|
if let Some(current_lsp) = this.current_server_id {
|
|
if !store.read(cx).language_servers.contains_key(¤t_lsp)
|
|
&& let Some(server_id) = first_server_id_for_project
|
|
{
|
|
match this.active_entry_kind {
|
|
LogKind::Rpc => this.show_rpc_trace_for_server(server_id, window, cx),
|
|
LogKind::Trace => this.show_trace_for_server(server_id, window, cx),
|
|
LogKind::Logs => this.show_logs_for_server(server_id, window, cx),
|
|
LogKind::ServerInfo => this.show_server_info(server_id, window, cx),
|
|
}
|
|
}
|
|
} else if let Some(server_id) = first_server_id_for_project {
|
|
match this.active_entry_kind {
|
|
LogKind::Rpc => this.show_rpc_trace_for_server(server_id, window, cx),
|
|
LogKind::Trace => this.show_trace_for_server(server_id, window, cx),
|
|
LogKind::Logs => this.show_logs_for_server(server_id, window, cx),
|
|
LogKind::ServerInfo => this.show_server_info(server_id, window, cx),
|
|
}
|
|
}
|
|
|
|
cx.notify();
|
|
});
|
|
|
|
let events_subscriptions = cx.subscribe_in(
|
|
&log_store,
|
|
window,
|
|
move |log_view, _, e, window, cx| match e {
|
|
Event::NewServerLogEntry { id, kind, text } => {
|
|
if log_view.current_server_id == Some(*id)
|
|
&& LogKind::from_server_log_type(kind) == log_view.active_entry_kind
|
|
{
|
|
log_view.editor.update(cx, |editor, cx| {
|
|
editor.set_read_only(false);
|
|
let last_offset = editor.buffer().read(cx).len(cx);
|
|
let newest_cursor_is_at_end =
|
|
editor.selections.newest::<usize>(cx).start >= last_offset;
|
|
editor.edit(
|
|
vec![
|
|
(last_offset..last_offset, text.as_str()),
|
|
(last_offset..last_offset, "\n"),
|
|
],
|
|
cx,
|
|
);
|
|
if text.len() > 1024
|
|
&& let Some((fold_offset, _)) =
|
|
text.char_indices().dropping(1024).next()
|
|
&& fold_offset < text.len()
|
|
{
|
|
editor.fold_ranges(
|
|
vec![last_offset + fold_offset..last_offset + text.len()],
|
|
false,
|
|
window,
|
|
cx,
|
|
);
|
|
}
|
|
|
|
if newest_cursor_is_at_end {
|
|
editor.request_autoscroll(Autoscroll::bottom(), cx);
|
|
}
|
|
editor.set_read_only(true);
|
|
});
|
|
}
|
|
}
|
|
},
|
|
);
|
|
let (editor, editor_subscriptions) = Self::editor_for_logs(String::new(), window, cx);
|
|
|
|
let focus_handle = cx.focus_handle();
|
|
let focus_subscription = cx.on_focus(&focus_handle, window, |log_view, window, cx| {
|
|
window.focus(&log_view.editor.focus_handle(cx));
|
|
});
|
|
|
|
cx.on_release(|log_view, cx| {
|
|
log_view.log_store.update(cx, |log_store, cx| {
|
|
for (server_id, state) in &log_store.language_servers {
|
|
if let Some(log_kind) = state.toggled_log_kind {
|
|
if let Some(log_type) = log_type(log_kind) {
|
|
send_toggle_log_message(state, *server_id, false, log_type, cx);
|
|
}
|
|
}
|
|
}
|
|
});
|
|
})
|
|
.detach();
|
|
|
|
let mut lsp_log_view = Self {
|
|
focus_handle,
|
|
editor,
|
|
editor_subscriptions,
|
|
project,
|
|
log_store,
|
|
current_server_id: None,
|
|
active_entry_kind: LogKind::Logs,
|
|
_log_store_subscriptions: vec![
|
|
model_changes_subscription,
|
|
events_subscriptions,
|
|
focus_subscription,
|
|
],
|
|
};
|
|
if let Some(server_id) = server_id {
|
|
lsp_log_view.show_logs_for_server(server_id, window, cx);
|
|
}
|
|
lsp_log_view
|
|
}
|
|
|
|
fn editor_for_logs(
|
|
log_contents: String,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) -> (Entity<Editor>, Vec<Subscription>) {
|
|
let editor = initialize_new_editor(log_contents, true, window, cx);
|
|
let editor_subscription = cx.subscribe(
|
|
&editor,
|
|
|_, _, event: &EditorEvent, cx: &mut Context<LspLogView>| cx.emit(event.clone()),
|
|
);
|
|
let search_subscription = cx.subscribe(
|
|
&editor,
|
|
|_, _, event: &SearchEvent, cx: &mut Context<LspLogView>| cx.emit(event.clone()),
|
|
);
|
|
(editor, vec![editor_subscription, search_subscription])
|
|
}
|
|
|
|
fn editor_for_server_info(
|
|
info: ServerInfo,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) -> (Entity<Editor>, Vec<Subscription>) {
|
|
let server_info = format!(
|
|
"* Server: {NAME} (id {ID})
|
|
|
|
* Binary: {BINARY:#?}
|
|
|
|
* Registered workspace folders:
|
|
{WORKSPACE_FOLDERS}
|
|
|
|
* Capabilities: {CAPABILITIES}
|
|
|
|
* Configuration: {CONFIGURATION}",
|
|
NAME = info.name,
|
|
ID = info.id,
|
|
BINARY = info.binary.as_ref().map_or_else(
|
|
|| "Unknown".to_string(),
|
|
|bin| bin.path.as_path().to_string_lossy().to_string()
|
|
),
|
|
WORKSPACE_FOLDERS = info.workspace_folders.join(", "),
|
|
CAPABILITIES = serde_json::to_string_pretty(&info.capabilities)
|
|
.unwrap_or_else(|e| format!("Failed to serialize capabilities: {e}")),
|
|
CONFIGURATION = info
|
|
.configuration
|
|
.map(|configuration| serde_json::to_string_pretty(&configuration))
|
|
.transpose()
|
|
.unwrap_or_else(|e| Some(format!("Failed to serialize configuration: {e}")))
|
|
.unwrap_or_else(|| "Unknown".to_string()),
|
|
);
|
|
let editor = initialize_new_editor(server_info, false, window, cx);
|
|
let editor_subscription = cx.subscribe(
|
|
&editor,
|
|
|_, _, event: &EditorEvent, cx: &mut Context<LspLogView>| cx.emit(event.clone()),
|
|
);
|
|
let search_subscription = cx.subscribe(
|
|
&editor,
|
|
|_, _, event: &SearchEvent, cx: &mut Context<LspLogView>| cx.emit(event.clone()),
|
|
);
|
|
(editor, vec![editor_subscription, search_subscription])
|
|
}
|
|
|
|
pub(crate) fn menu_items<'a>(&'a self, cx: &'a App) -> Option<Vec<LogMenuItem>> {
|
|
let log_store = self.log_store.read(cx);
|
|
|
|
let unknown_server = LanguageServerName::new_static("unknown server");
|
|
|
|
let mut rows = log_store
|
|
.language_servers
|
|
.iter()
|
|
.map(|(server_id, state)| match &state.kind {
|
|
LanguageServerKind::Local { .. }
|
|
| LanguageServerKind::Remote { .. }
|
|
| LanguageServerKind::LocalSsh { .. } => {
|
|
let worktree_root_name = state
|
|
.worktree_id
|
|
.and_then(|id| self.project.read(cx).worktree_for_id(id, cx))
|
|
.map(|worktree| worktree.read(cx).root_name().to_string())
|
|
.unwrap_or_else(|| "Unknown worktree".to_string());
|
|
|
|
LogMenuItem {
|
|
server_id: *server_id,
|
|
server_name: state.name.clone().unwrap_or(unknown_server.clone()),
|
|
server_kind: state.kind.clone(),
|
|
worktree_root_name,
|
|
rpc_trace_enabled: state.rpc_state.is_some(),
|
|
selected_entry: self.active_entry_kind,
|
|
trace_level: lsp::TraceValue::Off,
|
|
}
|
|
}
|
|
|
|
LanguageServerKind::Global => LogMenuItem {
|
|
server_id: *server_id,
|
|
server_name: state.name.clone().unwrap_or(unknown_server.clone()),
|
|
server_kind: state.kind.clone(),
|
|
worktree_root_name: "supplementary".to_string(),
|
|
rpc_trace_enabled: state.rpc_state.is_some(),
|
|
selected_entry: self.active_entry_kind,
|
|
trace_level: lsp::TraceValue::Off,
|
|
},
|
|
})
|
|
.chain(
|
|
self.project
|
|
.read(cx)
|
|
.supplementary_language_servers(cx)
|
|
.filter_map(|(server_id, name)| {
|
|
let state = log_store.language_servers.get(&server_id)?;
|
|
Some(LogMenuItem {
|
|
server_id,
|
|
server_name: name,
|
|
server_kind: state.kind.clone(),
|
|
worktree_root_name: "supplementary".to_string(),
|
|
rpc_trace_enabled: state.rpc_state.is_some(),
|
|
selected_entry: self.active_entry_kind,
|
|
trace_level: lsp::TraceValue::Off,
|
|
})
|
|
}),
|
|
)
|
|
.collect::<Vec<_>>();
|
|
rows.sort_by_key(|row| row.server_id);
|
|
rows.dedup_by_key(|row| row.server_id);
|
|
Some(rows)
|
|
}
|
|
|
|
fn show_logs_for_server(
|
|
&mut self,
|
|
server_id: LanguageServerId,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
let typ = self
|
|
.log_store
|
|
.read(cx)
|
|
.language_servers
|
|
.get(&server_id)
|
|
.map(|v| v.log_level)
|
|
.unwrap_or(MessageType::LOG);
|
|
let log_contents = self
|
|
.log_store
|
|
.read(cx)
|
|
.server_logs(server_id)
|
|
.map(|v| log_contents(v, typ));
|
|
if let Some(log_contents) = log_contents {
|
|
self.current_server_id = Some(server_id);
|
|
self.active_entry_kind = LogKind::Logs;
|
|
let (editor, editor_subscriptions) = Self::editor_for_logs(log_contents, window, cx);
|
|
self.editor = editor;
|
|
self.editor_subscriptions = editor_subscriptions;
|
|
cx.notify();
|
|
}
|
|
self.editor.read(cx).focus_handle(cx).focus(window);
|
|
self.log_store.update(cx, |log_store, cx| {
|
|
let state = log_store.get_language_server_state(server_id)?;
|
|
state.toggled_log_kind = Some(LogKind::Logs);
|
|
send_toggle_log_message(state, server_id, true, LogType::Log, cx);
|
|
Some(())
|
|
});
|
|
}
|
|
|
|
fn update_log_level(
|
|
&self,
|
|
server_id: LanguageServerId,
|
|
level: MessageType,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
let log_contents = self.log_store.update(cx, |this, _| {
|
|
if let Some(state) = this.get_language_server_state(server_id) {
|
|
state.log_level = level;
|
|
}
|
|
|
|
this.server_logs(server_id).map(|v| log_contents(v, level))
|
|
});
|
|
|
|
if let Some(log_contents) = log_contents {
|
|
self.editor.update(cx, |editor, cx| {
|
|
editor.set_text(log_contents, window, cx);
|
|
editor.move_to_end(&MoveToEnd, window, cx);
|
|
});
|
|
cx.notify();
|
|
}
|
|
|
|
self.editor.read(cx).focus_handle(cx).focus(window);
|
|
}
|
|
|
|
fn show_trace_for_server(
|
|
&mut self,
|
|
server_id: LanguageServerId,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
let trace_level = self
|
|
.log_store
|
|
.update(cx, |log_store, _| {
|
|
Some(log_store.get_language_server_state(server_id)?.trace_level)
|
|
})
|
|
.unwrap_or(TraceValue::Messages);
|
|
let log_contents = self
|
|
.log_store
|
|
.read(cx)
|
|
.server_trace(server_id)
|
|
.map(|v| log_contents(v, trace_level));
|
|
if let Some(log_contents) = log_contents {
|
|
self.current_server_id = Some(server_id);
|
|
self.active_entry_kind = LogKind::Trace;
|
|
let (editor, editor_subscriptions) = Self::editor_for_logs(log_contents, window, cx);
|
|
self.editor = editor;
|
|
self.editor_subscriptions = editor_subscriptions;
|
|
self.log_store.update(cx, |log_store, cx| {
|
|
let state = log_store.get_language_server_state(server_id)?;
|
|
state.toggled_log_kind = Some(LogKind::Trace);
|
|
send_toggle_log_message(state, server_id, true, LogType::Trace, cx);
|
|
Some(())
|
|
});
|
|
cx.notify();
|
|
}
|
|
self.editor.read(cx).focus_handle(cx).focus(window);
|
|
}
|
|
|
|
fn show_rpc_trace_for_server(
|
|
&mut self,
|
|
server_id: LanguageServerId,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
self.toggle_rpc_trace_for_server(server_id, true, window, cx);
|
|
let rpc_log = self.log_store.update(cx, |log_store, _| {
|
|
log_store
|
|
.enable_rpc_trace_for_language_server(server_id)
|
|
.map(|state| log_contents(&state.rpc_messages, ()))
|
|
});
|
|
if let Some(rpc_log) = rpc_log {
|
|
self.current_server_id = Some(server_id);
|
|
self.active_entry_kind = LogKind::Rpc;
|
|
let (editor, editor_subscriptions) = Self::editor_for_logs(rpc_log, window, cx);
|
|
let language = self.project.read(cx).languages().language_for_name("JSON");
|
|
editor
|
|
.read(cx)
|
|
.buffer()
|
|
.read(cx)
|
|
.as_singleton()
|
|
.expect("log buffer should be a singleton")
|
|
.update(cx, |_, cx| {
|
|
cx.spawn({
|
|
let buffer = cx.entity();
|
|
async move |_, cx| {
|
|
let language = language.await.ok();
|
|
buffer.update(cx, |buffer, cx| {
|
|
buffer.set_language(language, cx);
|
|
})
|
|
}
|
|
})
|
|
.detach_and_log_err(cx);
|
|
});
|
|
|
|
self.editor = editor;
|
|
self.editor_subscriptions = editor_subscriptions;
|
|
cx.notify();
|
|
}
|
|
|
|
self.editor.read(cx).focus_handle(cx).focus(window);
|
|
}
|
|
|
|
fn toggle_rpc_trace_for_server(
|
|
&mut self,
|
|
server_id: LanguageServerId,
|
|
enabled: bool,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
self.log_store.update(cx, |log_store, cx| {
|
|
if enabled {
|
|
log_store.enable_rpc_trace_for_language_server(server_id);
|
|
} else {
|
|
log_store.disable_rpc_trace_for_language_server(server_id);
|
|
}
|
|
|
|
if let Some(server_state) = log_store.language_servers.get(&server_id) {
|
|
send_toggle_log_message(server_state, server_id, enabled, LogType::Rpc, cx);
|
|
};
|
|
});
|
|
if !enabled && Some(server_id) == self.current_server_id {
|
|
self.show_logs_for_server(server_id, window, cx);
|
|
cx.notify();
|
|
}
|
|
}
|
|
|
|
fn update_trace_level(
|
|
&self,
|
|
server_id: LanguageServerId,
|
|
level: TraceValue,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
if let Some(server) = self
|
|
.project
|
|
.read(cx)
|
|
.lsp_store()
|
|
.read(cx)
|
|
.language_server_for_id(server_id)
|
|
{
|
|
self.log_store.update(cx, |this, _| {
|
|
if let Some(state) = this.get_language_server_state(server_id) {
|
|
state.trace_level = level;
|
|
}
|
|
});
|
|
|
|
server
|
|
.notify::<SetTrace>(&SetTraceParams { value: level })
|
|
.ok();
|
|
}
|
|
}
|
|
|
|
fn show_server_info(
|
|
&mut self,
|
|
server_id: LanguageServerId,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
let Some(server_info) = self
|
|
.project
|
|
.read(cx)
|
|
.lsp_store()
|
|
.update(cx, |lsp_store, _| {
|
|
lsp_store
|
|
.language_server_for_id(server_id)
|
|
.as_ref()
|
|
.map(|language_server| ServerInfo::new(language_server))
|
|
.or_else(move || {
|
|
let capabilities =
|
|
lsp_store.lsp_server_capabilities.get(&server_id)?.clone();
|
|
let name = lsp_store
|
|
.language_server_statuses
|
|
.get(&server_id)
|
|
.map(|status| status.name.clone())?;
|
|
Some(ServerInfo {
|
|
id: server_id,
|
|
capabilities,
|
|
binary: None,
|
|
name,
|
|
workspace_folders: Vec::new(),
|
|
configuration: None,
|
|
})
|
|
})
|
|
})
|
|
else {
|
|
return;
|
|
};
|
|
self.current_server_id = Some(server_id);
|
|
self.active_entry_kind = LogKind::ServerInfo;
|
|
let (editor, editor_subscriptions) = Self::editor_for_server_info(server_info, window, cx);
|
|
self.editor = editor;
|
|
self.editor_subscriptions = editor_subscriptions;
|
|
cx.notify();
|
|
self.editor.read(cx).focus_handle(cx).focus(window);
|
|
self.log_store.update(cx, |log_store, cx| {
|
|
let state = log_store.get_language_server_state(server_id)?;
|
|
if let Some(log_kind) = state.toggled_log_kind.take() {
|
|
if let Some(log_type) = log_type(log_kind) {
|
|
send_toggle_log_message(state, server_id, false, log_type, cx);
|
|
}
|
|
};
|
|
Some(())
|
|
});
|
|
}
|
|
}
|
|
|
|
fn log_type(log_kind: LogKind) -> Option<LogType> {
|
|
match log_kind {
|
|
LogKind::Rpc => Some(LogType::Rpc),
|
|
LogKind::Trace => Some(LogType::Trace),
|
|
LogKind::Logs => Some(LogType::Log),
|
|
LogKind::ServerInfo => None,
|
|
}
|
|
}
|
|
|
|
fn send_toggle_log_message(
|
|
server_state: &log_store::LanguageServerState,
|
|
server_id: LanguageServerId,
|
|
enabled: bool,
|
|
log_type: LogType,
|
|
cx: &mut App,
|
|
) {
|
|
if let LanguageServerKind::Remote { project } = &server_state.kind {
|
|
project
|
|
.update(cx, |project, cx| {
|
|
if let Some((client, project_id)) = project.lsp_store().read(cx).upstream_client() {
|
|
client
|
|
.send(proto::ToggleLspLogs {
|
|
project_id,
|
|
log_type: log_type as i32,
|
|
server_id: server_id.to_proto(),
|
|
enabled,
|
|
})
|
|
.log_err();
|
|
}
|
|
})
|
|
.ok();
|
|
}
|
|
}
|
|
|
|
fn log_contents<T: Message>(lines: &VecDeque<T>, level: <T as Message>::Level) -> String {
|
|
lines
|
|
.iter()
|
|
.filter(|message| message.should_include(level))
|
|
.flat_map(|message| [message.as_ref(), "\n"])
|
|
.collect()
|
|
}
|
|
|
|
impl Render for LspLogView {
|
|
fn render(&mut self, window: &mut Window, cx: &mut Context<Self>) -> impl IntoElement {
|
|
self.editor.update(cx, |editor, cx| {
|
|
editor.render(window, cx).into_any_element()
|
|
})
|
|
}
|
|
}
|
|
|
|
impl Focusable for LspLogView {
|
|
fn focus_handle(&self, _: &App) -> FocusHandle {
|
|
self.focus_handle.clone()
|
|
}
|
|
}
|
|
|
|
impl Item for LspLogView {
|
|
type Event = EditorEvent;
|
|
|
|
fn to_item_events(event: &Self::Event, f: impl FnMut(workspace::item::ItemEvent)) {
|
|
Editor::to_item_events(event, f)
|
|
}
|
|
|
|
fn tab_content_text(&self, _detail: usize, _cx: &App) -> SharedString {
|
|
"LSP Logs".into()
|
|
}
|
|
|
|
fn telemetry_event_text(&self) -> Option<&'static str> {
|
|
None
|
|
}
|
|
|
|
fn as_searchable(&self, handle: &Entity<Self>) -> Option<Box<dyn SearchableItemHandle>> {
|
|
Some(Box::new(handle.clone()))
|
|
}
|
|
|
|
fn act_as_type<'a>(
|
|
&'a self,
|
|
type_id: TypeId,
|
|
self_handle: &'a Entity<Self>,
|
|
_: &'a App,
|
|
) -> Option<AnyView> {
|
|
if type_id == TypeId::of::<Self>() {
|
|
Some(self_handle.to_any())
|
|
} else if type_id == TypeId::of::<Editor>() {
|
|
Some(self.editor.to_any())
|
|
} else {
|
|
None
|
|
}
|
|
}
|
|
|
|
fn clone_on_split(
|
|
&self,
|
|
_workspace_id: Option<WorkspaceId>,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) -> Option<Entity<Self>>
|
|
where
|
|
Self: Sized,
|
|
{
|
|
Some(cx.new(|cx| {
|
|
let mut new_view = Self::new(self.project.clone(), self.log_store.clone(), window, cx);
|
|
if let Some(server_id) = self.current_server_id {
|
|
match self.active_entry_kind {
|
|
LogKind::Rpc => new_view.show_rpc_trace_for_server(server_id, window, cx),
|
|
LogKind::Trace => new_view.show_trace_for_server(server_id, window, cx),
|
|
LogKind::Logs => new_view.show_logs_for_server(server_id, window, cx),
|
|
LogKind::ServerInfo => new_view.show_server_info(server_id, window, cx),
|
|
}
|
|
}
|
|
new_view
|
|
}))
|
|
}
|
|
}
|
|
|
|
impl SearchableItem for LspLogView {
|
|
type Match = <Editor as SearchableItem>::Match;
|
|
|
|
fn clear_matches(&mut self, window: &mut Window, cx: &mut Context<Self>) {
|
|
self.editor.update(cx, |e, cx| e.clear_matches(window, cx))
|
|
}
|
|
|
|
fn update_matches(
|
|
&mut self,
|
|
matches: &[Self::Match],
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
self.editor
|
|
.update(cx, |e, cx| e.update_matches(matches, window, cx))
|
|
}
|
|
|
|
fn query_suggestion(&mut self, window: &mut Window, cx: &mut Context<Self>) -> String {
|
|
self.editor
|
|
.update(cx, |e, cx| e.query_suggestion(window, cx))
|
|
}
|
|
|
|
fn activate_match(
|
|
&mut self,
|
|
index: usize,
|
|
matches: &[Self::Match],
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
self.editor
|
|
.update(cx, |e, cx| e.activate_match(index, matches, window, cx))
|
|
}
|
|
|
|
fn select_matches(
|
|
&mut self,
|
|
matches: &[Self::Match],
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
self.editor
|
|
.update(cx, |e, cx| e.select_matches(matches, window, cx))
|
|
}
|
|
|
|
fn find_matches(
|
|
&mut self,
|
|
query: Arc<project::search::SearchQuery>,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) -> gpui::Task<Vec<Self::Match>> {
|
|
self.editor
|
|
.update(cx, |e, cx| e.find_matches(query, window, cx))
|
|
}
|
|
|
|
fn replace(
|
|
&mut self,
|
|
_: &Self::Match,
|
|
_: &SearchQuery,
|
|
_window: &mut Window,
|
|
_: &mut Context<Self>,
|
|
) {
|
|
// Since LSP Log is read-only, it doesn't make sense to support replace operation.
|
|
}
|
|
fn supported_options(&self) -> workspace::searchable::SearchOptions {
|
|
workspace::searchable::SearchOptions {
|
|
case: true,
|
|
word: true,
|
|
regex: true,
|
|
find_in_results: false,
|
|
// LSP log is read-only.
|
|
replacement: false,
|
|
selection: false,
|
|
}
|
|
}
|
|
fn active_match_index(
|
|
&mut self,
|
|
direction: Direction,
|
|
matches: &[Self::Match],
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) -> Option<usize> {
|
|
self.editor.update(cx, |e, cx| {
|
|
e.active_match_index(direction, matches, window, cx)
|
|
})
|
|
}
|
|
}
|
|
|
|
impl EventEmitter<ToolbarItemEvent> for LspLogToolbarItemView {}
|
|
|
|
impl ToolbarItemView for LspLogToolbarItemView {
|
|
fn set_active_pane_item(
|
|
&mut self,
|
|
active_pane_item: Option<&dyn ItemHandle>,
|
|
_: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) -> workspace::ToolbarItemLocation {
|
|
if let Some(item) = active_pane_item
|
|
&& let Some(log_view) = item.downcast::<LspLogView>()
|
|
{
|
|
self.log_view = Some(log_view.clone());
|
|
self._log_view_subscription = Some(cx.observe(&log_view, |_, _, cx| {
|
|
cx.notify();
|
|
}));
|
|
return ToolbarItemLocation::PrimaryLeft;
|
|
}
|
|
self.log_view = None;
|
|
self._log_view_subscription = None;
|
|
ToolbarItemLocation::Hidden
|
|
}
|
|
}
|
|
|
|
impl Render for LspLogToolbarItemView {
|
|
fn render(&mut self, _: &mut Window, cx: &mut Context<Self>) -> impl IntoElement {
|
|
let Some(log_view) = self.log_view.clone() else {
|
|
return div();
|
|
};
|
|
|
|
let (menu_rows, current_server_id) = log_view.update(cx, |log_view, cx| {
|
|
let menu_rows = log_view.menu_items(cx).unwrap_or_default();
|
|
let current_server_id = log_view.current_server_id;
|
|
(menu_rows, current_server_id)
|
|
});
|
|
|
|
let current_server = current_server_id.and_then(|current_server_id| {
|
|
if let Ok(ix) = menu_rows.binary_search_by_key(¤t_server_id, |e| e.server_id) {
|
|
Some(menu_rows[ix].clone())
|
|
} else {
|
|
None
|
|
}
|
|
});
|
|
|
|
let available_language_servers: Vec<_> = menu_rows
|
|
.into_iter()
|
|
.map(|row| {
|
|
(
|
|
row.server_id,
|
|
row.server_name,
|
|
row.worktree_root_name,
|
|
row.selected_entry,
|
|
)
|
|
})
|
|
.collect();
|
|
|
|
let log_toolbar_view = cx.entity();
|
|
|
|
let lsp_menu = PopoverMenu::new("LspLogView")
|
|
.anchor(Corner::TopLeft)
|
|
.trigger(
|
|
Button::new(
|
|
"language_server_menu_header",
|
|
current_server
|
|
.as_ref()
|
|
.map(|row| {
|
|
Cow::Owned(format!(
|
|
"{} ({})",
|
|
row.server_name.0, row.worktree_root_name,
|
|
))
|
|
})
|
|
.unwrap_or_else(|| "No server selected".into()),
|
|
)
|
|
.icon(IconName::ChevronDown)
|
|
.icon_size(IconSize::Small)
|
|
.icon_color(Color::Muted),
|
|
)
|
|
.menu({
|
|
let log_view = log_view.clone();
|
|
move |window, cx| {
|
|
let log_view = log_view.clone();
|
|
ContextMenu::build(window, cx, |mut menu, window, _| {
|
|
for (server_id, name, worktree_root, active_entry_kind) in
|
|
available_language_servers.iter()
|
|
{
|
|
let label = format!("{} ({})", name, worktree_root);
|
|
let server_id = *server_id;
|
|
let active_entry_kind = *active_entry_kind;
|
|
menu = menu.entry(
|
|
label,
|
|
None,
|
|
window.handler_for(&log_view, move |view, window, cx| {
|
|
view.current_server_id = Some(server_id);
|
|
view.active_entry_kind = active_entry_kind;
|
|
match view.active_entry_kind {
|
|
LogKind::Rpc => {
|
|
view.toggle_rpc_trace_for_server(
|
|
server_id, true, window, cx,
|
|
);
|
|
view.show_rpc_trace_for_server(server_id, window, cx);
|
|
}
|
|
LogKind::Trace => {
|
|
view.show_trace_for_server(server_id, window, cx)
|
|
}
|
|
LogKind::Logs => {
|
|
view.show_logs_for_server(server_id, window, cx)
|
|
}
|
|
LogKind::ServerInfo => {
|
|
view.show_server_info(server_id, window, cx)
|
|
}
|
|
}
|
|
cx.notify();
|
|
}),
|
|
);
|
|
}
|
|
menu
|
|
})
|
|
.into()
|
|
}
|
|
});
|
|
|
|
let view_selector = current_server.map(|server| {
|
|
let server_id = server.server_id;
|
|
let rpc_trace_enabled = server.rpc_trace_enabled;
|
|
let log_view = log_view.clone();
|
|
PopoverMenu::new("LspViewSelector")
|
|
.anchor(Corner::TopLeft)
|
|
.trigger(
|
|
Button::new("language_server_menu_header", server.selected_entry.label())
|
|
.icon(IconName::ChevronDown)
|
|
.icon_size(IconSize::Small)
|
|
.icon_color(Color::Muted),
|
|
)
|
|
.menu(move |window, cx| {
|
|
let log_toolbar_view = log_toolbar_view.clone();
|
|
let log_view = log_view.clone();
|
|
Some(ContextMenu::build(window, cx, move |this, window, _| {
|
|
this.entry(
|
|
SERVER_LOGS,
|
|
None,
|
|
window.handler_for(&log_view, move |view, window, cx| {
|
|
view.show_logs_for_server(server_id, window, cx);
|
|
}),
|
|
)
|
|
.entry(
|
|
SERVER_TRACE,
|
|
None,
|
|
window.handler_for(&log_view, move |view, window, cx| {
|
|
view.show_trace_for_server(server_id, window, cx);
|
|
}),
|
|
)
|
|
.custom_entry(
|
|
{
|
|
let log_toolbar_view = log_toolbar_view.clone();
|
|
move |window, _| {
|
|
h_flex()
|
|
.w_full()
|
|
.justify_between()
|
|
.child(Label::new(RPC_MESSAGES))
|
|
.child(
|
|
div().child(
|
|
Checkbox::new(
|
|
"LspLogEnableRpcTrace",
|
|
if rpc_trace_enabled {
|
|
ToggleState::Selected
|
|
} else {
|
|
ToggleState::Unselected
|
|
},
|
|
)
|
|
.on_click(window.listener_for(
|
|
&log_toolbar_view,
|
|
move |view, selection, window, cx| {
|
|
let enabled = matches!(
|
|
selection,
|
|
ToggleState::Selected
|
|
);
|
|
view.toggle_rpc_logging_for_server(
|
|
server_id, enabled, window, cx,
|
|
);
|
|
cx.stop_propagation();
|
|
},
|
|
)),
|
|
),
|
|
)
|
|
.into_any_element()
|
|
}
|
|
},
|
|
window.handler_for(&log_view, move |view, window, cx| {
|
|
view.show_rpc_trace_for_server(server_id, window, cx);
|
|
}),
|
|
)
|
|
.entry(
|
|
SERVER_INFO,
|
|
None,
|
|
window.handler_for(&log_view, move |view, window, cx| {
|
|
view.show_server_info(server_id, window, cx);
|
|
}),
|
|
)
|
|
}))
|
|
})
|
|
});
|
|
|
|
h_flex()
|
|
.size_full()
|
|
.gap_1()
|
|
.justify_between()
|
|
.child(
|
|
h_flex()
|
|
.gap_0p5()
|
|
.child(lsp_menu)
|
|
.children(view_selector)
|
|
.child(
|
|
log_view.update(cx, |this, _cx| match this.active_entry_kind {
|
|
LogKind::Trace => {
|
|
let log_view = log_view.clone();
|
|
div().child(
|
|
PopoverMenu::new("lsp-trace-level-menu")
|
|
.anchor(Corner::TopLeft)
|
|
.trigger(
|
|
Button::new(
|
|
"language_server_trace_level_selector",
|
|
"Trace level",
|
|
)
|
|
.icon(IconName::ChevronDown)
|
|
.icon_size(IconSize::Small)
|
|
.icon_color(Color::Muted),
|
|
)
|
|
.menu({
|
|
let log_view = log_view;
|
|
|
|
move |window, cx| {
|
|
let id = log_view.read(cx).current_server_id?;
|
|
|
|
let trace_level =
|
|
log_view.update(cx, |this, cx| {
|
|
this.log_store.update(cx, |this, _| {
|
|
Some(
|
|
this.get_language_server_state(id)?
|
|
.trace_level,
|
|
)
|
|
})
|
|
})?;
|
|
|
|
ContextMenu::build(
|
|
window,
|
|
cx,
|
|
|mut menu, window, cx| {
|
|
let log_view = log_view.clone();
|
|
|
|
for (option, label) in [
|
|
(TraceValue::Off, "Off"),
|
|
(TraceValue::Messages, "Messages"),
|
|
(TraceValue::Verbose, "Verbose"),
|
|
] {
|
|
menu = menu.entry(label, None, {
|
|
let log_view = log_view.clone();
|
|
move |_, cx| {
|
|
log_view.update(cx, |this, cx| {
|
|
if let Some(id) =
|
|
this.current_server_id
|
|
{
|
|
this.update_trace_level(
|
|
id, option, cx,
|
|
);
|
|
}
|
|
});
|
|
}
|
|
});
|
|
if option == trace_level {
|
|
menu.select_last(window, cx);
|
|
}
|
|
}
|
|
|
|
menu
|
|
},
|
|
)
|
|
.into()
|
|
}
|
|
}),
|
|
)
|
|
}
|
|
LogKind::Logs => {
|
|
let log_view = log_view.clone();
|
|
div().child(
|
|
PopoverMenu::new("lsp-log-level-menu")
|
|
.anchor(Corner::TopLeft)
|
|
.trigger(
|
|
Button::new(
|
|
"language_server_log_level_selector",
|
|
"Log level",
|
|
)
|
|
.icon(IconName::ChevronDown)
|
|
.icon_size(IconSize::Small)
|
|
.icon_color(Color::Muted),
|
|
)
|
|
.menu({
|
|
let log_view = log_view;
|
|
|
|
move |window, cx| {
|
|
let id = log_view.read(cx).current_server_id?;
|
|
|
|
let log_level =
|
|
log_view.update(cx, |this, cx| {
|
|
this.log_store.update(cx, |this, _| {
|
|
Some(
|
|
this.get_language_server_state(id)?
|
|
.log_level,
|
|
)
|
|
})
|
|
})?;
|
|
|
|
ContextMenu::build(
|
|
window,
|
|
cx,
|
|
|mut menu, window, cx| {
|
|
let log_view = log_view.clone();
|
|
|
|
for (option, label) in [
|
|
(MessageType::LOG, "Log"),
|
|
(MessageType::INFO, "Info"),
|
|
(MessageType::WARNING, "Warning"),
|
|
(MessageType::ERROR, "Error"),
|
|
] {
|
|
menu = menu.entry(label, None, {
|
|
let log_view = log_view.clone();
|
|
move |window, cx| {
|
|
log_view.update(cx, |this, cx| {
|
|
if let Some(id) =
|
|
this.current_server_id
|
|
{
|
|
this.update_log_level(
|
|
id, option, window, cx,
|
|
);
|
|
}
|
|
});
|
|
}
|
|
});
|
|
if option == log_level {
|
|
menu.select_last(window, cx);
|
|
}
|
|
}
|
|
|
|
menu
|
|
},
|
|
)
|
|
.into()
|
|
}
|
|
}),
|
|
)
|
|
}
|
|
_ => div(),
|
|
}),
|
|
),
|
|
)
|
|
.child(
|
|
Button::new("clear_log_button", "Clear").on_click(cx.listener(
|
|
|this, _, window, cx| {
|
|
if let Some(log_view) = this.log_view.as_ref() {
|
|
log_view.update(cx, |log_view, cx| {
|
|
log_view.editor.update(cx, |editor, cx| {
|
|
editor.set_read_only(false);
|
|
editor.clear(window, cx);
|
|
editor.set_read_only(true);
|
|
});
|
|
})
|
|
}
|
|
},
|
|
)),
|
|
)
|
|
}
|
|
}
|
|
|
|
fn initialize_new_editor(
|
|
content: String,
|
|
move_to_end: bool,
|
|
window: &mut Window,
|
|
cx: &mut App,
|
|
) -> Entity<Editor> {
|
|
cx.new(|cx| {
|
|
let mut editor = Editor::multi_line(window, cx);
|
|
editor.hide_minimap_by_default(window, cx);
|
|
editor.set_text(content, window, cx);
|
|
editor.set_show_git_diff_gutter(false, cx);
|
|
editor.set_show_runnables(false, cx);
|
|
editor.set_show_breakpoints(false, cx);
|
|
editor.set_read_only(true);
|
|
editor.set_show_edit_predictions(Some(false), window, cx);
|
|
editor.set_soft_wrap_mode(SoftWrap::EditorWidth, cx);
|
|
if move_to_end {
|
|
editor.move_to_end(&MoveToEnd, window, cx);
|
|
}
|
|
editor
|
|
})
|
|
}
|
|
|
|
const RPC_MESSAGES: &str = "RPC Messages";
|
|
const SERVER_LOGS: &str = "Server Logs";
|
|
const SERVER_TRACE: &str = "Server Trace";
|
|
const SERVER_INFO: &str = "Server Info";
|
|
|
|
impl LspLogToolbarItemView {
|
|
pub fn new() -> Self {
|
|
Self {
|
|
log_view: None,
|
|
_log_view_subscription: None,
|
|
}
|
|
}
|
|
|
|
fn toggle_rpc_logging_for_server(
|
|
&mut self,
|
|
id: LanguageServerId,
|
|
enabled: bool,
|
|
window: &mut Window,
|
|
cx: &mut Context<Self>,
|
|
) {
|
|
if let Some(log_view) = &self.log_view {
|
|
log_view.update(cx, |log_view, cx| {
|
|
log_view.toggle_rpc_trace_for_server(id, enabled, window, cx);
|
|
if !enabled && Some(id) == log_view.current_server_id {
|
|
log_view.show_logs_for_server(id, window, cx);
|
|
cx.notify();
|
|
} else if enabled {
|
|
log_view.show_rpc_trace_for_server(id, window, cx);
|
|
cx.notify();
|
|
}
|
|
window.focus(&log_view.focus_handle);
|
|
});
|
|
}
|
|
cx.notify();
|
|
}
|
|
}
|
|
|
|
struct ServerInfo {
|
|
id: LanguageServerId,
|
|
capabilities: lsp::ServerCapabilities,
|
|
binary: Option<LanguageServerBinary>,
|
|
name: LanguageServerName,
|
|
workspace_folders: Vec<String>,
|
|
configuration: Option<serde_json::Value>,
|
|
}
|
|
|
|
impl ServerInfo {
|
|
fn new(server: &LanguageServer) -> Self {
|
|
Self {
|
|
id: server.server_id(),
|
|
capabilities: server.capabilities(),
|
|
binary: Some(server.binary().clone()),
|
|
name: server.name(),
|
|
workspace_folders: server
|
|
.workspace_folders()
|
|
.into_iter()
|
|
.filter_map(|path| {
|
|
path.to_file_path()
|
|
.ok()
|
|
.map(|path| path.to_string_lossy().into_owned())
|
|
})
|
|
.collect::<Vec<_>>(),
|
|
configuration: Some(server.configuration().clone()),
|
|
}
|
|
}
|
|
}
|
|
|
|
impl EventEmitter<EditorEvent> for LspLogView {}
|
|
impl EventEmitter<SearchEvent> for LspLogView {}
|