blob: bb34c80cfc2ca473bbb437f20d6e793f18d2561f (
plain)
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
42
|
use anyhow::Result;
use log::{self, debug};
use warp::Filter;
use warp::reply::Response;
use std::collections::HashMap;
pub async fn run_server() -> Result<()> {
// GET /
let homepage = warp::path::end().map(|| "Not much to see here yet!");
// GET /xrpc/some.method w/ query params
let xrpc_some_get = warp::get()
.and(warp::path!("xrpc" / "some.method"))
.and(warp::query::<HashMap<String, String>>())
.map(|query_params: HashMap<String, String>| {
println!("query params: {:?}", query_params);
// return query params as a JSON map object
warp::reply::json(&query_params)
});
// POST /xrpc/other.method w/ query params
let xrpc_other_post = warp::post()
.and(warp::path!("xrpc" / "other.method"))
.and(warp::query::<HashMap<String, String>>())
.and(warp::body::json())
.map(|query_params: HashMap<String, String>, body_val: serde_json::Value| {
println!("query params: {:?}", query_params);
println!("body JSON: {}", body_val);
// echo it back
warp::reply::json(&body_val)
});
let routes = homepage.or(xrpc_some_get).or(xrpc_other_post).with(warp::log("adenosine-pds"));
warp::serve(routes)
.run(([127, 0, 0, 1], 3030))
.await;
Ok(())
}
// TODO: tokio::task::spawn_blocking
|
