refactor!: adds a port override to the client setup

README.md

@@ -62,12 +62,14 @@ Here's a basic example to create a client:
 use dapr;
 
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    // Get the Dapr port and create a connection
-    let port: u16 = std::env::var("DAPR_GRPC_PORT")?.parse()?;
-    let addr = format!("https://127.0.0.1:{}", port);
+    // Dapr GRPC Address
+    let addr = "https://127.0.0.1";
+
+    // Dapr GRPC Port (optional)
+    let port = "50001";
 
     // Create the client
-    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr).await?;
+    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr, port).await?;
 ```
 
 ## Explore more examples

examples/actors/client.rs

@@ -20,7 +20,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let addr = "https://127.0.0.1".to_string();
 
     // Create the client
-    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr).await?;
+    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr, None).await?;
 
     let data = MyRequest {
         name: "test".to_string(),

examples/client/client.rs

@@ -8,7 +8,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let addr = "https://127.0.0.1".to_string();
 
     // Create the client
-    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr).await?;
+    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr, None).await?;
 
     let key = String::from("hello");
 

examples/configuration/main.rs

@@ -13,7 +13,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let addr = "https://127.0.0.1".to_string();
 
     // Create the client
-    let mut client = DaprClient::connect(addr).await?;
+    let mut client = DaprClient::connect(addr, None).await?;
 
     let key = String::from("hello");
 

examples/crypto/main.rs

@@ -10,7 +10,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     sleep(std::time::Duration::new(2, 0)).await;
     let addr = "https://127.0.0.1".to_string();
 
-    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr).await?;
+    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr, None).await?;
 
     let encrypted = client
         .encrypt(

examples/invoke/grpc/client.rs

@@ -17,7 +17,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     // Set the Dapr address
     let address = "https://127.0.0.1".to_string();
 
-    let mut client = DaprClient::connect(address).await?;
+    let mut client = DaprClient::connect(address, None).await?;
 
     let request = HelloRequest {
         name: "Test".to_string(),

examples/pubsub/publisher.rs

@@ -25,7 +25,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let addr = "https://127.0.0.1".to_string();
 
     // Create the client
-    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr).await?;
+    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr, None).await?;
 
     // name of the pubsub component
     let pubsub_name = "pubsub".to_string();

examples/query_state/query1.rs

@@ -9,7 +9,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let addr = "https://127.0.0.1".to_string();
 
     // Create the client
-    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr).await?;
+    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr, None).await?;
 
     let query_condition = json!({
         "filter": {

examples/query_state/query2.rs

@@ -9,7 +9,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let addr = "https://127.0.0.1".to_string();
 
     // Create the client
-    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr).await?;
+    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr, None).await?;
 
     let query_condition = json!({
         "filter": {

examples/secrets-bulk/app.rs

@@ -4,7 +4,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let addr = "https://127.0.0.1".to_string();
 
     // Create the client
-    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr).await?;
+    let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr, None).await?;
 
     let secret_store = "localsecretstore";
 

src/client.rs

@@ -1,3 +1,4 @@
+use log::error;
 use serde_json::Value;
 use std::collections::HashMap;
 
@@ -21,10 +22,31 @@ impl<T: DaprInterface> Client<T> {
     ///
     /// # Arguments
     ///
-    /// * `addr` - Address of gRPC server to connect to.
-    pub async fn connect(addr: String) -> Result<Self, Error> {
+    /// * `addr` - Address of the gRPC server to connect to.
+    /// * `port` - Port of the gRPC server to connect to.
+    pub async fn connect(addr: String, port: Option<String>) -> Result<Self, Error> {
+        const DEFAULT_DAPR_GRPC_PORT: u16 = 50001;
+
         // Get the Dapr port to create a connection
-        let port: u16 = std::env::var("DAPR_GRPC_PORT")?.parse()?;
+        let port: u16 = match port {
+            Some(port) => {
+                // Handle port
+                let port = port.parse::<u16>().unwrap();
+                match port {
+                    1..=65535 => port,
+                    _ => {
+                        panic!("invalid port specified: {port:?}")
+                    }
+                }
+            }
+            None => match std::env::var("DAPR_GRPC_PORT")?.parse::<u16>() {
+                Ok(port) => port,
+                Err(e) => {
+                    error!("error retrieving port from the env var DAPR_GRPC_PORT, using default: {e:?}");
+                    DEFAULT_DAPR_GRPC_PORT
+                }
+            },
+        };
         let address = format!("{}:{}", addr, port);
 
         Ok(Client(T::connect(address).await?))