1use std::sync::Arc;
  2
  3use crate::lsp_log::LogMenuItem;
  4
  5use super::*;
  6use futures::StreamExt;
  7use gpui::{Context, TestAppContext, VisualTestContext};
  8use language::{tree_sitter_rust, FakeLspAdapter, Language, LanguageConfig, LanguageServerName};
  9use project::{FakeFs, Project};
 10use serde_json::json;
 11use settings::SettingsStore;
 12
 13#[gpui::test]
 14async fn test_lsp_logs(cx: &mut TestAppContext) {
 15    if std::env::var("RUST_LOG").is_ok() {
 16        env_logger::init();
 17    }
 18
 19    init_test(cx);
 20
 21    let mut rust_language = Language::new(
 22        LanguageConfig {
 23            name: "Rust".into(),
 24            path_suffixes: vec!["rs".to_string()],
 25            ..Default::default()
 26        },
 27        Some(tree_sitter_rust::language()),
 28    );
 29    let mut fake_rust_servers = rust_language
 30        .set_fake_lsp_adapter(Arc::new(FakeLspAdapter {
 31            name: "the-rust-language-server",
 32            ..Default::default()
 33        }))
 34        .await;
 35
 36    let fs = FakeFs::new(cx.background_executor.clone());
 37    fs.insert_tree(
 38        "/the-root",
 39        json!({
 40            "test.rs": "",
 41            "package.json": "",
 42        }),
 43    )
 44    .await;
 45    let project = Project::test(fs.clone(), ["/the-root".as_ref()], cx).await;
 46    project.update(cx, |project, _| {
 47        project.languages().add(Arc::new(rust_language));
 48    });
 49
 50    let log_store = cx.new_model(|cx| LogStore::new(cx));
 51    log_store.update(cx, |store, cx| store.add_project(&project, cx));
 52
 53    let _rust_buffer = project
 54        .update(cx, |project, cx| {
 55            project.open_local_buffer("/the-root/test.rs", cx)
 56        })
 57        .await
 58        .unwrap();
 59
 60    let mut language_server = fake_rust_servers.next().await.unwrap();
 61    language_server
 62        .receive_notification::<lsp::notification::DidOpenTextDocument>()
 63        .await;
 64
 65    let window = cx.add_window(|cx| LspLogView::new(project.clone(), log_store.clone(), cx));
 66    let log_view = window.root(cx).unwrap();
 67    let mut cx = VisualTestContext::from_window(*window, cx);
 68
 69    language_server.notify::<lsp::notification::LogMessage>(lsp::LogMessageParams {
 70        message: "hello from the server".into(),
 71        typ: lsp::MessageType::INFO,
 72    });
 73    cx.executor().run_until_parked();
 74
 75    log_view.update(&mut cx, |view, cx| {
 76        assert_eq!(
 77            view.menu_items(cx).unwrap(),
 78            &[LogMenuItem {
 79                server_id: language_server.server.server_id(),
 80                server_name: LanguageServerName("the-rust-language-server".into()),
 81                worktree_root_name: project
 82                    .read(cx)
 83                    .worktrees()
 84                    .next()
 85                    .unwrap()
 86                    .read(cx)
 87                    .root_name()
 88                    .to_string(),
 89                rpc_trace_enabled: false,
 90                rpc_trace_selected: false,
 91                logs_selected: true,
 92            }]
 93        );
 94        assert_eq!(view.editor.read(cx).text(cx), "hello from the server\n");
 95    });
 96}
 97
 98fn init_test(cx: &mut gpui::TestAppContext) {
 99    cx.update(|cx| {
100        let settings_store = SettingsStore::test(cx);
101        cx.set_global(settings_store);
102        theme::init(theme::LoadThemes::JustBase, cx);
103        release_channel::init("0.0.0", cx);
104        language::init(cx);
105        client::init_settings(cx);
106        Project::init_settings(cx);
107        editor::init_settings(cx);
108    });
109}