src/custom_filters.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

// Common filters ment to be shared between many endpoints

use std::convert::Infallible;
use warp::{Filter, Rejection};

use crate::schema::{Db, Transaction}; // `Block` coming later

// Database context for routes
pub fn with_db(db: Db) -> impl Filter<Extract = (Db,), Error = Infallible> + Clone {
    warp::any().map(move || db.clone())
}

// Optional query params to allow pagination
// pub fn list_options() -> impl Filter<Extract = (ListOptions,), Error = Rejection> + Clone {
//     warp::query::<ListOptions>()
// }

// Accept only JSON body and reject big payloads
pub fn json_body() -> impl Filter<Extract = (Transaction,), Error = Rejection> + Clone {
    warp::body::content_length_limit(1024 * 32).and(warp::body::json())
}