Restore funky diag. record rubbish values

Author: robsdedude

nutkit/protocol/cypher.py

@@ -496,4 +496,18 @@ def as_cypher_type(value):
         return CypherString(value)
     if isinstance(value, (bytes, bytearray)):
         return CypherBytes(value)
+    if isinstance(
+        value,
+        (
+            CypherNode,
+            CypherRelationship,
+            CypherPath,
+            CypherPoint,
+            CypherDate,
+            CypherTime,
+            CypherDateTime,
+            CypherDuration,
+        )
+    ):
+        return value
     raise TypeError("Unsupported type: {}".format(type(value)))

tests/stub/errors/test_errors.py

@@ -283,6 +283,9 @@ def test_filling_default_value_in_diagnostic_record(self):
                     self._assert_is_test_error(error, error_data)
 
     def test_keeps_rubbish_in_diagnostic_record(self):
+        use_spacial = self.driver_supports_features(
+            types.Feature.API_TYPE_SPATIAL
+        )
         for as_cause in (False, True):
             with self.subTest(as_cause=as_cause):
                 diagnostic_record = {
@@ -292,16 +295,26 @@ def test_keeps_rubbish_in_diagnostic_record(self):
                     "CURRENT_SCHEMA": {"uh": "oh!"},
                     "OPERATION_CODE": False,
                     "_classification": 42,
-                    # stub script will interpret this as JOLT bytes
-                    "_status_parameters": {"Hello": "Goodbye"},
+                    "_status_parameters": [
+                        # stub script will interpret this as JOLT spatial point
+                        {"@": "SRID=4326;POINT(56.21 13.43)"}
+                        if use_spacial
+                        else "whatever",
+                    ],
                 }
                 error_data = self._make_test_error_data(
                     diagnostic_record=diagnostic_record,
                     code=None if as_cause else ...,
                 )
                 if as_cause:
                     error_data = self._make_test_error_data(cause=error_data)
+
                 error = self.get_error(error_data)
+
+                if use_spacial:
+                    diagnostic_record["_status_parameters"] = [
+                        types.CypherPoint("wgs84", 56.21, 13.43)
+                    ]
                 self._assert_is_test_error(error, error_data)
 
     def test_error_retryable(self):