Bump deps, parser fixes, example UI & SDK docs

Update dependency versions (uuid -> 1.22.0, libc -> 0.2.183) and remove chrono/getrandom from the wasm feature set. Enhance SQL parser to recognize CURRENT_USER / CURRENT_ROLE keywords and rewrite them to KDB_CURRENT_*() for DataFusion (adds regexes and a unit test). Improve example apps: add vite env types, compute stable sort keys and sort/cap rows for chat and activity examples to ensure deterministic ordering. Revise link/ README and Dart SDK README to reflect current SDK shape, usage, and init/connect patterns; adjust crate feature lists. Misc: update related generated SDK artifacts and native libs.

Author: jamals86

Cargo.lock

@@ -87,7 +87,7 @@ actix-files = "0.6.10"
 actix-multipart = "0.7"
 
 # UUID generation
-uuid = { version = "1.21.0", features = ["v4", "v7", "serde"] }
+uuid = { version = "1.22.0", features = ["v4", "v7", "serde"] }
 
 # NanoID generation (21-char URL-safe unique IDs)
 nanoid = "0.4.0"
@@ -175,9 +175,8 @@ ntest = "0.9.5"
 wasm-bindgen = { version = "0.2.114" }
 wasm-bindgen-futures = { version = "0.4.64" }
 js-sys = { version = "0.3.91" }
-libc = "0.2.182"
+libc = "0.2.183"
 web-sys = { version = "0.3.91" }
-getrandom = { version = "0.2.15" }
 tsify-next = { version = "0.5", default-features = false, features = ["js"] }
 serde-wasm-bindgen = "0.6"
 flate2 = "1.1.9"

Cargo.toml

