mirrors/zed
1
0
Fork 0
mirror of https://github.com/zed-industries/zed.git synced 2025-01-07 17:26:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 13

Uncomment lsp2 tests

Browse source
This commit is contained in:
Julia 2023-11-02 11:42:48 -04:00
parent ec0cff0e1a
commit b7efab8a55
1 changed files with 64 additions and 64 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

128
crates/lsp2/src/lsp2.rs
View file

@ -1107,74 +1107,74 @@ impl FakeLanguageServer {
}
}
// #[cfg(test)]
// mod tests {
// use super::*;
// use gpui::TestAppContext;
#[cfg(test)]
mod tests {
use super::*;
use gpui2::TestAppContext;
// #[ctor::ctor]
// fn init_logger() {
// if std::env::var("RUST_LOG").is_ok() {
// env_logger::init();
// }
// }
#[ctor::ctor]
fn init_logger() {
if std::env::var("RUST_LOG").is_ok() {
env_logger::init();
}
}
// #[gpui::test]
// async fn test_fake(cx: &mut TestAppContext) {
// let (server, mut fake) =
// LanguageServer::fake("the-lsp".to_string(), Default::default(), cx.to_async());
#[gpui2::test]
async fn test_fake(cx: &mut TestAppContext) {
let (server, mut fake) =
LanguageServer::fake("the-lsp".to_string(), Default::default(), cx.to_async());
// let (message_tx, message_rx) = channel::unbounded();
// let (diagnostics_tx, diagnostics_rx) = channel::unbounded();
// server
// .on_notification::<notification::ShowMessage, _>(move |params, _| {
// message_tx.try_send(params).unwrap()
// })
// .detach();
// server
// .on_notification::<notification::PublishDiagnostics, _>(move |params, _| {
// diagnostics_tx.try_send(params).unwrap()
// })
// .detach();
let (message_tx, message_rx) = channel::unbounded();
let (diagnostics_tx, diagnostics_rx) = channel::unbounded();
server
.on_notification::<notification::ShowMessage, _>(move |params, _| {
message_tx.try_send(params).unwrap()
})
.detach();
server
.on_notification::<notification::PublishDiagnostics, _>(move |params, _| {
diagnostics_tx.try_send(params).unwrap()
})
.detach();
// let server = server.initialize(None).await.unwrap();
// server
// .notify::<notification::DidOpenTextDocument>(DidOpenTextDocumentParams {
// text_document: TextDocumentItem::new(
// Url::from_str("file://a/b").unwrap(),
// "rust".to_string(),
// 0,
// "".to_string(),
// ),
// })
// .unwrap();
// assert_eq!(
// fake.receive_notification::<notification::DidOpenTextDocument>()
// .await
// .text_document
// .uri
// .as_str(),
// "file://a/b"
// );
let server = server.initialize(None).await.unwrap();
server
.notify::<notification::DidOpenTextDocument>(DidOpenTextDocumentParams {
text_document: TextDocumentItem::new(
Url::from_str("file://a/b").unwrap(),
"rust".to_string(),
0,
"".to_string(),
),
})
.unwrap();
assert_eq!(
fake.receive_notification::<notification::DidOpenTextDocument>()
.await
.text_document
.uri
.as_str(),
"file://a/b"
);
// fake.notify::<notification::ShowMessage>(ShowMessageParams {
// typ: MessageType::ERROR,
// message: "ok".to_string(),
// });
// fake.notify::<notification::PublishDiagnostics>(PublishDiagnosticsParams {
// uri: Url::from_str("file://b/c").unwrap(),
// version: Some(5),
// diagnostics: vec![],
// });
// assert_eq!(message_rx.recv().await.unwrap().message, "ok");
// assert_eq!(
// diagnostics_rx.recv().await.unwrap().uri.as_str(),
// "file://b/c"
// );
fake.notify::<notification::ShowMessage>(ShowMessageParams {
typ: MessageType::ERROR,
message: "ok".to_string(),
});
fake.notify::<notification::PublishDiagnostics>(PublishDiagnosticsParams {
uri: Url::from_str("file://b/c").unwrap(),
version: Some(5),
diagnostics: vec![],
});
assert_eq!(message_rx.recv().await.unwrap().message, "ok");
assert_eq!(
diagnostics_rx.recv().await.unwrap().uri.as_str(),
"file://b/c"
);
// fake.handle_request::<request::Shutdown, _, _>(|_, _| async move { Ok(()) });
fake.handle_request::<request::Shutdown, _, _>(|_, _| async move { Ok(()) });
// drop(server);
// fake.receive_notification::<notification::Exit>().await;
// }
// }
drop(server);
fake.receive_notification::<notification::Exit>().await;
}
}