use std::ops::{Deref, DerefMut};
use poem::{Request, RequestBody, Result};
use crate::{
error::ParseParamError,
registry::{MetaParamIn, MetaSchemaRef, Registry},
types::ParseFromParameter,
ApiExtractor, ApiExtractorType, ExtractParamOptions,
};
pub struct Cookie<T>(pub T);
impl<T> Deref for Cookie<T> {
type Target = T;
fn deref(&self) -> &Self::Target {
&self.0
}
}
impl<T> DerefMut for Cookie<T> {
fn deref_mut(&mut self) -> &mut Self::Target {
&mut self.0
}
}
#[poem::async_trait]
impl<'a, T: ParseFromParameter> ApiExtractor<'a> for Cookie<T> {
const TYPE: ApiExtractorType = ApiExtractorType::Parameter;
const PARAM_IS_REQUIRED: bool = T::IS_REQUIRED;
type ParamType = T;
type ParamRawType = T::RawValueType;
fn register(registry: &mut Registry) {
T::register(registry);
}
fn param_in() -> Option<MetaParamIn> {
Some(MetaParamIn::Cookie)
}
fn param_schema_ref() -> Option<MetaSchemaRef> {
Some(T::schema_ref())
}
fn param_raw_type(&self) -> Option<&Self::ParamRawType> {
self.0.as_raw_value()
}
async fn from_request(
request: &'a Request,
_body: &mut RequestBody,
param_opts: ExtractParamOptions<Self::ParamType>,
) -> Result<Self> {
let value = request
.cookie()
.get(param_opts.name)
.as_ref()
.map(|cookie| cookie.value_str().to_string());
let value = match (value, ¶m_opts.default_value) {
(Some(value), _) => Some(value),
(None, Some(default_value)) => return Ok(Self(default_value())),
(None, _) => None,
};
ParseFromParameter::parse_from_parameters(value.as_deref())
.map(Self)
.map_err(|err| {
ParseParamError {
name: param_opts.name,
reason: err.into_message(),
}
.into()
})
}
}
pub struct CookiePrivate<T>(pub T);
impl<T> Deref for CookiePrivate<T> {
type Target = T;
fn deref(&self) -> &Self::Target {
&self.0
}
}
impl<T> DerefMut for CookiePrivate<T> {
fn deref_mut(&mut self) -> &mut Self::Target {
&mut self.0
}
}
#[poem::async_trait]
impl<'a, T: ParseFromParameter> ApiExtractor<'a> for CookiePrivate<T> {
const TYPE: ApiExtractorType = ApiExtractorType::Parameter;
const PARAM_IS_REQUIRED: bool = T::IS_REQUIRED;
type ParamType = T;
type ParamRawType = T::RawValueType;
fn register(registry: &mut Registry) {
T::register(registry);
}
fn param_in() -> Option<MetaParamIn> {
Some(MetaParamIn::Cookie)
}
fn param_schema_ref() -> Option<MetaSchemaRef> {
Some(T::schema_ref())
}
fn param_raw_type(&self) -> Option<&Self::ParamRawType> {
self.0.as_raw_value()
}
async fn from_request(
request: &'a Request,
_body: &mut RequestBody,
param_opts: ExtractParamOptions<Self::ParamType>,
) -> Result<Self> {
let value = request
.cookie()
.private()
.get(param_opts.name)
.as_ref()
.map(|cookie| cookie.value_str().to_string());
let value = match (value, ¶m_opts.default_value) {
(Some(value), _) => Some(value),
(None, Some(default_value)) => return Ok(Self(default_value())),
(None, _) => None,
};
ParseFromParameter::parse_from_parameters(value.as_deref())
.map(Self)
.map_err(|err| {
ParseParamError {
name: param_opts.name,
reason: err.into_message(),
}
.into()
})
}
}
pub struct CookieSigned<T>(pub T);
impl<T> Deref for CookieSigned<T> {
type Target = T;
fn deref(&self) -> &Self::Target {
&self.0
}
}
impl<T> DerefMut for CookieSigned<T> {
fn deref_mut(&mut self) -> &mut Self::Target {
&mut self.0
}
}
#[poem::async_trait]
impl<'a, T: ParseFromParameter> ApiExtractor<'a> for CookieSigned<T> {
const TYPE: ApiExtractorType = ApiExtractorType::Parameter;
const PARAM_IS_REQUIRED: bool = T::IS_REQUIRED;
type ParamType = T;
type ParamRawType = T::RawValueType;
fn register(registry: &mut Registry) {
T::register(registry);
}
fn param_in() -> Option<MetaParamIn> {
Some(MetaParamIn::Cookie)
}
fn param_schema_ref() -> Option<MetaSchemaRef> {
Some(T::schema_ref())
}
fn param_raw_type(&self) -> Option<&Self::ParamRawType> {
self.0.as_raw_value()
}
async fn from_request(
request: &'a Request,
_body: &mut RequestBody,
param_opts: ExtractParamOptions<Self::ParamType>,
) -> Result<Self> {
let value = request
.cookie()
.signed()
.get(param_opts.name)
.as_ref()
.map(|cookie| cookie.value_str().to_string());
let value = match (value, ¶m_opts.default_value) {
(Some(value), _) => Some(value),
(None, Some(default_value)) => return Ok(Self(default_value())),
(None, _) => None,
};
ParseFromParameter::parse_from_parameters(value.as_deref())
.map(Self)
.map_err(|err| {
ParseParamError {
name: param_opts.name,
reason: err.into_message(),
}
.into()
})
}
}