feat: Add comprehensive project context documentation and refactor CMS service to include HTTP tracing and streamline CORS configuration.

This commit is contained in:
2026-03-13 12:43:32 -03:00
parent 3bfff51a69
commit c49a49dc19
3 changed files with 431 additions and 44 deletions
+26 -9
View File
@@ -2336,28 +2336,45 @@ pub async fn login(
State(pool): State<PgPool>,
Json(payload): Json<AuthPayload>,
) -> Result<Json<AuthResponse>, (StatusCode, String)> {
tracing::info!("Login attempt for email: {}", payload.email);
let user = sqlx::query_as::<_, User>("SELECT * FROM fn_get_user_by_email($1)")
.bind(&payload.email)
.fetch_one(&pool)
.await
.map_err(|_| (StatusCode::UNAUTHORIZED, "Invalid credentials".into()))?;
.map_err(|e| {
tracing::error!("Failed to fetch user: {}", e);
(StatusCode::UNAUTHORIZED, "Invalid credentials".into())
})?;
if !verify(payload.password, &user.password_hash).map_err(|_| {
(
StatusCode::INTERNAL_SERVER_ERROR,
"Verification failed".into(),
)
})? {
return Err((StatusCode::UNAUTHORIZED, "Credenciales inválidas".into()));
tracing::info!("User found: {}", user.email);
let verify_result = verify(payload.password, &user.password_hash);
match verify_result {
Ok(valid) => {
if !valid {
tracing::warn!("Invalid password for user: {}", user.email);
return Err((StatusCode::UNAUTHORIZED, "Credenciales inválidas".into()));
}
},
Err(e) => {
tracing::error!("Password verification failed: {}", e);
return Err((StatusCode::INTERNAL_SERVER_ERROR, "Verification failed".into()));
}
}
let token = create_jwt(user.id, user.organization_id, &user.role).map_err(|_| {
tracing::info!("Password verified for user: {}", user.email);
let token = create_jwt(user.id, user.organization_id, &user.role).map_err(|e| {
tracing::error!("JWT generation failed: {}", e);
(
StatusCode::INTERNAL_SERVER_ERROR,
"JWT generation failed".into(),
)
})?;
tracing::info!("Login successful for user: {}", user.email);
Ok(Json(AuthResponse {
user: UserResponse {
id: user.id,
+16 -35
View File
@@ -12,9 +12,7 @@ mod webhooks;
use axum::{
Router,
extract::DefaultBodyLimit,
http::{StatusCode, HeaderValue},
middleware,
response::Response,
routing::{delete, get, post, put},
};
use common::health::{self, HealthState};
@@ -28,25 +26,7 @@ use tower_governor::governor::GovernorConfigBuilder;
use tower_governor::GovernorLayer;
use tower_http::cors::{Any, CorsLayer};
use tower_http::set_header::SetResponseHeaderLayer;
/// Handler para requests OPTIONS (CORS preflight)
async fn handle_options() -> Response {
let mut res = Response::new(String::new().into());
*res.status_mut() = StatusCode::NO_CONTENT;
res.headers_mut().insert(
"Access-Control-Allow-Origin",
HeaderValue::from_static("*"),
);
res.headers_mut().insert(
"Access-Control-Allow-Methods",
HeaderValue::from_static("GET, POST, PUT, DELETE, OPTIONS"),
);
res.headers_mut().insert(
"Access-Control-Allow-Headers",
HeaderValue::from_static("Content-Type, Authorization, Origin, Accept"),
);
res
}
use tower_http::trace::TraceLayer;
#[tokio::main]
async fn main() {
@@ -329,26 +309,23 @@ async fn main() {
);
// Rutas públicas que no requieren autenticación
let public_routes = Router::new()
.nest("/api/external", api_routes)
.route("/auth/register", post(handlers::register).options(handle_options))
.route("/auth/login", post(handlers::login).options(handle_options))
.route("/auth/sso/login/{org_id}", get(handlers::sso_login_init).options(handle_options))
.route("/auth/sso/callback", get(handlers::sso_callback).options(handle_options))
let auth_routes = Router::new()
.route("/auth/register", post(handlers::register))
.route("/auth/login", post(handlers::login))
.route("/auth/sso/login/{org_id}", get(handlers::sso_login_init))
.route("/auth/sso/callback", get(handlers::sso_callback))
.route(
"/branding",
get(handlers_branding::get_organization_branding).options(handle_options),
)
get(handlers_branding::get_organization_branding),
);
let public_routes = Router::new()
.nest("/api/external", api_routes)
// Health check routes
.merge(health::health_routes(pool.clone()).with_state(health_state))
.nest_service("/assets", tower_http::services::ServeDir::new("uploads"))
.merge(auth_routes)
.merge(protected_routes)
// CORS layer - debe estar PRIMERO (más cerca del servicio) para ejecutarse ULTIMO
.layer(cors)
// Rate limiting
.layer(GovernorLayer {
config: governor_conf,
})
// Security headers
.layer(SetResponseHeaderLayer::overriding(
http::header::STRICT_TRANSPORT_SECURITY,
@@ -370,6 +347,10 @@ async fn main() {
http::header::REFERRER_POLICY,
http::HeaderValue::from_static("strict-origin-when-cross-origin"),
))
// CORS layer - MUST be last to execute first on response
.layer(cors)
// Trace layer for logging requests/responses
.layer(TraceLayer::new_for_http())
.with_state(pool);
let addr = SocketAddr::from(([0, 0, 0, 0], 3001));