feat: Implement HTTP gateway with JSON encoding and graph/cell operations

Author: shisoft

.gitignore

@@ -126,3 +126,6 @@ perf.data*
 /models/
 *.onnx
 *.onnx_data
+
+
+nohup.out

Cargo.toml

@@ -4,6 +4,11 @@ version = "0.1.0"
 authors = ["Hao Shi <shisoftgenius@gmail.com>"]
 edition = "2021"
 
+[workspace]
+members = [
+    "crates/morpheus-http-client",
+]
+
 [lib]
 name = "morpheus"
 path = "src/lib.rs"
@@ -52,6 +57,11 @@ chrono = "0.4"
 rayon = "1.10"
 fixedbitset = "0.5"
 
+# HTTP gateway (external clients)
+axum = { version = "0.7", features = ["json"] }
+tower-http = { version = "0.5", features = ["cors"] }
+bs58 = "0.5"
+
 # Embedding dependencies
 embellama = "0.8.0"
 async-trait = "0.1"
@@ -113,4 +123,4 @@ opt-level = 3
 debug = true
 lto = true
 panic = 'unwind'
-strip = "none"
+strip = "none"

config/server.yaml

@@ -0,0 +1,19 @@
+server_addr: 127.0.0.1:5403
+group_name: MediumMorpheus
+meta_members:
+  - 127.0.0.1:5403
+storage:
+  chunk_count: 32
+  total_size: "16GB"
+  backup_storage: null
+  wal_storage: null
+  enable_recovery: false
+  services:
+    - Cell
+    - Transaction
+    - RangedIndexer
+    - Query
+  index_enabled: true
+  tiered_config:
+    threshold: 0.8
+    physical_memory_limit: "8GB"

crates/morpheus-http-client/README.md

@@ -0,0 +1,80 @@
+# morpheus-http-client
+
+Async HTTP client for Morpheus' REST gateway.
+
+## Usage
+
+```rust
+use morpheus_http_client::{MorpheusHttpClient, CellWriteRequest};
+use url::Url;
+
+#[tokio::main]
+async fn main() {
+    let client = MorpheusHttpClient::new(Url::parse("http://127.0.0.1:8080").unwrap())
+        .with_admin_token("devtoken");
+
+    let _ = client.health().await.unwrap();
+
+    // Cell CRUD
+    let cell_id_b58 = "<base58_cell_id>";
+    let _ = client
+        .cell_upsert(
+            cell_id_b58,
+            &CellWriteRequest {
+                schema_id: 123,
+                data: serde_json::json!({"k": "v"}),
+            },
+        )
+        .await
+        .unwrap();
+}
+```
+
+## Graph
+
+```rust
+use morpheus_http_client::{MorpheusHttpClient, SchemaRef, VertexCreateRequest};
+use url::Url;
+
+#[tokio::main]
+async fn main() {
+    let client = MorpheusHttpClient::new(Url::parse("http://127.0.0.1:8080").unwrap())
+        .with_admin_token("devtoken");
+
+    let v = client
+        .vertex_create(&VertexCreateRequest {
+            schema: SchemaRef::Name {
+                schema_name: "people".to_string(),
+            },
+            id: None,
+            data: serde_json::json!({"name": "alice"}),
+        })
+        .await
+        .unwrap();
+
+    let _ = client.vertex_get(&v.data.id).await.unwrap();
+}
+```
+
+## Auth
+
+If the server is configured with `MORPHEUS_HTTP_ADMIN_TOKEN`, this client will send:
+
+`Authorization: Bearer <token>`
+
+when `with_admin_token(...)` is set.
+
+## Data Encoding
+
+The HTTP gateway accepts JSON-native objects and arrays for maps and arrays. For non-JSON
+types, use typed values:
+
+```json
+{"$type": "u64", "value": 18446744073709551615}
+```
+
+Common tags:
+- `i8`, `i16`, `i32`, `i64`, `u8`, `u16`, `u32`, `u64`, `f32`, `f64`
+- `id` with base58 string value (16-byte id)
+- `bytes` with `value` as an array of byte numbers
+- `u32[]`, `string[]`, `id[]`, etc.