2019-10-31 22:09:23 +08:00
|
|
|
use http::header::HeaderValue;
|
|
|
|
use log::info;
|
|
|
|
use main_error::MainError;
|
2019-11-20 00:09:06 +08:00
|
|
|
use structopt::StructOpt;
|
2019-10-31 22:09:23 +08:00
|
|
|
use tide::middleware::{CorsMiddleware, CorsOrigin};
|
|
|
|
use tide_log::RequestLogger;
|
|
|
|
|
|
|
|
use meilidb_http::data::Data;
|
|
|
|
use meilidb_http::option::Opt;
|
|
|
|
use meilidb_http::routes;
|
2019-11-16 00:33:06 +08:00
|
|
|
use meilidb_http::routes::index::index_update_callback;
|
2019-10-31 22:09:23 +08:00
|
|
|
|
|
|
|
#[cfg(not(target_os = "macos"))]
|
|
|
|
#[global_allocator]
|
|
|
|
static ALLOC: jemallocator::Jemalloc = jemallocator::Jemalloc;
|
|
|
|
|
|
|
|
pub fn main() -> Result<(), MainError> {
|
2019-11-12 02:03:38 +08:00
|
|
|
env_logger::init();
|
|
|
|
|
2019-11-20 00:09:06 +08:00
|
|
|
let opt = Opt::from_args();
|
2019-10-31 22:09:23 +08:00
|
|
|
let data = Data::new(opt.clone());
|
2019-11-16 00:33:06 +08:00
|
|
|
|
|
|
|
let data_cloned = data.clone();
|
|
|
|
data.db.set_update_callback(Box::new(move |name, status| {
|
|
|
|
index_update_callback(name, &data_cloned, status);
|
|
|
|
}));
|
|
|
|
|
2019-10-31 22:09:23 +08:00
|
|
|
let mut app = tide::App::with_state(data);
|
|
|
|
|
|
|
|
app.middleware(
|
|
|
|
CorsMiddleware::new()
|
|
|
|
.allow_origin(CorsOrigin::from("*"))
|
|
|
|
.allow_methods(HeaderValue::from_static("GET, POST, OPTIONS")),
|
|
|
|
);
|
|
|
|
app.middleware(RequestLogger::new());
|
|
|
|
app.middleware(tide_compression::Compression::new());
|
|
|
|
app.middleware(tide_compression::Decompression::new());
|
|
|
|
|
|
|
|
routes::load_routes(&mut app);
|
|
|
|
|
|
|
|
info!("Server HTTP enabled");
|
|
|
|
app.run(opt.http_addr)?;
|
|
|
|
|
|
|
|
Ok(())
|
2019-10-31 22:00:36 +08:00
|
|
|
}
|