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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
use poem::web::Field as PoemField;
use serde_json::Value;
use crate::{
registry::MetaSchemaRef,
types::{
ParseError, ParseFromJSON, ParseFromMultipartField, ParseFromParameter, ParseResult,
ToJSON, Type, TypeName,
},
};
impl<T: Type> Type for Option<T> {
const NAME: TypeName = T::NAME;
const IS_REQUIRED: bool = false;
type ValueType = T;
fn schema_ref() -> MetaSchemaRef {
T::schema_ref()
}
fn as_value(&self) -> Option<&Self::ValueType> {
match self {
Some(value) => Some(value),
None => None,
}
}
}
impl<T: ParseFromJSON> ParseFromJSON for Option<T> {
fn parse_from_json(value: Value) -> ParseResult<Self> {
match value {
Value::Null => Ok(None),
value => Ok(Some(
T::parse_from_json(value).map_err(ParseError::propagate)?,
)),
}
}
}
impl<T: ParseFromParameter> ParseFromParameter for Option<T> {
fn parse_from_parameter(value: Option<&str>) -> ParseResult<Self> {
match value {
Some(value) => T::parse_from_parameter(Some(value))
.map_err(ParseError::propagate)
.map(Some),
None => Ok(None),
}
}
}
#[poem::async_trait]
impl<T: ParseFromMultipartField> ParseFromMultipartField for Option<T> {
async fn parse_from_multipart(value: Option<PoemField>) -> ParseResult<Self> {
match value {
Some(value) => T::parse_from_multipart(Some(value))
.await
.map_err(ParseError::propagate)
.map(Some),
None => Ok(None),
}
}
}
impl<T: ToJSON> ToJSON for Option<T> {
fn to_json(&self) -> Value {
match self {
Some(value) => value.to_json(),
None => Value::Null,
}
}
}