path: root/dichroism/src/main.rs

#[macro_use]
extern crate serde;
#[macro_use]
extern crate diesel;

use actix_web::{App, HttpServer};
use config::Config;
use diesel::prelude::SqliteConnection;
use diesel::r2d2::ConnectionManager;
use diesel::r2d2::Pool;
use listenfd::ListenFd;
use result::Result;

mod config;
mod constants;
mod error;
mod handlers;
mod models;
mod photo_repo;
mod product_repo;
mod result;
mod schema;
mod types;

#[actix_web::main]
async fn main() -> Result<()> {
    // Gather config.
    let config = Config::from_toml()?;
    let bind_addr = config.bind_addr;

    // Initialize DB connection pool.
    let manager = ConnectionManager::<SqliteConnection>::new(&config.db_url);
    let pool = Pool::builder().build(manager)?;

    // Initialize application server.
    let mut server = HttpServer::new(move || {
        App::new()
            .data(config.clone())
            .data(pool.clone())
            .service(handlers::hello)
            .service(handlers::get_products)
            .service(handlers::update_product)
            .service(handlers::create_product)
    });

    let mut listenfd = ListenFd::from_env();
    server = if let Some(l) = listenfd
        .take_tcp_listener(0)
        .expect("Unable to grab TCP listener!")
    {
        // If using listenfd, use it to allow for cargo watch auto-reloading.
        server.listen(l)?
    } else {
        // Bind to config for release.
        server.bind(bind_addr)?
    };

    Ok(server.run().await?)
}