mirror of
https://github.com/andwati/telecom-platform.git
synced 2026-10-30 08:32:15 +00:00
nutcas3
3cef1fbf03
- Add auth module import to main.rs - Add AuthConfig initialization from environment in main function - Add auth_config field to AppState struct - Add auth_middleware layer to protected routes - Move health check, credit check, deduct, balance, and usage recording to public routes (no auth required for packet-gateway integration) - Move add credit, subscriber management, rating plans, monitoring, and engine
69 lines
1.9 KiB
Rust
69 lines
1.9 KiB
Rust
mod auth;
|
|
mod charging;
|
|
mod monitoring;
|
|
mod errors;
|
|
mod models;
|
|
mod routes;
|
|
mod handlers;
|
|
|
|
use anyhow::Result;
|
|
use std::sync::Arc;
|
|
use tracing::info;
|
|
|
|
use routes::create_router;
|
|
use charging::{ChargingEngine, RatingPlansRepo};
|
|
use auth::AuthConfig;
|
|
|
|
#[tokio::main]
|
|
async fn main() -> Result<()> {
|
|
// Initialize tracing
|
|
tracing_subscriber::fmt()
|
|
.with_target(false)
|
|
.compact()
|
|
.init();
|
|
|
|
// Load environment variables
|
|
dotenv::dotenv().ok();
|
|
|
|
// Initialize charging engine
|
|
let redis_url = std::env::var("REDIS_URI").unwrap_or_else(|_| "redis://127.0.0.1/".to_string());
|
|
let database_url = std::env::var("DATABASE_URL")
|
|
.expect("DATABASE_URL is required (for rating plans)");
|
|
let sync_interval = std::env::var("SYNC_INTERVAL")
|
|
.unwrap_or_else(|_| "1".to_string())
|
|
.parse::<u64>()
|
|
.unwrap_or(1);
|
|
|
|
// Connect to Postgres and seed defaults if the table is empty.
|
|
let plans_repo = RatingPlansRepo::connect(&database_url).await?;
|
|
plans_repo.seed_defaults().await?;
|
|
info!("Connected to Postgres and ensured default rating plans");
|
|
|
|
let charging_engine = Arc::new(ChargingEngine::new(&redis_url, plans_repo, sync_interval)?);
|
|
|
|
// Test Redis connection
|
|
charging_engine.test_connection().await?;
|
|
info!("Connected to Redis successfully");
|
|
|
|
// Create application state
|
|
let auth_config = AuthConfig::from_env();
|
|
let state = crate::models::AppState {
|
|
charging_engine,
|
|
auth_config,
|
|
};
|
|
|
|
// Create router
|
|
let app = create_router(state);
|
|
|
|
// Start server
|
|
let port = std::env::var("SERVER_PORT").unwrap_or_else(|_| "8080".to_string());
|
|
let addr = format!("0.0.0.0:{}", port);
|
|
let listener = tokio::net::TcpListener::bind(&addr).await?;
|
|
|
|
info!("Charging engine listening on {}", addr);
|
|
|
|
axum::serve(listener, app).await?;
|
|
|
|
Ok(())
|
|
}
|