Function smoke_test

crates/csskit_lsp/src/server.rs:145–191

()

	#[test]
	fn smoke_test() {
		let stderr_log = fmt::layer().with_writer(io::stderr).with_filter(LevelFilter::TRACE);
		struct TestHandler {
			initialized: AtomicBool,
		}
		impl Handler for TestHandler {
			fn initialized(&self) -> bool {
				self.initialized.load(Ordering::SeqCst)
			}
			fn initialize(&self, _req: InitializeParams) -> Result<InitializeResult, ErrorCode> {
				self.initialized.swap(true, Ordering::SeqCst);
				Ok(InitializeResult { ..Default::default() })
			}
		}

		let server = Server::new(TestHandler { initialized: AtomicBool::new(false) });
		registry().with(stderr_log).with(server.tracer()).init();
		let (sender, receiver) = server.raw_channels();
		sender
			.send(Message::Request(Request {
				id: 1.into(),
				method: Initialize::METHOD.into(),
				params: to_value(InitializeParams { ..Default::default() }).unwrap(),
			}))
			.unwrap();
		assert_eq!(receiver.recv(), Ok(Message::Response(Response::Ok(1.into(), json!({"capabilities": {}})))));
		sender
			.send(Message::Request(Request {
				id: 1.into(),
				method: GotoDeclaration::METHOD.into(),
				params: json!({
					"textDocument": {
						"uri": "foo/bar",
					},
					"position": {
						"line": 1,
						"character": 1
					}
				}),
			}))
			.unwrap();
		assert_eq!(
			receiver.recv(),
			Ok(Message::Response(Response::Err(1.into(), ErrorCode::MethodNotFound, "".into(), Value::Null)))
		);
		sender.send(Message::Notification(Notification { method: "exit".into(), params: Value::Null })).unwrap();
	}
}