Switch to surrealdb-beta crate to use official QueryStats-API (#164)

* Switch to `surrealdb-beta` crate and official `QueryStats`-API

* Slightly simplify `process_result`

* Revert change in Tauri config

* update embeddings

src-embed/Cargo.toml

@@ -20,7 +20,7 @@ wasm-bindgen = "0.2.87"
 wasm-bindgen-futures = "0.4.37"
 serde-wasm-bindgen = "0.6.0"
 concat-string = "1.0.1"
-surrealdb = { git = "https://github.com/macjuul/surrealdb.git", rev = "33461a33", features = ["kv-mem"] }
+surrealdb = { package="surrealdb-beta", version="1", features = ["kv-mem"] }
 regex = "1.9.5"
 serde_json = "1.0"
 tokio = { version = "1", features = ["time"] }

src-embed/src/query/local.rs

@@ -45,7 +45,7 @@ pub async fn execute_local_query(
         console_log!("Failed to parse query variables");
     }
 
-    let query_task = builder.await;
+    let query_task = builder.with_stats().await;
 
     console_log!(
         "Received response from database, success: {}",

src-embed/src/query/mod.rs

@@ -2,6 +2,7 @@ pub mod local;
 pub mod remote;
 
 use serde::Deserialize;
+use surrealdb::method::WithStats;
 use surrealdb::sql::Array;
 use surrealdb::sql::Object;
 use surrealdb::sql::Value;
@@ -45,7 +46,7 @@ fn make_error(err: &str) -> Array {
     results
 }
 
-fn process_result(response: Result<Response, surrealdb::Error>) -> String {
+fn process_result(response: Result<WithStats<Response>, surrealdb::Error>) -> String {
     let results: Array = match response {
         Ok(mut response) => {
             let statement_count = response.num_statements();
@@ -56,28 +57,24 @@ fn process_result(response: Result<Response, surrealdb::Error>) -> String {
             for i in 0..statement_count {
                 let mut entry = Object::default();
                 let error = errors.get(&i);
-
-                entry.insert(
-                    "time".to_owned(),
-                    Value::from(response.take_time(i).unwrap()),
-                );
-
-                let result: Value;
-                let status: Value;
-
-                match error {
-                    Some(error) => {
-                        result = Value::from(error.to_string());
-                        status = "ERR".into();
+                let (result, status, stats) = match error {
+                    Some((stats, error)) => {
+                        (Value::from(error.to_string()), Value::from("ERR"), *stats)
                     }
                     None => {
-                        result = response.take(i).unwrap();
-                        status = "OK".into();
+                        let (stats, res) = response.take::<Value>(i).unwrap();
+                        (res.unwrap(), Value::from("OK"), stats)
                     }
                 };
 
                 entry.insert("result".to_owned(), result);
                 entry.insert("status".to_owned(), status);
+                if let Some(time) = stats.execution_time {
+                    entry.insert(
+                        "time".to_owned(),
+                        Value::Duration(time.into()),
+                    );
+                };
 
                 results.push(Value::Object(entry));
             }

src-embed/src/query/remote.rs

@@ -165,7 +165,7 @@ pub async fn execute_remote_query(query: String, params: String) -> String {
         console_log!("Failed to parse query variables");
     }
 
-    let query_task = builder.await;
+    let query_task = builder.with_stats().await;
 
     console_log!(
         "Received response from database, success: {}",