119 lines
4.4 KiB
Rust
119 lines
4.4 KiB
Rust
pub mod host {
|
|
pub const PORT: i64 = 9081;
|
|
|
|
pub fn get_full() -> String {
|
|
let address: &str = "0.0.0.0";
|
|
format!("{}:{}", address, PORT)
|
|
}
|
|
}
|
|
|
|
pub mod init {
|
|
use std::time::Duration;
|
|
|
|
use axum::routing::post;
|
|
use tower_http::timeout::TimeoutLayer;
|
|
use utoipa::OpenApi;
|
|
|
|
use crate::caller::contact as contact_caller;
|
|
use contact_caller::endpoint as contact_endpoints;
|
|
// use contact_caller::response as contact_responses;
|
|
|
|
mod cors {
|
|
pub async fn configure_cors() -> tower_http::cors::CorsLayer {
|
|
let cors = tower_http::cors::CorsLayer::new()
|
|
.allow_methods([
|
|
axum::http::Method::GET,
|
|
axum::http::Method::POST,
|
|
axum::http::Method::PUT,
|
|
axum::http::Method::DELETE,
|
|
]) // Specify allowed methods:cite[2]
|
|
.allow_headers([
|
|
axum::http::header::CONTENT_TYPE,
|
|
axum::http::header::AUTHORIZATION,
|
|
]) // Specify allowed headers:cite[2]
|
|
.allow_credentials(true) // If you need to send cookies or authentication headers:cite[2]
|
|
.max_age(std::time::Duration::from_secs(3600)); // Cache the preflight response for 1 hour:cite[2]
|
|
|
|
// Dynamically set the allowed origin based on the environment
|
|
match std::env::var(textsender_models::envy::keys::APP_ENV).as_deref() {
|
|
Ok("production") => {
|
|
// In production, allow only your specific, trusted origins
|
|
let allowed_origins_env =
|
|
textsender_models::envy::environment::get_allowed_origins().await;
|
|
match textsender_models::envy::utility::delimitize(&allowed_origins_env) {
|
|
Ok(alwd) => {
|
|
let allowed_origins: Vec<axum::http::HeaderValue> = alwd
|
|
.into_iter()
|
|
.map(|a| a.parse::<axum::http::HeaderValue>().unwrap())
|
|
.collect();
|
|
cors.allow_origin(allowed_origins)
|
|
}
|
|
Err(err) => {
|
|
eprintln!("Error getting allowed origins: Error: {err:?}");
|
|
std::process::exit(-1);
|
|
}
|
|
}
|
|
}
|
|
_ => {
|
|
// Development (default): Allow localhost origins
|
|
cors.allow_origin(vec![
|
|
format!("http://localhost:{}", super::super::host::PORT)
|
|
.parse()
|
|
.unwrap(),
|
|
format!("http://127.0.0.1:{}", super::super::host::PORT)
|
|
.parse()
|
|
.unwrap(),
|
|
"http://localhost:4200".parse().unwrap(),
|
|
"http://127.0.0.1:4200".parse().unwrap(),
|
|
])
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
#[derive(utoipa::OpenApi)]
|
|
#[openapi(
|
|
paths(contact_endpoints::create_contact,),
|
|
components(schemas(contact_caller::response::AddContactResponse)),
|
|
tags(
|
|
(name = "textsender API", description = "Web API to manage texting")
|
|
)
|
|
)]
|
|
struct ApiDoc;
|
|
|
|
pub async fn routes() -> axum::Router {
|
|
axum::Router::new()
|
|
.route(
|
|
crate::caller::endpoints::ADD_CONTACT,
|
|
post(contact_endpoints::create_contact).route_layer(axum::middleware::from_fn(
|
|
crate::auth::auth::<axum::body::Body>,
|
|
)),
|
|
)
|
|
.layer(cors::configure_cors().await)
|
|
}
|
|
|
|
pub async fn app() -> axum::Router {
|
|
let pool = crate::db::create_pool()
|
|
.await
|
|
.expect("Failed to create pool");
|
|
|
|
crate::db::migrations(&pool).await;
|
|
|
|
let cors = cors::configure_cors().await;
|
|
|
|
routes()
|
|
.await
|
|
.merge(
|
|
utoipa_swagger_ui::SwaggerUi::new("/swagger-ui")
|
|
.url("/api-docs/openapi.json", ApiDoc::openapi()),
|
|
)
|
|
.layer(axum::Extension(pool))
|
|
.layer(axum::extract::DefaultBodyLimit::max(1024 * 1024 * 1024))
|
|
.layer(TimeoutLayer::with_status_code(
|
|
axum::http::StatusCode::OK,
|
|
Duration::from_secs(300),
|
|
))
|
|
.layer(cors)
|
|
}
|
|
}
|