More progress to cli dev and also the rust sdk file storage

Author: jamals86

.github/workflows/python-sdk.yml

@@ -5,7 +5,7 @@ on:
     branches: [main]
     paths:
       - 'link/sdks/python/**'
-      - 'link/kalam-client/**'
+      - 'link/sdks/rust/**'
       - 'link/link-common/**'
       - '.github/workflows/python-sdk.yml'
   workflow_dispatch:

.github/workflows/rust-sdk.yml

@@ -5,7 +5,7 @@ on:
     branches: [main]
     paths:
       - 'link/sdks/rust/**'
-      - 'link/kalam-client/**'
+      - 'link/sdks/rust/**'
       - 'link/link-common/**'
       - 'backend/crates/kalamdb-commons/**'
       - 'backend/crates/kalamdb-observability/**'

.github/workflows/versions.yml

@@ -8,7 +8,7 @@ on:
       - 'backend/Cargo.toml'
       - 'cli/Cargo.toml'
       - 'pg/Cargo.toml'
-      - 'link/kalam-client/Cargo.toml'
+      - 'link/sdks/rust/Cargo.toml'
       - 'link/sdks/rust/**'
       - 'link/sdks/typescript/**/package.json'
       - 'link/sdks/dart/pubspec.yaml'

.gitignore

@@ -131,3 +131,5 @@ link/sdks/typescript/client/.npmrc
 /tools/supabase-local
 /.playwright-mcp
 cli/kalam.toml
+/link/sdks/rust/sdks/typescript/client/.wasm-cargo-home
+/link/sdks/rust/sdks/typescript/client/.wasm-target

Cargo.toml

@@ -46,7 +46,7 @@ members = [
     "backend/crates/kalamdb-server-auth",
     "backend",
     "link/link-common",
-    "link/kalam-client",
+    "link/sdks/rust",
     "link/kalam-consumer-wasm",
     "link/kalam-link-dart",
     "cli",
@@ -185,6 +185,7 @@ x509-parser = "0.18.1"
 kalamdb-commons = { path = "backend/crates/kalamdb-commons", default-features = false }
 kalamdb-observability = { path = "backend/crates/kalamdb-observability", default-features = false }
 link-common = { path = "link/link-common", default-features = false }
+kalam-client = { path = "link/sdks/rust", default-features = false }
 kalamdb-row-filter = { path = "backend/crates/kalamdb-row-filter" }
 kalamdb-transfer = { path = "backend/crates/kalamdb-transfer" }
 kalamdb-plan-cache = { path = "backend/crates/kalamdb-plan-cache" }

README.md

@@ -57,8 +57,6 @@ Agents and frontends use the same backend directly: SQL over HTTP for reads and
   </tbody>
 </table>
 
-SDKs: [TypeScript/JavaScript](https://www.npmjs.com/package/@kalamdb/client), [Dart/Flutter](https://pub.dev/packages/kalam_link), and [Rust](https://crates.io/crates/kalam-client).
-
 PostgreSQL extension Docker image: [jamals86/pg-kalam](https://hub.docker.com/r/jamals86/pg-kalam) with `pg_kalam` preinstalled.
 
 > Frontend clients can execute SQL directly against KalamDB. You keep one SQL API plus live subscriptions instead of maintaining a custom REST or GraphQL CRUD layer for every agent workflow.

backend/Cargo.toml

@@ -150,7 +150,7 @@ kalamdb-configs = { path = "crates/kalamdb-configs" }
 kalamdb-tables = { path = "crates/kalamdb-tables" }
 kalamdb-raft = { path = "crates/kalamdb-raft" }
 kalamdb-dba = { path = "crates/kalamdb-dba" }
-kalam-client = { path = "../link/kalam-client", default-features = false, features = ["tokio-runtime", "cluster"] }
+kalam-client = { path = "../link/sdks/rust", default-features = false, features = ["tokio-runtime", "cluster"] }
 
 # External dependencies
 tempfile = { workspace = true }

backend/crates/kalamdb-commons/src/constants.rs

@@ -122,6 +122,17 @@ pub const RESERVED_NAMESPACE_NAMES: &[&str] = &[
 
 /// SQL keywords that must never be used as namespace, table, or column identifiers.
 pub const CRITICAL_RESERVED_SQL_KEYWORDS: &[&str] = &[
-    "TABLE", "TABLES", "TABLESPACE", "INDEX", "VIEW", "SCHEMA", "DATABASE", "INSERT", "UPDATE",
-    "DELETE", "CREATE", "DROP", "ALTER",
+    "TABLE",
+    "TABLES",
+    "TABLESPACE",
+    "INDEX",
+    "VIEW",
+    "SCHEMA",
+    "DATABASE",
+    "INSERT",
+    "UPDATE",
+    "DELETE",
+    "CREATE",
+    "DROP",
+    "ALTER",
 ];

backend/crates/kalamdb-commons/src/conversions/arrow_json_conversion.rs

@@ -588,7 +588,8 @@ mod tests {
         let batch = json_rows_to_arrow_batch(&schema, rows).unwrap();
         let embedding = batch
             .column(1)
-            .as_any().downcast_ref::<FixedSizeListArray>()
+            .as_any()
+            .downcast_ref::<FixedSizeListArray>()
             .expect("embedding array");
 
         assert!(embedding.is_null(0));

backend/crates/kalamdb-commons/src/helpers/arrow_utils.rs

@@ -324,16 +324,20 @@ pub fn compute_min_max(array: &ArrayRef) -> (Option<StoredScalarValue>, Option<S
 pub fn array_value_to_string(array: &dyn arrow::array::Array, row_idx: usize) -> Option<String> {
     match array.data_type() {
         ArrowDataType::Int64 => array
-            .as_any().downcast_ref::<Int64Array>()
+            .as_any()
+            .downcast_ref::<Int64Array>()
             .map(|arr| arr.value(row_idx).to_string()),
         ArrowDataType::Int32 => array
-            .as_any().downcast_ref::<Int32Array>()
+            .as_any()
+            .downcast_ref::<Int32Array>()
             .map(|arr| arr.value(row_idx).to_string()),
         ArrowDataType::Utf8 => array
-            .as_any().downcast_ref::<StringArray>()
+            .as_any()
+            .downcast_ref::<StringArray>()
             .map(|arr| arr.value(row_idx).to_string()),
         ArrowDataType::LargeUtf8 => array
-            .as_any().downcast_ref::<LargeStringArray>()
+            .as_any()
+            .downcast_ref::<LargeStringArray>()
             .map(|arr| arr.value(row_idx).to_string()),
         _ => None,
     }