Introduce the device scheme

Cargo.toml

@@ -5,7 +5,7 @@ members = ["crates/*", "examples/*"]
 exclude = ["crates/tosca-esp32c3"]
 
 [workspace.package]
-version = "0.1.1"
+version = "0.2.0"
 authors = ["Michele Valsesia <michele.valsesia@toscalabs.org>"]
 description = "A versatile, customizable, and secure IoT framework."
 edition = "2024"
@@ -18,10 +18,10 @@ rust-version = "1.90"
 readme = "README.md"
 
 [workspace.dependencies]
-tosca = { version = "0.1.1", path = "crates/tosca", default-features = false }
-tosca-os = { version = "0.1.1", path = "crates/tosca-os", default-features = false }
-tosca-drivers = { version = "0.1.1", path = "crates/tosca-drivers", default-features = false }
-tosca-controller = { version = "0.1.1", path = "crates/tosca-controller" }
+tosca = { version = "0.2.0", path = "crates/tosca", default-features = false }
+tosca-os = { version = "0.2.0", path = "crates/tosca-os", default-features = false }
+tosca-drivers = { version = "0.2.0", path = "crates/tosca-drivers", default-features = false }
+tosca-controller = { version = "0.2.0", path = "crates/tosca-controller" }
 
 hashbrown = { version = "0.17", default-features = false, features = ["default-hasher"] }
 indexmap = { version = "2.12", default-features = false }

crates/tosca-controller/src/controller.rs

@@ -50,7 +50,7 @@ impl RequestSender<'_> {
     /// and affect the returned response as well.
     pub async fn send_with_parameters(
         &self,
-        parameters: &ParametersValues<'_>,
+        parameters: &ParametersValues,
     ) -> Result<Response, Error> {
         if self.request.parameters_data.is_empty() {
             warn!("The request does not have input parameters.");
@@ -349,9 +349,9 @@ mod tests {
     use crate::policy::Policy;
     use crate::response::Response;
 
-    use crate::device::tests::{create_light, create_unknown};
+    use crate::device::tests::{create_custom_device, create_light};
     use crate::discovery::tests::configure_discovery;
-    use crate::tests::{Brightness, check_function_with_device};
+    use crate::tests::{Brightness, light_with_toggle, run_one_device};
 
     use super::{Controller, DeviceSender, RequestSender, sender_error};
 
@@ -374,15 +374,15 @@ mod tests {
 
     #[test]
     fn controller_from_devices() {
-        let devices = Devices::from_devices(vec![create_light(), create_unknown()]);
+        let devices = Devices::from_devices(vec![create_light(), create_custom_device()]);
 
         let controller = Controller::from_devices(configure_discovery(), devices);
 
         assert_eq!(
             controller,
             Controller {
                 discovery: configure_discovery(),
-                devices: Devices::from_devices(vec![create_light(), create_unknown()]),
+                devices: Devices::from_devices(vec![create_light(), create_custom_device()]),
                 privacy_policy: Policy::init(),
             }
         );
@@ -398,7 +398,7 @@ mod tests {
     async fn check_ok_response_with_parameters(
         device_sender: &DeviceSender<'_>,
         route: &str,
-        parameters: &ParametersValues<'_>,
+        parameters: &ParametersValues,
     ) {
         check_ok_response(device_sender, route, async move |request_sender| {
             request_sender.send_with_parameters(parameters).await
@@ -447,7 +447,7 @@ mod tests {
     >(
         device_sender: &DeviceSender<'_>,
         route: &str,
-        parameters: &ParametersValues<'_>,
+        parameters: &ParametersValues,
         value: T,
     ) {
         check_serial_response(
@@ -573,7 +573,7 @@ mod tests {
     }
 
     #[inline]
-    async fn run_controller_function<F, Fut>(name: &str, function: F)
+    async fn controller_test<F, Fut>(name: &str, function: F)
     where
         F: FnOnce() -> Fut,
         Fut: Future<Output = ()>,
@@ -584,17 +584,22 @@ mod tests {
                 name
             );
         } else {
-            check_function_with_device(|| async {
-                function().await;
-            })
+            run_one_device(
+                |close_rx| async {
+                    light_with_toggle(close_rx).await;
+                },
+                || async {
+                    function().await;
+                },
+            )
             .await;
         }
     }
 
     #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
     #[serial]
     async fn test_without_policy_controller() {
-        run_controller_function("controller_without_policy", || async {
+        controller_test("controller_without_policy", || async {
             controller_without_policy().await;
         })
         .await;
@@ -603,7 +608,7 @@ mod tests {
     #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
     #[serial]
     async fn test_with_policy_controller() {
-        run_controller_function("controller_with_policy", || async {
+        controller_test("controller_with_policy", || async {
             controller_with_policy().await;
         })
         .await;