From 72d60b1fced66dd422e544f86db9cf37096e6cea Mon Sep 17 00:00:00 2001
From: Dominik Werder <dominik.werder@gmail.com>
Date: Fri, 23 Apr 2021 18:37:02 +0200
Subject: [PATCH] Parsed JSON request

---
 disk/src/raw.rs | 22 ++++++++++++++++++++--
 1 file changed, 20 insertions(+), 2 deletions(-)

diff --git a/disk/src/raw.rs b/disk/src/raw.rs
index 0e2dcf2..58e4a50 100644
--- a/disk/src/raw.rs
+++ b/disk/src/raw.rs
@@ -377,7 +377,7 @@ async fn raw_conn_handler_inner_try(stream: TcpStream, addr: SocketAddr) -> Resu
         .await
     {
         match k {
-            Ok(_) => {
+            Ok(k) => {
                 info!(". . . . . . . . . . . . . . . . . . . . . . . . . .   raw_conn_handler  FRAME RECV");
                 frames.push(k);
             }
@@ -390,7 +390,25 @@ async fn raw_conn_handler_inner_try(stream: TcpStream, addr: SocketAddr) -> Resu
         error!("expect a command frame");
         return Err((Error::with_msg("expect a command frame"), netout))?;
     }
-    error!("TODO decide on response content based on the parsed json query");
+    let s1 = match String::from_utf8(frames[0].to_vec()) {
+        Ok(k) => k,
+        Err(e) => {
+            return Err((e, netout))?;
+        }
+    };
+    trace!("json  {}", s1);
+    let res: Result<serde_json::Value, _> = serde_json::from_str(&s1);
+    let evq = match res {
+        Ok(k) => k,
+        Err(e) => {
+            error!("can not parse json {:?}", e);
+            return Err((Error::with_msg("can not parse request json"), netout))?;
+        }
+    };
+    error!(
+        "TODO decide on response content based on the parsed json query\n{:?}",
+        evq
+    );
     let mut batch = MinMaxAvgScalarEventBatch::empty();
     batch.tss.push(42);
     batch.tss.push(43);