adapt server json path format.

Author: kafka1991

questdb-rs/src/ingress/http.rs

@@ -507,7 +507,7 @@ pub(super) fn read_server_settings(
         })?;
 
         let mut support_versions: Vec<ProtocolVersion> = vec![];
-        if let Some(serde_json::Value::Array(ref values)) = json.get("line.proto.support.versions")
+        if let Some(serde_json::Value::Array(ref values)) = json.get("config").and_then(|v| v.get("line.proto.support.versions"))
         {
             for value in values.iter() {
                 if let Some(v) = value.as_u64() {
@@ -523,7 +523,8 @@ pub(super) fn read_server_settings(
         }
 
         let max_name_length = json
-            .get("cairo.max.file.name.length")
+            .get("config")
+            .and_then(|v| v.get("cairo.max.file.name.length"))
             .and_then(|v| v.as_u64())
             .unwrap_or(MAX_NAME_LEN_DEFAULT as u64) as usize;
         Ok((support_versions, max_name_length))

questdb-rs/src/tests/mock.rs

@@ -314,9 +314,16 @@ impl MockServer {
         if supported_versions.is_empty() {
             self.settings_response = serde_json::json!({"version": "8.1.2"});
         } else {
-            self.settings_response = serde_json::json!({
-                "line.proto.support.versions": supported_versions
-            });
+            self.settings_response = serde_json::json!(
+                {"config":{"release.type":"OSS","release.version":"[DEVELOPMENT]",
+                    "line.proto.support.versions":supported_versions,
+                    "ilp.proto.transports":["tcp", "http"],
+                    "posthog.enabled":false,
+                    "posthog.api.key":null,
+                    "cairo.max.file.name.length":127},
+                    "preferences.version":0,
+                    "preferences":{}}
+            );
         }
         self
     }