feat: update dependencies and remove alloc feature checks across the codebase

Author: lxsaah

Cargo.lock

@@ -277,10 +277,14 @@ examples:
 	@printf "$(GREEN)Building all example projects...$(NC)\n"
 	@printf "$(YELLOW)  → Building sync-api-demo (synchronous API wrapper)$(NC)\n"
 	cargo build --package sync-api-demo
+	@printf "$(YELLOW)  → Building mqtt-connector-demo-common (shared MQTT demo code, runtime-agnostic)$(NC)\n"
+	cargo build --package mqtt-connector-demo-common
 	@printf "$(YELLOW)  → Building tokio-mqtt-connector-demo (native, tokio runtime)$(NC)\n"
 	cargo build --package tokio-mqtt-connector-demo
 	@printf "$(YELLOW)  → Building embassy-mqtt-connector-demo (embedded, embassy runtime)$(NC)\n"
 	cargo build --package embassy-mqtt-connector-demo --target thumbv7em-none-eabihf
+	@printf "$(YELLOW)  → Building knx-connector-demo-common (shared KNX demo code, runtime-agnostic)$(NC)\n"
+	cargo build --package knx-connector-demo-common
 	@printf "$(YELLOW)  → Building tokio-knx-connector-demo (native, tokio runtime)$(NC)\n"
 	cargo build --package tokio-knx-connector-demo
 	@printf "$(YELLOW)  → Building embassy-knx-connector-demo (embedded, embassy runtime)$(NC)\n"

Makefile

@@ -15,7 +15,7 @@ use hashbrown::HashMap;
 #[cfg(not(feature = "std"))]
 use alloc::{boxed::Box, sync::Arc};
 
-#[cfg(all(not(feature = "std"), feature = "alloc"))]
+#[cfg(not(feature = "std"))]
 use alloc::string::{String, ToString};
 
 #[cfg(feature = "std")]
@@ -54,7 +54,6 @@ use crate::{DbError, DbResult};
 /// - `SerializerKind` - User-provided serializer for the record type (raw or context-aware)
 /// - `Vec<(String, String)>` - Configuration options from the URL query
 /// - `Option<TopicProviderFn>` - Optional dynamic topic provider
