added option to set client name on cli clients

worterbuch-cli/src/bin/wbdel.rs

@@ -48,6 +48,9 @@ struct Args {
     /// Print only the value of the deleted key/value pair
     #[arg(short, long)]
     raw: bool,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -86,6 +89,9 @@ async fn wbdel(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut trans_id = 0;

worterbuch-cli/src/bin/wbget.rs

@@ -51,6 +51,9 @@ struct Args {
     /// Print only the value of the specified key
     #[arg(short, long)]
     raw: bool,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -89,6 +92,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut trans_id = 0;

worterbuch-cli/src/bin/wbls.rs

@@ -48,6 +48,9 @@ struct Args {
     /// Auth token to be used for acquiring authorization from the server
     #[arg(long)]
     auth: Option<AuthToken>,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -85,6 +88,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let trans_id = wb.ls_async(parent).await?;

worterbuch-cli/src/bin/wblssub.rs

@@ -48,6 +48,9 @@ struct Args {
     /// Auth token to be used for acquiring authorization from the server
     #[arg(long)]
     auth: Option<AuthToken>,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -85,6 +88,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut rx = provide_keys(paths, subsys.clone());

worterbuch-cli/src/bin/wbpdel.rs

@@ -51,6 +51,9 @@ struct Args {
     /// Print only the deleted key/value pairs
     #[arg(short, long)]
     raw: bool,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 #[tokio::main(flavor = "current_thread")]
 async fn main() -> Result<()> {
@@ -88,6 +91,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut trans_id = 0;

worterbuch-cli/src/bin/wbpget.rs

@@ -51,6 +51,9 @@ struct Args {
     /// Print only the received key/value pairs
     #[arg(short, long)]
     raw: bool,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -89,6 +92,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut trans_id = 0;

worterbuch-cli/src/bin/wbpsub.rs

@@ -57,6 +57,9 @@ struct Args {
     /// Print only the received events
     #[arg(short, long)]
     raw: bool,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -97,6 +100,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut rx = provide_keys(patterns, subsys.clone());

worterbuch-cli/src/bin/wbpub.rs

@@ -48,6 +48,9 @@ struct Args {
     /// Auth token to be used for acquiring authorization from the server
     #[arg(long)]
     auth: Option<AuthToken>,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -85,6 +88,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut trans_id = 0;

worterbuch-cli/src/bin/wbpubs.rs

@@ -48,6 +48,9 @@ struct Args {
     /// Auth token to be used for acquiring authorization from the server
     #[arg(long)]
     auth: Option<AuthToken>,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -85,6 +88,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut trans_id = 0;

worterbuch-cli/src/bin/wbset.rs

@@ -48,6 +48,9 @@ struct Args {
     /// Auth token to be used for acquiring authorization from the server
     #[arg(long)]
     auth: Option<AuthToken>,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -85,6 +88,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut trans_id = 0;

worterbuch-cli/src/bin/wbsets.rs

@@ -48,6 +48,9 @@ struct Args {
     /// Auth token to be used for acquiring authorization from the server
     #[arg(long)]
     auth: Option<AuthToken>,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -85,6 +88,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut trans_id = 0;

worterbuch-cli/src/bin/wbsub.rs

@@ -57,6 +57,9 @@ struct Args {
     /// Print only the received events
     #[arg(short, long)]
     raw: bool,
+    /// Set a client name on the server
+    #[arg(short, long)]
+    name: Option<String>,
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -97,6 +100,9 @@ async fn run(subsys: SubsystemHandle) -> Result<()> {
     };
 
     let wb = connect(config, on_disconnect).await?;
+    if let Some(name) = args.name {
+        wb.set_client_name(name).await?;
+    }
     let mut responses = wb.all_messages().await?;
 
     let mut rx = provide_keys(keys, subsys.clone());