Merge pull request #666 from Xanewok/int-tests-void-params

Properly handle void params in integration test harness

Author: Xanewok

tests/support/mod.rs

@@ -168,33 +168,52 @@ impl RlsHandle {
     pub fn send(&mut self, j: serde_json::Value) -> io::Result<usize> {
         self.send_string(&j.to_string())
     }
-    pub fn notify(&mut self, method: &str, params: serde_json::Value) -> io::Result<usize> {
-        self.send(json!({
-            "jsonrpc": "2.0",
-            "method": method,
-            "params": params,
-        }))
+    pub fn notify(&mut self, method: &str, params: Option<serde_json::Value>) -> io::Result<usize> {
+        let message = if let Some(params) = params {
+            json!({
+                "jsonrpc": "2.0",
+                "method": method,
+                "params": params,
+            })
+        } else {
+            json!({
+                "jsonrpc": "2.0",
+                "method": method,
+            })
+        };
+
+        self.send(message)
     }
-    pub fn request(&mut self, id: u64, method: &str, params: serde_json::Value) -> io::Result<usize> {
-        self.send(json!({
-            "jsonrpc": "2.0",
-            "id": id,
-            "method": method,
-            "params": params,
-        }))
+    pub fn request(&mut self, id: u64, method: &str, params: Option<serde_json::Value>) -> io::Result<usize> {
+        let message = if let Some(params) = params {
+            json!({
+                "jsonrpc": "2.0",
+                "id": id,
+                "method": method,
+                "params": params,
+            })
+        } else {
+            json!({
+                "jsonrpc": "2.0",
+                "id": id,
+                "method": method,
+            })
+        };
+
+        self.send(message)
     }
     pub fn shutdown_exit(&mut self) {
-        self.request(99999, "shutdown", json!({})).unwrap();
+        self.request(99999, "shutdown", None).unwrap();
 
         self.expect_messages(&[
             &ExpectedMessage::new(Some(99999)),
         ]);
 
-        self.notify("exit", json!({})).unwrap();
+        self.notify("exit", None).unwrap();
 
         let ecode = self.child.wait()
             .expect("failed to wait on child rls process");
-        
+
         assert!(ecode.success());
     }
 

tests/tests.rs

@@ -37,10 +37,10 @@ fn test_infer_bin() {
         let rls_child = p.rls().spawn().unwrap();
         let mut rls = RlsHandle::new(rls_child);
 
-        rls.request(0, "initialize", json!({
+        rls.request(0, "initialize", Some(json!({
             "rootPath": root_path,
             "capabilities": {}
-        })).unwrap();
+        }))).unwrap();
 
         rls.expect_messages(&[
             ExpectedMessage::new(Some(0)).expect_contains("capabilities"),
@@ -119,10 +119,10 @@ fn test_simple_workspace() {
         let rls_child = p.rls().spawn().unwrap();
         let mut rls = RlsHandle::new(rls_child);
 
-        rls.request(0, "initialize", json!({
+        rls.request(0, "initialize", Some(json!({
             "rootPath": root_path,
             "capabilities": {}
-        })).unwrap();
+        }))).unwrap();
 
         // This is the expected behavior is workspace_mode is on by default
         rls.expect_messages(&[