release: v0.13.0 — minor release with WebSocket Mint migration, CI fixes, and dependency updates

- Migrate WebSocket client from WebSockex to Mint.WebSocket (IPv6 support for Fly.io)
- Service JWT auth for Core WebSocket endpoint
- Resolve all Clippy warnings (collapsible_if, for_kv_map, needless_borrows)
- Fix incomplete sync transport test assertion
- Remove unused websockex dep from mix.lock
- Bump all service and SDK versions to 0.13.0
- Update Cargo.lock with workspace dependency changes

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: decebal

Cargo.lock

@@ -1,6 +1,6 @@
 [workspace]
 resolver = "3"
-members = ["apps/core", "apps/registry", "tooling/performance", "sdks/rust"]
+members = ["apps/core", "apps/chronon", "apps/registry", "tooling/performance", "sdks/rust"]
 
 [workspace.dependencies]
 
@@ -29,12 +29,14 @@ bytes = "1.11.1"
 
 # Common utilities
 chrono = { version = "0.4", features = ["serde"] }
+clap = { version = "4.5", features = ["derive"] }
 crc32fast = "1.4"
 
 # Dev / Test
 criterion = "0.8"
 crossbeam = "0.8"
 crossbeam-queue = "0.3"
+crossterm = "0.28"
 ctrlc = "3.5"
 
 # Storage & Concurrency
@@ -55,6 +57,7 @@ parking_lot = "0.12"
 parquet = { version = "57.3", features = ["arrow", "async"] }
 prometheus = "0.14"
 rand = "0.10"
+ratatui = "0.29"
 rocksdb = { version = "0.24" }
 
 # Serialization
@@ -64,6 +67,7 @@ sha2 = "0.10"
 simd-json = "0.17"
 sqlx = { version = "0.8", features = ["runtime-tokio-rustls", "postgres", "json", "chrono", "uuid"] }
 tantivy = { version = "0.25" }
+tabled = "0.17"
 tempfile = "3.23"
 thiserror = "2.0"
 time = "0.3.47"

Cargo.toml

@@ -2,7 +2,7 @@
 title: "AllSource Event Store - Monorepo"
 status: CURRENT
 last_updated: 2026-03-01
-version: "0.12.0"
+version: "0.13.0"
 ---
 
 <div align="center">

README.md

