Add node_url field to Cli struct and update related code

Author: Eshanatnight

server/src/cli.rs

@@ -86,6 +86,9 @@ pub struct Cli {
 
     /// Mode of operation
     pub mode: Mode,
+
+    /// public address for the parseable server
+    pub node_url: String,
 }
 
 impl Cli {
@@ -112,6 +115,7 @@ impl Cli {
     pub const ROW_GROUP_SIZE: &'static str = "row-group-size";
     pub const PARQUET_COMPRESSION_ALGO: &'static str = "compression-algo";
     pub const MODE: &'static str = "mode";
+    pub const NODE_URL: &'static str = "node-url";
     pub const DEFAULT_USERNAME: &'static str = "admin";
     pub const DEFAULT_PASSWORD: &'static str = "admin";
 
@@ -247,7 +251,7 @@ impl Cli {
                 Arg::new(Self::OPENID_ISSUER)
                     .long(Self::OPENID_ISSUER)
                     .env("P_OIDC_ISSUER")
-                    .value_name("URl")
+                    .value_name("URL")
                     .required(false)
                     .value_parser(validation::url)
                     .help("OIDC provider's host address"),
@@ -312,6 +316,15 @@ impl Cli {
                         "all"])
                     .help("Mode of operation"),
             )
+            .arg(
+            	Arg::new(Self::NODE_URL)
+             		.long(Self::NODE_URL)
+               		.env("P_NODE_URL")
+                 	.value_name("URL")
+                  	.required(true)
+                    .value_parser(validation::socket_addr)
+                    .help("Node URL for Parseable server")
+            )
             .arg(
                 Arg::new(Self::PARQUET_COMPRESSION_ALGO)
                     .long(Self::PARQUET_COMPRESSION_ALGO)
@@ -354,6 +367,12 @@ impl FromArgMatches for Cli {
             .get_one::<String>(Self::ADDRESS)
             .cloned()
             .expect("default value for address");
+
+        self.node_url = m
+            .get_one::<String>(Self::NODE_URL)
+            .cloned()
+            .expect("Node URL set");
+
         self.local_staging_path = m
             .get_one::<PathBuf>(Self::STAGING)
             .cloned()

server/src/handlers/http/modal/server.rs

@@ -480,7 +480,7 @@ impl Server {
     pub fn get_server_address() -> SocketAddr {
         // this might cause an issue down the line
         // best is to make the Cli Struct better, but thats a chore
-        (CONFIG.parseable.address.clone())
+        (CONFIG.parseable.node_url.clone())
             .parse::<SocketAddr>()
             .unwrap()
     }

server/src/utils.rs

@@ -228,7 +228,7 @@ impl TimePeriod {
 
 #[inline(always)]
 pub fn get_address() -> (IpAddr, u16) {
-    let addr = CONFIG.parseable.address.parse::<SocketAddr>().unwrap();
+    let addr = CONFIG.parseable.node_url.parse::<SocketAddr>().unwrap();
     (addr.ip(), addr.port())
 }