UDT result

Adds support for converting udt responses to a JavaScript object.

Author: PiotrJunior

lib/types/results-wrapper.js

@@ -19,7 +19,7 @@ const Tuple = require("./tuple");
 function getCqlObject(field) {
     if (field == null) return null;
     let type = field.getType();
-    let res, fields;
+    let res, fields, names;
     switch (type) {
         case rust.CqlType.Ascii:
             return field.getAscii();
@@ -49,6 +49,13 @@ function getCqlObject(field) {
             for (let i = 0; i < fields.length; i++)
                 res.push(getCqlObject(fields[i]));
             return res;
+        case rust.CqlType.UserDefinedType:
+            fields = field.getUdtValues();
+            names = field.getUdtNames();
+            res = {};
+            for (let i = 0; i < fields.length; i++)
+                res[names[i]] = getCqlObject(fields[i]);
+            return res;
         case rust.CqlType.Text:
             return field.getText();
         case rust.CqlType.Timestamp:

src/result.rs

@@ -395,6 +395,25 @@ impl CqlValueWrapper {
         }
     }
 
+    #[napi]
+    pub fn get_udt_values(&self) -> napi::Result<Vec<Option<CqlValueWrapper>>> {
+        match self.inner.as_udt() {
+            Some(r) => Ok(r
+                .iter()
+                .map(|f| f.1.clone().map(|f| CqlValueWrapper { inner: f }))
+                .collect()),
+            None => Err(Self::generic_error("user_defined_type")),
+        }
+    }
+
+    #[napi]
+    pub fn get_udt_names(&self) -> napi::Result<Vec<String>> {
+        match self.inner.as_udt() {
+            Some(r) => Ok(r.iter().map(|f| f.0.clone()).collect()),
+            None => Err(Self::generic_error("user_defined_type")),
+        }
+    }
+
     #[napi]
     pub fn get_small_int(&self) -> napi::Result<i16> {
         match self.inner.as_smallint() {