@@ -30,7 +30,7 @@ var openAPIYAML []byte
 // Control plane configuration constants.
 const (
 	// Version is the current version of the control plane.
-	Version = "0.12.0"
+	Version = "0.13.0"
 	// DefaultPort is the default port the control plane listens on.
 	DefaultPort = "3901"
 	// CoreServiceURL is the URL of the core event store service.

apps/control-plane/main.go

@@ -19,7 +19,7 @@ import (
 
 const (
 	serviceName    = "allsource-control-plane"
-	serviceVersion = "0.12.0"
+	serviceVersion = "0.13.0"
 )
 
 // TracingConfig holds OpenTelemetry configuration

apps/control-plane/tracing.go

@@ -1,6 +1,6 @@
 [package]
 name = "allsource-core"
-version = "0.12.0"
+version = "0.13.0"
 edition = "2024"
 rust-version = "1.92"
 authors = ["AllSource Team"]

apps/core/Cargo.toml

@@ -489,7 +489,7 @@ impl EmbeddedCore {
             Some(resolver) => {
                 let all_vv = resolver.all_version_vectors();
                 let mut merged = crate::infrastructure::cluster::crdt::VersionVector::new();
-                for (_region, vv) in &all_vv {
+                for vv in all_vv.values() {
                     merged.merge(vv);
                 }
                 merged.entries().clone()
@@ -502,17 +502,16 @@ impl EmbeddedCore {
     ///
     /// Returns `None` if sync is not configured (no `node_id`).
     pub fn region_id(&self) -> Option<String> {
-        self.hlc.as_ref().map(|hlc| format!("node-{}", hlc.node_id()))
+        self.hlc
+            .as_ref()
+            .map(|hlc| format!("node-{}", hlc.node_id()))
     }
 
     /// Receive events from a remote sync push.
     ///
     /// Applies CRDT conflict resolution to each event and ingests
     /// accepted events. Returns `(accepted, skipped)` counts.
-    pub async fn receive_sync_push(
-        &self,
-        events: Vec<ReplicatedEvent>,
-    ) -> Result<(usize, usize)> {
+    pub async fn receive_sync_push(&self, events: Vec<ReplicatedEvent>) -> Result<(usize, usize)> {
         let (Some(_hlc), Some(resolver)) = (&self.hlc, &self.resolver) else {
             return Err(crate::error::AllSourceError::InvalidInput(
                 "sync requires node_id to be configured".to_string(),
@@ -561,13 +560,8 @@ impl EmbeddedCore {
                         .unwrap_or(serde_json::json!({}));
                     let metadata = event_data.get("metadata").cloned();
 
-                    let domain_event = Event::from_strings(
-                        event_type,
-                        entity_id,
-                        tenant_id,
-                        payload,
-                        metadata,
-                    )?;
+                    let domain_event =
+                        Event::from_strings(event_type, entity_id, tenant_id, payload, metadata)?;
                     store.ingest(domain_event)?;
                 }
                 Ok::<(), crate::error::AllSourceError>(())
@@ -587,7 +581,10 @@ impl EmbeddedCore {
     /// newer than the threshold are returned).
     pub async fn events_for_sync(
         &self,
-        since_vv: &std::collections::BTreeMap<String, crate::infrastructure::cluster::hlc::HlcTimestamp>,
+        since_vv: &std::collections::BTreeMap<
+            String,
+            crate::infrastructure::cluster::hlc::HlcTimestamp,
+        >,
     ) -> Result<Vec<ReplicatedEvent>> {
         let Some(hlc) = &self.hlc else {
             return Err(crate::error::AllSourceError::InvalidInput(
@@ -596,11 +593,9 @@ impl EmbeddedCore {
         };
 
         let self_region = format!("node-{}", hlc.node_id());
-        let since = since_vv
-            .get(&self_region)
-            .map(|ts| {
-                chrono::DateTime::from_timestamp_millis(ts.physical_ms as i64).unwrap_or_default()
-            });
+        let since = since_vv.get(&self_region).map(|ts| {
+            chrono::DateTime::from_timestamp_millis(ts.physical_ms as i64).unwrap_or_default()
+        });
 
         let store = Arc::clone(&self.store);
         let all_events = tokio::task::spawn_blocking(move || {

apps/core/src/embedded/core.rs

@@ -28,8 +28,10 @@
 //! # }
 //! ```
 
-use crate::embedded::{EmbeddedCore, IngestEvent};
-use crate::error::Result;
+use crate::{
+    embedded::{EmbeddedCore, IngestEvent},
+    error::Result,
+};
 use serde_json::Value;
 use std::future::Future;
 
@@ -91,12 +93,7 @@ impl<'a> McpToolTracker<'a> {
     ///
     /// On success, emits `mcp.tool.result` with `duration_ms`.
     /// On error, emits `mcp.tool.error` with the error message and `duration_ms`.
-    pub async fn track<F, Fut>(
-        &self,
-        workflow_id: &str,
-        tool_name: &str,
-        f: F,
-    ) -> Result<Value>
+    pub async fn track<F, Fut>(&self, workflow_id: &str, tool_name: &str, f: F) -> Result<Value>
     where
         F: FnOnce() -> Fut,
         Fut: Future<Output = Result<Value>>,

apps/core/src/embedded/mcp_events.rs

@@ -46,10 +46,7 @@ impl SyncClient {
     /// Perform a full bidirectional sync: pull then push.
     ///
     /// Returns aggregate statistics for the sync operation.
-    pub async fn sync(
-        &self,
-        core: &super::core::EmbeddedCore,
-    ) -> Result<SyncStats> {
+    pub async fn sync(&self, core: &super::core::EmbeddedCore) -> Result<SyncStats> {
         let mut stats = SyncStats::default();
 
         // Phase 1: Pull — get events we haven't seen from the server
@@ -66,10 +63,7 @@ impl SyncClient {
     }
 
     /// Pull events from the remote server into the local core.
-    async fn pull(
-        &self,
-        core: &super::core::EmbeddedCore,
-    ) -> Result<SyncStats> {
+    async fn pull(&self, core: &super::core::EmbeddedCore) -> Result<SyncStats> {
         let vv = core.version_vector();
         let request = SyncPullRequest {
             node_id: self.node_id.clone(),
@@ -105,10 +99,7 @@ impl SyncClient {
     }
 
     /// Push local events to the remote server.
-    async fn push(
-        &self,
-        core: &super::core::EmbeddedCore,
-    ) -> Result<SyncStats> {
+    async fn push(&self, core: &super::core::EmbeddedCore) -> Result<SyncStats> {
         // Get the server's version vector first (via a zero-event pull)
         let server_vv = self.fetch_server_version_vector().await?;
 

apps/core/src/embedded/sync_transport.rs

@@ -3,10 +3,7 @@
 //! Used by [`SyncClient`](super::sync_transport::SyncClient) and the
 //! server-side `/api/v1/sync/pull` and `/api/v1/sync/push` endpoints.
 
-use crate::infrastructure::cluster::{
-    crdt::ReplicatedEvent,
-    hlc::HlcTimestamp,
-};
+use crate::infrastructure::cluster::{crdt::ReplicatedEvent, hlc::HlcTimestamp};
 use serde::{Deserialize, Serialize};
 use std::collections::BTreeMap;