es-entity 0.10.19

Event Sourcing Entity Framework
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

use sqlx::{
    Postgres,
    postgres::{PgArgumentBuffer, PgHasArrayType, PgTypeInfo, PgValueRef},
};

use super::ContextData;

impl sqlx::Type<Postgres> for ContextData {
    fn type_info() -> PgTypeInfo {
        <serde_json::Value as sqlx::Type<Postgres>>::type_info()
    }
}

impl<'q> sqlx::Encode<'q, Postgres> for ContextData {
    fn encode_by_ref(
        &self,
        buf: &mut PgArgumentBuffer,
    ) -> Result<sqlx::encode::IsNull, Box<dyn std::error::Error + Send + Sync + 'static>> {
        let json_value = serde_json::to_value(&self.0)?;
        <serde_json::Value as sqlx::Encode<Postgres>>::encode_by_ref(&json_value, buf)
    }
}

impl<'r> sqlx::Decode<'r, Postgres> for ContextData {
    fn decode(
        value: PgValueRef<'r>,
    ) -> Result<Self, Box<dyn std::error::Error + 'static + Send + Sync>> {
        let json_value = <serde_json::Value as sqlx::Decode<Postgres>>::decode(value)?;
        let res: ContextData = serde_json::from_value(json_value)?;
        Ok(res)
    }
}

impl PgHasArrayType for ContextData {
    fn array_type_info() -> PgTypeInfo {
        <serde_json::Value as sqlx::postgres::PgHasArrayType>::array_type_info()
    }
}