Add dashboard server port command line argument

src/bin/omnip.rs

@@ -31,6 +31,7 @@ fn main() -> Result<()> {
         args.threads,
         args.watch_proxy_rules_change,
         args.tcp_nodelay,
+        Some(args.dashboard_addr),
     )?;
 
     let common_quic_config = CommonQuicConfig {
@@ -114,6 +115,11 @@ struct OmnipArgs {
     #[arg(short = 'u', long, default_value = "")]
     upstream: String,
 
+    /// Dashboard server address [ip:port]
+    /// for example: 127.0.0.1:8000, [::1]:8000
+    #[arg(short = 'd', long, default_value = "")]
+    dashboard_addr: String,
+
     /// Path to the proxy rules file
     #[arg(short = 'r', long, default_value = "")]
     proxy_rules_file: String,

src/lib.rs

@@ -277,6 +277,7 @@ pub struct Config {
     pub name_servers: String,
     pub watch_proxy_rules_change: bool,
     pub tcp_nodelay: bool,
+    pub dashboard_addr: Option<SocketAddr>,
 }
 
 #[derive(Debug)]
@@ -430,6 +431,7 @@ pub fn create_config(
     threads: usize,
     watch_proxy_rules_change: bool,
     tcp_nodelay: bool,
+    dashboard_addr: Option<String>,
 ) -> Result<Config> {
     let (server_type, orig_server_addr, is_layered_proto) = parse_server_addr(addr.as_str());
 
@@ -467,6 +469,11 @@ pub fn create_config(
         num_cpus::get()
     };
 
+    let dashboard_server_addr = dashboard_addr.as_deref().and_then(parse_socket_addr);
+    if dashboard_server_addr.is_none() {
+        log_and_bail!("server addr must be an IP address: {:?}", addr);
+    }
+
     Ok(Config {
         server_type,
         addr: server_addr,
@@ -480,6 +487,7 @@ pub fn create_config(
         name_servers,
         watch_proxy_rules_change,
         tcp_nodelay,
+        dashboard_addr: dashboard_server_addr,
     })
 }
 
@@ -561,6 +569,7 @@ pub mod android {
             jthreads as usize,
             false,
             jtcpNoDelay != 0,
+            None,
         ) {
             Ok(config) => config,
             Err(e) => {

src/server.rs

@@ -163,7 +163,10 @@ impl Server {
         self.set_and_post_server_state(ServerState::Preparing);
 
         // start the dashboard server
-        let addr = local_socket_addr_with_unspecified_port(self.config.addr.is_ipv6());
+        let addr = match self.config.dashboard_addr {
+            Some(dashboard_addr) => dashboard_addr,
+            None => local_socket_addr_with_unspecified_port(self.config.addr.is_ipv6()),
+        };
         let dashboard_server = DashboardServer::new();
         let dashboard_listener = dashboard_server.bind(addr).await?;
         let dashboard_addr = dashboard_listener.local_addr().ok();