route-util 0.1.0

route utils
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use crate::mailbox::{MailboxParser, MailboxReq};
use http_pool::body::VariantBody;
use http_pool::net_pool::{Pool, Pools};
use hyper::body::{Bytes, Incoming};
use hyper::{Request, Response};

/// json解析器
pub struct JsonMailboxParser;

impl MailboxParser for JsonMailboxParser {
    type Error = serde_json::Error;

    fn parse(data: Bytes, _zip: Option<String>) -> Result<MailboxReq, Self::Error> {
        serde_json::from_slice(data.as_ref())
    }
}

pub async fn send_to_mailbox<P: Pool>(
    builder: &kmailbox::Builder,
    pools: Pools<P>,
    req: Request<Incoming>,
) -> Result<(Response<VariantBody>, Option<anyhow::Error>), anyhow::Error> {
    crate::mailbox::send_to_mailbox::<P, JsonMailboxParser>(builder, pools, req).await
}