hl7v2-server 1.2.1

HTTP/REST API server for HL7v2 message processing
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

//! HL7v2 HTTP/REST API server binary.

use hl7v2_server::{CorsAllowedOrigins, Server};
use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Initialize tracing/logging
    tracing_subscriber::registry()
        .with(
            tracing_subscriber::EnvFilter::try_from_default_env()
                .unwrap_or_else(|_| "hl7v2_server=info,tower_http=debug".into()),
        )
        .with(tracing_subscriber::fmt::layer())
        .init();

    // Get bind address from environment or use default
    let bind_address = std::env::var("BIND_ADDRESS").unwrap_or_else(|_| "0.0.0.0:8080".to_string());

    tracing::info!("Starting HL7v2 HTTP server");
    tracing::info!("Bind address: {}", bind_address);

    // Get API key from environment if set
    let api_key = std::env::var("HL7V2_API_KEY").ok();
    if api_key.is_some() {
        tracing::info!("API key authentication enabled");
    } else {
        tracing::warn!("API key authentication disabled (public access enabled)");
    }

    let cors_allowed_origins = std::env::var("HL7V2_CORS_ALLOWED_ORIGINS")
        .map(|value| CorsAllowedOrigins::from_csv(&value))
        .unwrap_or_default();
    tracing::info!("CORS allowed origins: {:?}", cors_allowed_origins);

    // Create and run server
    let server = Server::builder()
        .bind(bind_address)
        .api_key(api_key)
        .cors_allowed_origins(cors_allowed_origins)
        .build();

    server.serve().await?;

    Ok(())
}