Configurable port

src/config.rs

@@ -1,4 +1,4 @@
-use std::{env, path::PathBuf};
+use std::{env, num::ParseIntError, path::PathBuf};
 
 use secrecy::SecretString;
 use thiserror::Error;
@@ -6,12 +6,15 @@ use thiserror::Error;
 pub struct Config {
     pub server_secret: SecretString,
     pub state_dir: PathBuf,
+    pub port: i32,
 }
 
 #[derive(Error, Debug)]
 pub enum ConfigError {
     #[error("Missing SERVER_SECRET")]
     MissingServerSecret,
+    #[error("Parse error {0}")]
+    InvalidPort(#[from] ParseIntError),
     #[error("Unknown error: #{0}")]
     Unknown(anyhow::Error),
 }
@@ -20,8 +23,12 @@ impl Config {
     pub fn new() -> Result<Self, ConfigError> {
         dotenvy::dotenv().map_err(|err| ConfigError::Unknown(err.into()))?;
         let server_secret = env::var("SERVER_SECRET").map(SecretString::from).map_err(|_| ConfigError::MissingServerSecret)?;
-        let state_dir = env::var("RUKOSYNC_STATE_DIR").map_or_else(|_| PathBuf::from("/tmp/"), PathBuf::from);
-        Ok(Self{server_secret, state_dir})
+        let state_dir = env::var("STATE_DIR").map_or_else(|_| PathBuf::from("/tmp/"), PathBuf::from);
+        let port = match env::var("PORT") {
+            Ok(p) => p.parse(),
+            Err(_) => Ok(3000),
+        }?;
+        Ok(Self{server_secret, state_dir, port})
     }
 }
 

src/main.rs

@@ -27,7 +27,9 @@ async fn main() -> anyhow::Result<()> {
         .nest("/syncs", syncs::syncs_routes())
         .with_state(app_state)
         .layer(TraceLayer::new_for_http());
-    let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await?;
+    let address = format!("0.0.0.0:{}", config.port);
+    tracing::info!("Listening on {:?}", address);
+    let listener = tokio::net::TcpListener::bind(address).await?;
     axum::serve(listener, app).await?;
     Ok(())
 }