Initialize project with basic backend setup

This commit is contained in:
2025-08-14 11:56:32 -04:00
commit 3dc6c86c3b
7 changed files with 2494 additions and 0 deletions

36
src/config.rs Normal file
View File

@@ -0,0 +1,36 @@
// src/config.rs
use std::env;
use std::net::SocketAddr;
use std::str::FromStr;
use tracing::error;
#[derive(Debug)]
pub struct Config {
pub bind_address: SocketAddr,
pub database_url: Option<String>,
}
impl Config {
pub fn from_env() -> Result<Self, String> {
let bind_address_str =
env::var("BIND_ADDRESS").unwrap_or_else(|_| "127.0.0.1:3000".to_string());
let bind_address = SocketAddr::from_str(&bind_address_str)
.map_err(|e| format!("Invalid BIND_ADDRESS: {}", e))?;
#[cfg(feature = "no-auth")]
if bind_address.ip() != std::net::IpAddr::from([127, 0, 0, 1]) {
error!("In no-auth mode, BIND_ADDRESS must be 127.0.0.1");
return Err("In no-auth mode, BIND_ADDRESS must be 127.0.0.1".to_string());
}
let database_url = env::var("DATABASE_URL").ok();
Ok(Self {
bind_address,
database_url,
})
}
}

10
src/health.rs Normal file
View File

@@ -0,0 +1,10 @@
// src/health.rs
use axum::Json;
use axum::http::StatusCode;
use axum::response::IntoResponse;
use serde_json::json;
pub async fn health() -> impl IntoResponse {
(StatusCode::OK, Json(json!({ "status": "ok" })))
}

82
src/main.rs Normal file
View File

@@ -0,0 +1,82 @@
// src/main.rs
use std::net::SocketAddr;
use std::process::exit;
use axum::{Router, routing::get};
use dotenvy::dotenv;
use tokio::signal;
use tower_http::trace::TraceLayer;
use tracing::{error, info};
use tracing_subscriber::{EnvFilter, fmt, prelude::*};
mod config;
mod health;
use config::Config;
#[tokio::main]
async fn main() {
// Load environment variables from .env file
dotenv().ok();
// Initialize tracing
tracing_subscriber::registry()
.with(fmt::layer())
.with(EnvFilter::from_env("RUST_LOG"))
.init();
// Load config
let config = match Config::from_env() {
Ok(c) => c,
Err(e) => {
error!("Failed to load config: {}", e);
exit(1);
}
};
#[cfg(feature = "no-auth")]
info!("NO-AUTH MODE ENABLED");
info!("Server starting on {}", config.bind_address);
// Build the Axum router
let app = Router::new()
.route("/health", get(health::health))
.layer(TraceLayer::new_for_http());
// Run the server
let listener = tokio::net::TcpListener::bind(config.bind_address)
.await
.unwrap();
axum::serve(listener, app)
.with_graceful_shutdown(shutdown_signal())
.await
.unwrap();
}
async fn shutdown_signal() {
let ctrl_c = async {
signal::ctrl_c()
.await
.expect("Failed to install Ctrl+C handler");
};
#[cfg(unix)]
let terminate = async {
signal::unix::signal(signal::unix::SignalKind::terminate())
.expect("Failed to install signal handler")
.recv()
.await;
};
#[cfg(not(unix))]
let terminate = std::future::pending::<()>();
tokio::select! {
_ = ctrl_c => {},
_ = terminate => {},
}
info!("Signal received, shutting down server gracefully");
}