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

use super::handlers::*;
use crate::v0::context::SharedContext;
use warp::filters::BoxedFilter;
use warp::{Filter, Rejection, Reply};

pub async fn filter(
    root: BoxedFilter<()>,
    context: SharedContext,
) -> impl Filter<Extract = impl Reply, Error = Rejection> + Clone {
    let with_context = warp::any().map(move || context.clone());

    let fund = warp::path::end()
        .and(warp::get())
        .and(with_context.clone())
        .and_then(get_fund);

    let fund_by_id = warp::path!(i32)
        .and(warp::get())
        .and(with_context.clone())
        .and_then(get_fund_by_id);

    let all_funds = warp::path::end()
        .and(warp::get())
        .and(with_context)
        .and_then(get_all_funds);

    // fund_by_id need to be checked first otherwise requests are swallowed by the fund::any
    root.and(fund_by_id.or(fund).or(all_funds)).boxed()
}

pub fn admin_filter(
    context: SharedContext,
) -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone {
    let with_context = warp::any().map(move || context.clone());

    warp::path::end()
        .and(warp::put())
        .and(warp::body::json())
        .and(with_context)
        .and_then(put_fund)
}