feat(cubestore): Web Socket transport (#2227)

* feat(cubestore): Web Socket transport * chore(cubestore): Web Socket transport * feat(cubestore): Web Socket transport: auth support
cube-js · Feb 28, 2021 · 8821b9e · 8821b9e
1 parent a1d091e
commit 8821b9e
Show file tree

Hide file tree

Showing 13 changed files with 1,261 additions and 124 deletions.
diff --git a/rust/Cargo.lock b/rust/Cargo.lock
diff --git a/rust/cubestore/Cargo.toml b/rust/cubestore/Cargo.toml
@@ -17,7 +17,7 @@ ipc-channel = { version = "0.14.1" }
 base64 = "0.13.0"
 bumpalo = "3.6.1"
 tokio = { version = "1.0", features = ["full", "rt"] }
-warp = "0.2"
+warp = { git = 'https://github.com/seanmonstar/warp', version = "0.3.0" }
 sqlparser = "0.7.0"
 serde_derive = "1.0.115"
 serde = "1.0.115"
@@ -72,3 +72,5 @@ tarpc = { version = "0.24", features = ["tokio1"] }
 pin-project-lite = "0.2.4"
 paste = "1.0.4"
 mysql_common = "0.26.0"
+flatbuffers = "0.7.0"
+http-auth-basic = "0.1.2"
diff --git a/rust/cubestore/flatbuffers-codegen.sh b/rust/cubestore/flatbuffers-codegen.sh
@@ -0,0 +1,4 @@
+#!/bin/bash
+
+cd src/codegen
+flatc --rust http_message.fbs
diff --git a/rust/cubestore/src/codegen/http_message.fbs b/rust/cubestore/src/codegen/http_message.fbs
@@ -0,0 +1,34 @@
+union HttpCommand {
+    HttpQuery,
+    HttpResultSet,
+    HttpError
+}
+
+table HttpMessage {
+    message_id: uint;
+    command: HttpCommand;
+}
+
+table HttpQuery {
+    query: string;
+}
+
+table HttpError {
+    error: string;
+}
+
+table HttpResultSet {
+    columns: [string];
+    rows: [HttpRow];
+}
+
+table HttpRow {
+    values: [HttpColumnValue];
+}
+
+table HttpColumnValue {
+    string_value: string;
+}
+
+
+root_type HttpMessage;