56 context aware deserializers

[lxsaah]

Added

• Context-Aware Deserializers (Design 026): Inbound connector deserializers can now receive a RuntimeContext<R> for platform-independent timestamps and logging
  • New .with_deserializer(|ctx, bytes| ...) API on InboundConnectorBuilder provides RuntimeContext<R> to deserialization closures
  • New .with_deserializer_raw(|bytes| ...) for plain bytes-only deserialization when context is unnecessary
  • DeserializerKind enum enforces mutual exclusivity between raw and context-aware deserializers
  • Router::route() propagates optional runtime context to context-aware routes
• Design document: 026 (Context-Aware Deserializers)

Changed

• aimdb-core: Breaking API changes to InboundConnectorLink, Router, and RouterBuilder to support DeserializerKind (see aimdb-core/CHANGELOG.md)
• aimdb-mqtt-connector: Updated router dispatch for new route() signature
• aimdb-knx-connector: Updated router dispatch for new route() signature
• aimdb-websocket-connector: Updated router dispatch for new route() signature
• All connector examples updated to use new .with_deserializer(|_ctx, bytes| ...) signature

[Copilot]

Pull request overview

This PR implements Design 026 (Context-Aware Deserializers), extending inbound connector deserialization so it can optionally receive a RuntimeContext<R> (for platform-independent time + logging) while retaining a raw bytes-only deserializer escape hatch.

Changes:

• Adds DeserializerKind (Raw / Context) and updates routing/link plumbing to store and dispatch the appropriate deserializer variant.
• Introduces .with_deserializer(|ctx, bytes| ...) (context-aware) and .with_deserializer_raw(|bytes| ...) (bytes-only) on InboundConnectorBuilder.
• Updates connectors, tests, examples, and changelogs for the new API + Router::route(..., ctx) signature.

Reviewed changes

Copilot reviewed 24 out of 25 changed files in this pull request and generated 10 comments.

Show a summary per file

File	Description
examples/weather-mesh-demo/weather-hub/src/main.rs	Updates example deserializers to new `
examples/tokio-mqtt-connector-demo/src/main.rs	Updates example deserializers to new context-aware closure signature.
examples/tokio-knx-connector-demo/src/main.rs	Updates example deserializers to accept _ctx.
examples/embassy-mqtt-connector-demo/src/main.rs	Updates example deserializers to accept _ctx.
examples/embassy-knx-connector-demo/src/main.rs	Updates example deserializers to accept _ctx.
docs/design/026-context-aware-deserializers.md	Adds the design document describing the new API and plumbing.
CHANGELOG.md	Documents the new feature and breaking changes at the repo level.
Cargo.lock	Updates stm32-metapac git source reference.
aimdb-websocket-connector/src/session.rs	Updates Router::route() call to new signature (currently passes None).
aimdb-websocket-connector/src/client/connector.rs	Updates Router::route() call to new signature (currently passes None).
aimdb-websocket-connector/CHANGELOG.md	Notes the router signature update.
aimdb-mqtt-connector/tests/topic_provider_tests.rs	Updates test deserializer closure to accept _ctx.
aimdb-mqtt-connector/src/tokio_client.rs	Updates router dispatch signature (currently passes None).
aimdb-mqtt-connector/src/embassy_client.rs	Updates router dispatch signature (currently passes None).
aimdb-mqtt-connector/CHANGELOG.md	Notes the router signature update.
aimdb-knx-connector/tests/topic_provider_tests.rs	Updates test deserializer closure to accept _ctx.
aimdb-knx-connector/src/tokio_client.rs	Updates router dispatch signature (currently passes None).
aimdb-knx-connector/src/embassy_client.rs	Updates router dispatch signature (currently passes None).
aimdb-knx-connector/CHANGELOG.md	Notes the router signature update.
aimdb-core/src/typed_api.rs	Adds with_deserializer_raw, adds context-aware with_deserializer, and resolves DeserializerKind in finish().
aimdb-core/src/router.rs	Routes via DeserializerKind and adds optional runtime context parameter to route(), plus new tests.
aimdb-core/src/connector.rs	Introduces ContextDeserializerFn + DeserializerKind, updates InboundConnectorLink to store DeserializerKind.
aimdb-core/src/builder.rs	Updates collect_inbound_routes() return type to include DeserializerKind.
aimdb-core/CHANGELOG.md	Documents the new feature and breaking API changes in core.

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[Copilot]

Pull request overview

Copilot reviewed 35 out of 36 changed files in this pull request and generated 4 comments.

Comments suppressed due to low confidence (1)

aimdb-websocket-connector/src/lib.rs:58

• The doc example in the client quick start still uses the old bytes-only .with_deserializer(|data| ...) signature. After this PR, .with_deserializer expects a (ctx, bytes) closure, so this example will not compile as written; update it to |_ctx, data| or switch to .with_deserializer_raw(|data| ...) depending on which behavior you want to demonstrate.

//!         reg.buffer(BufferCfg::SpmcRing { capacity: 100 })
//!             .link_to("ws-client://sensors/temp")
//!             .with_serializer_raw(|t| serde_json::to_vec(t).map_err(Into::into))
//!             .finish()
//!             .link_from("ws-client://config/threshold")
//!             .with_deserializer(|data| serde_json::from_slice(data))
//!             .finish();

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.