@@ -72,7 +72,6 @@ const threadSql = `
   SELECT id, role, content, created_at
   FROM chat.messages
   WHERE thread_id = 'thread_42'
-  ORDER BY created_at ASC
 `;
 
 await client.query(`

README.md

@@ -20,6 +20,16 @@ static CURRENT_ROLE_CALL_RE: Lazy<Regex> =
     Lazy::new(|| Regex::new(r"(?i)\bCURRENT_ROLE\s*\(\s*\)").expect("valid regex"));
 static CURRENT_USER_ID_CALL_RE: Lazy<Regex> =
     Lazy::new(|| Regex::new(r"(?i)\bCURRENT_USER_ID\s*\(\s*\)").expect("valid regex"));
+static CURRENT_USER_KEYWORD_RE: Lazy<Regex> =
+    Lazy::new(|| {
+        Regex::new(r"(?i)(^|[^A-Za-z0-9_])(CURRENT_USER)([^A-Za-z0-9_(]|$)")
+            .expect("valid regex")
+    });
+static CURRENT_ROLE_KEYWORD_RE: Lazy<Regex> =
+    Lazy::new(|| {
+        Regex::new(r"(?i)(^|[^A-Za-z0-9_])(CURRENT_ROLE)([^A-Za-z0-9_(]|$)")
+            .expect("valid regex")
+    });
 
 /// Default sqlparser options used across KalamDB
 pub fn parser_options() -> ParserOptions {
@@ -43,8 +53,10 @@ pub fn normalize_context_keyword_calls_for_sqlparser(sql: &str) -> String {
 pub fn rewrite_context_functions_for_datafusion(sql: &str) -> String {
     let sql = CURRENT_USER_ID_CALL_RE.replace_all(sql, "KDB_CURRENT_USER_ID()");
     let sql = CURRENT_USER_CALL_RE.replace_all(&sql, "KDB_CURRENT_USER()");
-    CURRENT_ROLE_CALL_RE
-        .replace_all(&sql, "KDB_CURRENT_ROLE()")
+    let sql = CURRENT_ROLE_CALL_RE.replace_all(&sql, "KDB_CURRENT_ROLE()");
+    let sql = CURRENT_USER_KEYWORD_RE.replace_all(&sql, "${1}KDB_CURRENT_USER()${3}");
+    CURRENT_ROLE_KEYWORD_RE
+        .replace_all(&sql, "${1}KDB_CURRENT_ROLE()${3}")
         .into_owned()
 }
 
@@ -494,4 +506,15 @@ mod tests {
             "SELECT KDB_CURRENT_USER(), KDB_CURRENT_USER_ID(), KDB_CURRENT_ROLE()"
         );
     }
+
+    #[test]
+    fn test_rewrite_context_keywords_for_datafusion() {
+        let rewritten = rewrite_context_functions_for_datafusion(
+            "SELECT CURRENT_USER AS username, CURRENT_ROLE AS role",
+        );
+        assert_eq!(
+            rewritten,
+            "SELECT KDB_CURRENT_USER() AS username, KDB_CURRENT_ROLE() AS role"
+        );
+    }
 }

backend/crates/kalamdb-sql/src/parser/utils.rs

@@ -8,6 +8,7 @@ type ChatMessage = {
   author: string;
   content: string;
   createdAt: string;
+  sortKey: number;
 };
 
 type AgentEvent = {
@@ -17,6 +18,7 @@ type AgentEvent = {
   preview: string;
   message: string;
   createdAt: string;
+  sortKey: number;
 };
 
 type LiveDraft = {
@@ -35,13 +37,11 @@ const CHAT_SQL = [
   'SELECT id, role, author, content, created_at',
   'FROM chat_demo.messages',
   `WHERE room = '${ROOM_SQL}'`,
-  'ORDER BY created_at ASC, id ASC',
 ].join(' ');
 const EVENTS_SQL = [
   'SELECT id, response_id, stage, preview, message, created_at',
   'FROM chat_demo.agent_events',
   `WHERE room = '${ROOM_SQL}'`,
-  'ORDER BY created_at ASC, id ASC',
 ].join(' ');
 
 function createAuthedClient() {
@@ -81,26 +81,38 @@ function formatTimestamp(rawValue: string): string {
 }
 
 function toMessage(row: RowData): ChatMessage {
+  const sortKey = row['created_at']?.asDate()?.getTime() ?? row['_seq']?.asSeqId()?.timestampMillis() ?? 0;
   return {
     id: text(row, 'id'),
     role: text(row, 'role'),
     author: text(row, 'author'),
     content: text(row, 'content'),
     createdAt: formatTimestamp(text(row, 'created_at')),
+    sortKey,
   };
 }
 
 function toAgentEvent(row: RowData): AgentEvent {
+  const sortKey = row['created_at']?.asDate()?.getTime() ?? row['_seq']?.asSeqId()?.timestampMillis() ?? 0;
   return {
     id: text(row, 'id'),
     responseId: text(row, 'response_id'),
     stage: text(row, 'stage'),
     preview: text(row, 'preview'),
     message: text(row, 'message'),
     createdAt: formatTimestamp(text(row, 'created_at')),
+    sortKey,
   };
 }
 
+function sortMessages(rows: ChatMessage[]): ChatMessage[] {
+  return [...rows].sort((left, right) => left.sortKey - right.sortKey || left.id.localeCompare(right.id));
+}
+
+function sortEvents(rows: AgentEvent[]): AgentEvent[] {
+  return [...rows].sort((left, right) => left.sortKey - right.sortKey || left.id.localeCompare(right.id));
+}
+
 function deriveLiveDraft(events: AgentEvent[]): LiveDraft | null {
   let activeEvent: AgentEvent | null = null;
 
@@ -161,7 +173,7 @@ export function App() {
           CHAT_SQL,
           (nextMessages) => {
             if (active) {
-              setMessages(nextMessages);
+              setMessages(sortMessages(nextMessages));
             }
           },
           {
@@ -182,7 +194,7 @@ export function App() {
           EVENTS_SQL,
           (nextEvents) => {
             if (active) {
-              setEvents(nextEvents);
+              setEvents(sortEvents(nextEvents));
             }
           },
           {

examples/chat-with-ai/src/App.tsx

@@ -0,0 +1,12 @@
+/// <reference types="vite/client" />
+
+interface ImportMetaEnv {
+  readonly VITE_CHAT_ROOM: string
+  readonly VITE_KALAMDB_URL: string
+  readonly VITE_KALAMDB_USERNAME: string
+  readonly VITE_KALAMDB_PASSWORD: string
+}
+
+interface ImportMeta {
+  readonly env: ImportMetaEnv
+}

examples/chat-with-ai/src/vite-env.d.ts

@@ -18,8 +18,6 @@ type ActivityItem = {
 const FEED_SQL = [
   'SELECT id, service, level, actor, message, created_at',
   'FROM demo.activity_feed',
-  'ORDER BY created_at DESC',
-  'LIMIT 12',
 ].join(' ');
 
 const client = createClient({
@@ -46,6 +44,16 @@ function toActivity(row: RowData): ActivityItem {
   };
 }
 
+function readTimestamp(row: RowData, key: string): number {
+  return row[key]?.asDate()?.getTime() ?? row[key]?.asInt() ?? 0;
+}
+
+function sortRecentActivity(rows: RowData[]): RowData[] {
+  return [...rows]
+    .sort((left, right) => readTimestamp(right, 'created_at') - readTimestamp(left, 'created_at'))
+    .slice(0, 12);
+}
+
 export function App() {
   const [items, setItems] = useState<ActivityItem[]>([]);
   const [status, setStatus] = useState<'loading' | 'live' | 'error'>('loading');
@@ -76,7 +84,7 @@ export function App() {
               return;
             }
 
-            setItems(rows.map(toActivity));
+            setItems(sortRecentActivity(rows).map(toActivity));
             setStatus('live');
           },
           {

examples/simple-typescript/src/App.tsx

@@ -34,13 +34,6 @@ http-body-util = { workspace = true }
 # HTTP Basic Auth encoding
 base64 = { workspace = true }
 
-# Date/time handling for timestamp formatting
-# Minimal features: no serde, no iana-time-zone, no oldtime (saves ~0.3MB)
-chrono = { version = "0.4.44", default-features = false, features = ["clock", "std"] }
-
-# Random number generation for WASM
-getrandom = { version = "0.2", optional = true, features = ["js"] }
-
 # Futures utilities
 futures-util = { workspace = true, default-features = false }
 
@@ -92,7 +85,7 @@ default = ["tokio-runtime"]
 tokio-runtime = ["tokio", "reqwest", "tokio-tungstenite"]
 # Optional HTTP/2 support via reqwest (adds ~1.7MB h2 crate)
 http2 = ["reqwest/http2"]
-wasm = ["wasm-bindgen", "wasm-bindgen-futures", "js-sys", "web-sys", "getrandom", "tsify-next", "serde-wasm-bindgen", "chrono/wasmbind"]
+wasm = ["wasm-bindgen", "wasm-bindgen-futures", "js-sys", "web-sys", "tsify-next", "serde-wasm-bindgen"]
 # End-to-end tests require a running KalamDB server
 e2e-tests = []