79 extensible streamable registry remove closed dispatcher add builder registration (#80)

* feat: update aimdb-data-contracts version and enhance schema registration

- Updated aimdb-data-contracts dependency version to 0.1.0 in Cargo.toml.
- Refactored WasmDb to use a new registration method for Streamable types, allowing runtime dispatch.
- Introduced a new StreamableRegistry for managing schema types in the WebSocket connector.
- Added support for registering Streamable types in the WebSocketConnectorBuilder.
- Implemented new data contracts for humidity and GPS location, including simulation and observability features.
- Enhanced temperature schema with versioning and migration support for backward compatibility.
- Added tests for the new StreamableRegistry and its functionalities.

* feat: enhance WebSocketConnector registration examples and update weather station dependencies

* feat: update embassy dependencies to latest versions and adjust features in examples

* feat: update stm32-metapac source to use git repository and update embassy submodule

* fix: update TemperatureV1 schema name for consistency

* feat: update dependencies in Cargo.toml files to use specific versions

* feat: enhance StreamableRegistry to handle schema name collisions and update WebSocketConnectorBuilder registration

* fix: update comments in builder and registry for clarity on type handling

* chore: update embassy submodule to latest commit

* chore: update embassy submodule to latest commit

Author: lxsaah

Cargo.lock

@@ -85,7 +85,7 @@ tokio-test = "0.4"
 aimdb-tokio-adapter = { path = "./aimdb-tokio-adapter" }
 
 # Embassy ecosystem for embedded async
-embassy-stm32 = { version = "0.5.0", path = "./_external/embassy/embassy-stm32", features = [
+embassy-stm32 = { version = "0.6.0", path = "./_external/embassy/embassy-stm32", features = [
     "defmt",
     "stm32h563zi",
     "memory-x",
@@ -94,27 +94,27 @@ embassy-stm32 = { version = "0.5.0", path = "./_external/embassy/embassy-stm32",
     "unstable-pac",
     "low-power",
 ] }
-embassy-sync = { version = "0.7.2", path = "./_external/embassy/embassy-sync", features = [
+embassy-sync = { version = "0.8.0", path = "./_external/embassy/embassy-sync", features = [
     "defmt",
 ] }
-embassy-executor = { version = "0.9.1", path = "./_external/embassy/embassy-executor", features = [
-    "arch-cortex-m",
+embassy-executor = { version = "0.10.0", path = "./_external/embassy/embassy-executor", features = [
+    "platform-cortex-m",
     "executor-thread",
     "defmt",
 ] }
-embassy-time = { version = "0.5.0", path = "./_external/embassy/embassy-time", features = [
+embassy-time = { version = "0.5.1", path = "./_external/embassy/embassy-time", features = [
     "defmt",
     "defmt-timestamp-uptime",
     "tick-hz-32_768",
 ] }
-embassy-net = { version = "0.8.0", path = "./_external/embassy/embassy-net", features = [
+embassy-net = { version = "0.9.0", path = "./_external/embassy/embassy-net", features = [
     "defmt",
     "tcp",
     "dhcpv4",
     "medium-ethernet",
     "proto-ipv6",
 ] }
-embassy-usb = { version = "0.5.1", path = "./_external/embassy/embassy-usb", features = [
+embassy-usb = { version = "0.6.0", path = "./_external/embassy/embassy-usb", features = [
     "defmt",
 ] }
 embassy-futures = { version = "0.1.2", path = "./_external/embassy/embassy-futures" }

Cargo.toml

@@ -332,73 +332,77 @@ publish:
 	else \
 		printf "$(BLUE)Running in CI mode - skipping confirmation$(NC)\n"; \
 	fi
-	@printf "$(YELLOW)  → Publishing aimdb-executor (1/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-executor (1/18)$(NC)\n"
 	@cargo publish -p aimdb-executor
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-derive (2/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-derive (2/18)$(NC)\n"
 	@cargo publish -p aimdb-derive
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-codegen (3/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-codegen (3/18)$(NC)\n"
 	@cargo publish -p aimdb-codegen
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-core (4/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-core (4/18)$(NC)\n"
 	@cargo publish -p aimdb-core
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-tokio-adapter (5/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-data-contracts (5/18)$(NC)\n"
+	@cargo publish -p aimdb-data-contracts
+	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
+	@sleep 10
+	@printf "$(YELLOW)  → Publishing aimdb-tokio-adapter (6/18)$(NC)\n"
 	@cargo publish -p aimdb-tokio-adapter
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-embassy-adapter (6/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-embassy-adapter (7/18)$(NC)\n"
 	@cargo publish -p aimdb-embassy-adapter --no-verify
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-client (7/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-client (8/18)$(NC)\n"
 	@cargo publish -p aimdb-client
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-sync (8/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-sync (9/18)$(NC)\n"
 	@cargo publish -p aimdb-sync
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-persistence (9/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-persistence (10/18)$(NC)\n"
 	@cargo publish -p aimdb-persistence
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-persistence-sqlite (10/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-persistence-sqlite (11/18)$(NC)\n"
 	@cargo publish -p aimdb-persistence-sqlite
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-mqtt-connector (11/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-mqtt-connector (12/18)$(NC)\n"
 	@cargo publish -p aimdb-mqtt-connector
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-knx-connector (12/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-knx-connector (13/18)$(NC)\n"
 	@cargo publish -p aimdb-knx-connector
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-ws-protocol (13/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-ws-protocol (14/18)$(NC)\n"
 	@cargo publish -p aimdb-ws-protocol
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-websocket-connector (14/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-websocket-connector (15/18)$(NC)\n"
 	@cargo publish -p aimdb-websocket-connector
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-wasm-adapter (15/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-wasm-adapter (16/18)$(NC)\n"
 	@cargo publish -p aimdb-wasm-adapter --no-verify
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-cli (16/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-cli (17/18)$(NC)\n"
 	@cargo publish -p aimdb-cli
 	@printf "$(YELLOW)  → Waiting 10s for crates.io propagation...$(NC)\n"
 	@sleep 10
-	@printf "$(YELLOW)  → Publishing aimdb-mcp (17/17)$(NC)\n"
+	@printf "$(YELLOW)  → Publishing aimdb-mcp (18/18)$(NC)\n"
 	@cargo publish -p aimdb-mcp
-	@printf "$(GREEN)✓ All 17 crates published successfully!$(NC)\n"
+	@printf "$(GREEN)✓ All 18 crates published successfully!$(NC)\n"
 	@printf "$(BLUE)🎉 AimDB v$(shell grep '^version' Cargo.toml | head -1 | cut -d '"' -f 2) is now live on crates.io!$(NC)\n"
 
 ## Convenience commands

Makefile

@@ -1,12 +1,12 @@
 [package]
 name = "aimdb-data-contracts"
-version.workspace = true
+version = "0.1.0"
 edition.workspace = true
 authors.workspace = true
 license.workspace = true
 repository.workspace = true
 homepage.workspace = true
-description = "Data contracts for AimDB: portable schemas with built-in versioning and simulation support"
+description = "Trait definitions for AimDB data contracts: SchemaType, Streamable, Observable, Linkable, Simulatable, Migratable"
 keywords = ["aimdb", "iot", "edge", "schema", "contracts"]
 categories = ["embedded", "no-std"]
 
@@ -18,28 +18,23 @@ linkable = ["alloc", "serde_json"]
 simulatable = ["rand"]
 migratable = ["std", "serde_json"]
 observable = ["alloc", "aimdb-core", "aimdb-executor"]
-ts = ["std", "ts-rs"]
 
 [dependencies]
 serde = { version = "1.0", default-features = false, features = ["derive"] }
 serde_json = { version = "1.0", optional = true }
 
 # Optional dependencies for observable feature (log_tap function)
 # Note: aimdb-core requires alloc feature for core functionality
-aimdb-core = { path = "../aimdb-core", optional = true, default-features = false, features = [
+aimdb-core = { version = "1.0.0", path = "../aimdb-core", optional = true, default-features = false, features = [
     "alloc",
 ] }
-aimdb-executor = { path = "../aimdb-executor", optional = true, default-features = false }
+aimdb-executor = { version = "0.1.0", path = "../aimdb-executor", optional = true, default-features = false }
 
 [dependencies.rand]
 version = "0.8"
 optional = true
 default-features = false
 features = ["std_rng"]
 
-[dependencies.ts-rs]
-version = "10"
-optional = true
-
 [dev-dependencies]
 serde_json = "1.0"