Add client properties

Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>

Author: Gsantomaggio

src/client/mod.rs

@@ -200,6 +200,7 @@ pub struct Client {
     tune_notifier: Arc<Notify>,
     publish_sequence: Arc<AtomicU64>,
     filtering_supported: bool,
+    client_properties: HashMap<String, String>,
 }
 
 impl Client {
@@ -227,8 +228,29 @@ impl Client {
             tune_notifier: Arc::new(Notify::new()),
             publish_sequence: Arc::new(AtomicU64::new(1)),
             filtering_supported: false,
+            client_properties: HashMap::new(),
         };
 
+        client
+            .client_properties
+            .insert(String::from("product"), String::from("RabbitMQ"));
+        client
+            .client_properties
+            .insert(String::from("platform"), String::from("Rust"));
+        client.client_properties.insert(
+            String::from("copyright"),
+            String::from("Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term Broadcom refers to Broadcom Inc. and/or its subsidiaries."));
+        client.client_properties.insert(
+            String::from("information"),
+            String::from(
+                "Licensed under the Apache 2.0 and MPL 2.0 licenses. See https://www.rabbitmq.com/",
+            ),
+        );
+        client.client_properties.insert(
+            String::from("connection_name"),
+            client.opts.client_provided_name.clone(),
+        );
+
         client.initialize(receiver).await?;
 
         let command_versions = client.exchange_command_versions().await?;
@@ -676,7 +698,7 @@ impl Client {
 
     async fn peer_properties(&self) -> Result<HashMap<String, String>, ClientError> {
         self.send_and_receive::<PeerPropertiesResponse, _, _>(|correlation_id| {
-            PeerPropertiesCommand::new(correlation_id, HashMap::new())
+            PeerPropertiesCommand::new(correlation_id, self.client_properties.clone())
         })
         .await
         .map(|peer_properties| peer_properties.server_properties)

src/client/options.rs

@@ -15,6 +15,7 @@ pub struct ClientOptions {
     pub(crate) load_balancer_mode: bool,
     pub(crate) tls: TlsConfiguration,
     pub(crate) collector: Arc<dyn MetricsCollector>,
+    pub(crate) client_provided_name: String,
 }
 
 impl Debug for ClientOptions {
@@ -27,6 +28,7 @@ impl Debug for ClientOptions {
             .field("v_host", &self.v_host)
             .field("heartbeat", &self.heartbeat)
             .field("max_frame_size", &self.max_frame_size)
+            .field("client_provided_name", &self.client_provided_name)
             .finish()
     }
 }
@@ -49,6 +51,7 @@ impl Default for ClientOptions {
                 client_certificates_path: String::from(""),
                 client_keys_path: String::from(""),
             },
+            client_provided_name: String::from("rust-stream"),
         }
     }
 }