api.rs - extracted function

api.rs

pub fn customers(pool: &'static db::ConnectionPool) -> impl warp::Filter {
    // Clone pool in filter chain so child threads can access it safely.
    let database = warp::any().map(move || pool.clone());

    let customers = warp::path("customers");
    let customers_index = customers.and(warp::path::end());
    let customer_by_id = customers
        .and(warp::path::param::<i64>())
        .and(warp::path::end());

    let customer_list = warp::get2()
        .and(customers_index)
        .and(database.clone())
        .and_then(list_customers);

    let customer_read = warp::get2()
        .and(customer_by_id)
        .and(database.clone())
        .and_then(read_customer);

    let api = customer_list.or(customer_read).recover(handle_errors);

    let routes = api.with(warp::log("repo"));

    routes
}