ctx_ 0.1.8

Extract message form headers only once for one req ( support async and sync ) / 一个请求只提取一次消息, 支持异步和同步
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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

use std::{collections::HashMap, fmt, ops::Deref};

use crate::{Ctx, sync::Extract};

pub struct Cookie(HashMap<String, String>);

impl Deref for Cookie {
  type Target = HashMap<String, String>;

  fn deref(&self) -> &Self::Target {
    &self.0
  }
}

impl fmt::Display for Cookie {
  fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
    write!(f, "cookie: {:?}", self.0)
  }
}

impl fmt::Debug for Cookie {
  fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
    fmt::Display::fmt(self, f)
  }
}

impl Extract for Cookie {
  fn from_ctx(ctx: &Ctx) -> Self {
    use cookie::Cookie;

    let mut inner = HashMap::new();

    if let Some(cookie) = ctx.req.headers.get("cookie") {
      // dbg!(cookie);
      if let Ok(cookie) = xerr::ok!(cookie.to_str()) {
        for cookie in Cookie::split_parse(cookie) {
          if let Ok(cookie) = xerr::ok!(cookie) {
            let (name, value) = cookie.name_value();
            inner.insert(name.to_owned(), value.to_owned());
          }
        }
      }
    }
    Self(inner)
  }
}

// bumpalo not call drop
// impl Drop for Cookie {
//   fn drop(&mut self) {
//     info!("drop cookie");
//   }
// }