-#[cfg(feature = "alloc")]
 pub type OutboundRoute = (
     String,
     Box<dyn crate::connector::ConsumerTrait>,
@@ -579,7 +578,6 @@ where
         let mut reg = RecordRegistrar {
             rec,
             connector_builders: &self.connector_builders,
-            #[cfg(feature = "alloc")]
             record_key: record_key.as_str().to_string(),
             extensions: &self.extensions,
             last_stage: None,
@@ -1499,7 +1497,6 @@ impl<R: aimdb_executor::RuntimeAdapter + 'static> AimDb<R> {
     /// let router = RouterBuilder::from_routes(routes).build();
     /// connector.set_router(router).await?;
     /// ```
-    #[cfg(feature = "alloc")]
     pub fn collect_inbound_routes(
         &self,
         scheme: &str,
@@ -1577,7 +1574,6 @@ impl<R: aimdb_executor::RuntimeAdapter + 'static> AimDb<R> {
     ///
     /// The returned TypeId is the `TypeId::of::<T>()` for the record type `T`
     /// that was used in the corresponding `configure::<T>()` call.
-    #[cfg(feature = "alloc")]
     pub fn collect_outbound_topic_type_ids(&self, scheme: &str) -> Vec<(String, TypeId)> {
         let mut result = Vec::new();
 
@@ -1595,7 +1591,6 @@ impl<R: aimdb_executor::RuntimeAdapter + 'static> AimDb<R> {
         result
     }
 
-    #[cfg(feature = "alloc")]
     pub fn collect_outbound_routes(&self, scheme: &str) -> Vec<OutboundRoute> {
         let mut routes = Vec::new();
 

_external/embassy

@@ -480,7 +480,6 @@ pub struct ConnectorLink {
     /// Mirrors the producer_factory pattern used for inbound connectors.
     ///
     /// Available in both `std` and `no_std + alloc` environments.
-    #[cfg(feature = "alloc")]
     pub consumer_factory: Option<ConsumerFactoryFn>,
 
     /// Optional dynamic topic provider
@@ -507,10 +506,7 @@ impl Debug for ConnectorLink {
             )
             .field(
                 "consumer_factory",
-                #[cfg(feature = "alloc")]
                 &self.consumer_factory.as_ref().map(|_| "<function>"),
-                #[cfg(not(feature = "alloc"))]
-                &None::<()>,
             )
             .field(
                 "topic_provider",
@@ -527,7 +523,6 @@ impl ConnectorLink {
             url,
             config: Vec::new(),
             serializer: None,
-            #[cfg(feature = "alloc")]
             consumer_factory: None,
             topic_provider: None,
         }
@@ -547,7 +542,6 @@ impl ConnectorLink {
     /// Returns None if no factory is configured.
     ///
     /// Available in both `std` and `no_std + alloc` environments.
-    #[cfg(feature = "alloc")]
     pub fn create_consumer(
         &self,
         db_any: Arc<dyn core::any::Any + Send + Sync>,
@@ -598,7 +592,6 @@ pub enum DeserializerKind {
 /// the factory in a type-erased InboundConnectorLink.
 ///
 /// Available in both `std` and `no_std + alloc` environments.
-#[cfg(feature = "alloc")]
 pub type ProducerFactoryFn =
     Arc<dyn Fn(Arc<dyn core::any::Any + Send + Sync>) -> Box<dyn ProducerTrait> + Send + Sync>;
 
@@ -651,7 +644,6 @@ pub trait ProducerTrait: Send + Sync {
 /// Mirrors the ProducerFactoryFn pattern for symmetry between inbound and outbound.
 ///
 /// Available in both `std` and `no_std + alloc` environments.
-#[cfg(feature = "alloc")]
 pub type ConsumerFactoryFn =
     Arc<dyn Fn(Arc<dyn core::any::Any + Send + Sync>) -> Box<dyn ConsumerTrait> + Send + Sync>;
 
@@ -719,7 +711,6 @@ pub struct InboundConnectorLink {
     /// Captures the record type T at link_from() call time.
     ///
     /// Available in both `std` and `no_std + alloc` environments.
-    #[cfg(feature = "alloc")]
     pub producer_factory: Option<ProducerFactoryFn>,
 
     /// Optional dynamic topic resolver (late-binding)
@@ -737,7 +728,6 @@ impl Clone for InboundConnectorLink {
             url: self.url.clone(),
             config: self.config.clone(),
             deserializer: self.deserializer.clone(),
-            #[cfg(feature = "alloc")]
             producer_factory: self.producer_factory.clone(),
             topic_resolver: self.topic_resolver.clone(),
         }
@@ -765,16 +755,14 @@ impl InboundConnectorLink {
             url,
             config: Vec::new(),
             deserializer,
-            #[cfg(feature = "alloc")]
             producer_factory: None,
             topic_resolver: None,
         }
     }
 
-    /// Sets the producer factory callback (alloc feature)
+    /// Sets the producer factory callback.
     ///
     /// Available in both `std` and `no_std + alloc` environments.
-    #[cfg(feature = "alloc")]
     pub fn with_producer_factory<F>(mut self, factory: F) -> Self
     where
         F: Fn(Arc<dyn core::any::Any + Send + Sync>) -> Box<dyn ProducerTrait>
@@ -786,10 +774,9 @@ impl InboundConnectorLink {
         self
     }
 
-    /// Creates a producer using the stored factory (alloc feature)
+    /// Creates a producer using the stored factory.
     ///
     /// Available in both `std` and `no_std + alloc` environments.
-    #[cfg(feature = "alloc")]
     pub fn create_producer(
         &self,
         db_any: Arc<dyn core::any::Any + Send + Sync>,

aimdb-core/src/builder.rs

@@ -16,7 +16,6 @@
 
 #![cfg_attr(not(feature = "std"), no_std)]
 
-#[cfg(feature = "alloc")]
 extern crate alloc;
 
 pub mod buffer;
@@ -74,7 +73,6 @@ pub use aimdb_executor::{
 pub use database::Database;
 
 // Producer-Consumer Pattern exports
-#[cfg(feature = "alloc")]
 pub use builder::OutboundRoute;
 pub use builder::{AimDb, AimDbBuilder};
 pub use connector::ConnectorBuilder;
@@ -101,6 +99,5 @@ pub use record_id::{RecordId, RecordKey, StringKey};
 pub use graph::{DependencyGraph, EdgeType, GraphEdge, GraphNode, RecordGraphInfo, RecordOrigin};
 
 // Transform API exports
-#[cfg(feature = "alloc")]
 pub use transform::{JoinBuilder, JoinEventRx, JoinPipeline, JoinTrigger};
 pub use transform::{TransformBuilder, TransformPipeline};

aimdb-core/src/connector.rs

@@ -114,7 +114,6 @@ impl<R: JoinReceiver<JoinTrigger> + Send> DynJoinRx for R {
 // ============================================================================
 
 /// Type-erased factory for creating a forwarder task for one join input.
-#[cfg(feature = "alloc")]
 type JoinInputFactory<R> = Box<
     dyn FnOnce(
             Arc<crate::AimDb<R>>,
@@ -133,13 +132,11 @@ type JoinInputFactory<R> = Box<
 /// internal constant chosen per adapter (Tokio: 64, Embassy: 8, WASM: 64).
 ///
 /// Obtain via [`RecordRegistrar::transform_join`].
-#[cfg(feature = "alloc")]
 pub struct JoinBuilder<O, R: JoinFanInRuntime + 'static> {
     inputs: Vec<(String, JoinInputFactory<R>)>,
     _phantom: PhantomData<(O, R)>,
 }
 
-#[cfg(feature = "alloc")]
 impl<O, R> JoinBuilder<O, R>
 where
     O: Send + Sync + Clone + Debug + 'static,
@@ -245,12 +242,10 @@ where
 ///
 /// Produced by [`JoinBuilder::on_triggers`] and consumed by
 /// [`RecordRegistrar::transform_join`]. Not normally constructed directly.
-#[cfg(feature = "alloc")]
 pub struct JoinPipeline<O: Send + Sync + Clone + Debug + 'static, R: JoinFanInRuntime + 'static> {
     pub(crate) spawn_factory: Box<dyn FnOnce(()) -> TransformDescriptor<O, R> + Send>,
 }
 
-#[cfg(feature = "alloc")]
 impl<O, R> JoinPipeline<O, R>
 where
     O: Send + Sync + Clone + Debug + 'static,
@@ -265,7 +260,6 @@ where
 // Join Transform Build (forwarders + handler future, both collected at build time)
 // ============================================================================
 
-#[cfg(feature = "alloc")]
 #[allow(unused_variables)]
 fn build_join_collected<O, R, F, Fut>(
     db: Arc<crate::AimDb<R>>,

aimdb-core/src/lib.rs

@@ -22,7 +22,6 @@ pub mod single;
 // Public re-exports
 pub use single::{StatefulTransformBuilder, TransformBuilder, TransformPipeline};
 
-#[cfg(feature = "alloc")]
 pub use join::{JoinBuilder, JoinEventRx, JoinPipeline, JoinTrigger};
 
 // ============================================================================

aimdb-core/src/transform/join.rs

@@ -548,7 +548,6 @@ where
     /// Register a multi-input join transform (low-level API).
     ///
     /// Panics if a `.source()` or another `.transform()` is already registered.
-    #[cfg(feature = "alloc")]
     pub fn transform_join_raw<F>(&'a mut self, build_fn: F) -> &'a mut Self
     where
         R: aimdb_executor::JoinFanInRuntime,
@@ -567,7 +566,6 @@ where
     /// Derives this record from multiple input records. Available on any runtime
     /// that implements `JoinFanInRuntime`. Panics if a `.source()` or another
     /// `.transform()` is already registered.
-    #[cfg(feature = "alloc")]
     pub fn transform_join<F>(&'a mut self, build_fn: F) -> &'a mut Self
     where
         R: aimdb_executor::JoinFanInRuntime,

aimdb-core/src/transform/mod.rs

@@ -20,8 +20,7 @@ extern crate alloc;
 #[cfg(not(feature = "std"))]
 use alloc::{boxed::Box, sync::Arc, vec::Vec};
 
-// ToString is only needed when alloc is enabled (for record_key.to_string())
-#[cfg(all(not(feature = "std"), feature = "alloc"))]
+#[cfg(not(feature = "std"))]
 use alloc::string::ToString;
 
 #[cfg(feature = "std")]