refactor(e2e): improve the e2e-test

Restructure the code and use the channels to talk with Astarte.

Signed-off-by: Joshua Chapman <joshua.chapman@secomind.com>

Author: joshuachp

Cargo.lock

@@ -137,6 +137,7 @@ base64 = "0.22.0"
 bson = "2.7.0"
 bytes = "1.5.0"
 chrono = "0.4.20"
+clap = "4.5.32"
 color-eyre = "0.6.3"
 env_logger = "0.11.0"
 eyre = "0.6.12"
@@ -148,6 +149,7 @@ itertools = "0.11.0"
 mockall = "0.12.1"
 mockito = "1.4.0"
 openssl = "0.10.46"
+phoenix-chan = "0.4.1"
 pretty_assertions = "1.4.1"
 proc-macro2 = "1.0.83"
 quote = "1.0.35"

Cargo.toml

@@ -31,13 +31,21 @@ rust-version = { workspace = true }
 [dependencies]
 astarte-device-sdk = { workspace = true, features = ["derive"] }
 base64 = { workspace = true }
-chrono = { workspace = true }
+chrono = { workspace = true, features = ["serde"] }
+clap = { workspace = true, features = ["derive", "env"] }
 color-eyre = { workspace = true }
 eyre = { workspace = true }
+flume = { workspace = true, features = ["async"] }
+futures = { workspace = true }
 itertools = { workspace = true }
+phoenix-chan = { workspace = true }
 reqwest = { workspace = true }
 rustls = { workspace = true }
+serde = { workspace = true, features = ["derive"] }
 serde_json = { workspace = true }
 tokio = { workspace = true, features = ["full"] }
 tracing = { workspace = true }
 tracing-subscriber = { workspace = true, features = ["env-filter"] }
+
+[dev-dependencies]
+pretty_assertions = { workspace = true }