Refactor grpc test

Reworked to make use of the mock exported by the astarte message hub proto

Signed-off-by: Luca Arato <luca.arato@secomind.com>

Author: lucaato

Cargo.lock

@@ -80,6 +80,7 @@ uuid = { workspace = true, features = ["v4", "v5"] }
 
 [dev-dependencies]
 astarte-device-sdk-derive = { workspace = true }
+astarte-message-hub-proto = { workspace = true, features = ["mock"] }
 async-trait = { workspace = true }
 color-eyre = { workspace = true }
 env_logger = { workspace = true }
@@ -107,7 +108,7 @@ rustc-args = ["--cfg=docsrs"]
 [workspace.dependencies]
 astarte-device-sdk = { path = "./", version = "=0.9.3" }
 astarte-device-sdk-derive = { version = "=0.9.3", path = "./astarte-device-sdk-derive" }
-astarte-message-hub-proto = { git = "https://github.com/astarte-platform/astarte-message-hub-proto.git", rev = "370be08ff90236a25b15af6e27d5363739566f2f" }
+astarte-message-hub-proto = { git = "https://github.com/lucaato/astarte-message-hub-proto.git", rev = "3f866059d2f788646ffe91973d01216bcf40d29a" }
 async-trait = "0.1.67"
 base64 = "0.22.0"
 bson = "2.7.0"

Cargo.toml

@@ -108,6 +108,9 @@ mod test {
     pub(crate) const E2E_DEVICE_DATASTREAM: &str = include_str!(
         "../e2e-test/interfaces/org.astarte-platform.rust.e2etest.DeviceDatastream.json"
     );
+    pub(crate) const E2E_SERVER_DATASTREAM: &str = include_str!(
+        "../e2e-test/interfaces/org.astarte-platform.rust.e2etest.ServerAggregate.json"
+    );
     pub(crate) const E2E_DEVICE_AGGREGATE: &str = include_str!(
         "../e2e-test/interfaces/org.astarte-platform.rust.e2etest.DeviceAggregate.json"
     );