datasources 0.1.55

Async datasource interfaces, middleware, registry, and test doubles
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

use crate::command_middleware::CommandMiddleware;
use crate::entity::Entity;
use crate::i_repository::IRepository;
use crate::IWhere;
use crate::id_key::IdKey;
use crate::response::Response;
use crate::result::Result;
use crate::row::Row;
use crate::schema::Schema;
use crate::statement::Statement;
use async_trait::async_trait;
use futures_core::Stream;
use futures_util::StreamExt;
use std::any::TypeId;
use std::pin::Pin;
use std::sync::Arc;

#[async_trait]
pub trait IReadonlyRepository<T: Entity = Row>: IRepository {
    fn is_schema_required(&self) -> bool {
        true
    }

    fn to_crud(self: Arc<Self>) -> Option<Arc<dyn ICRUDRepository<T>>>
    where
        Self: Sized,
    {
        None
    }

    async fn read_single(
        &self,
        query: Option<&dyn Statement>,
        options: Option<&crate::ReadonlyRepositoryMappingOptions>,
    ) -> Result<Option<T>>;
    fn read<'a>(
        &'a self,
        query: Option<&'a dyn Statement>,
        options: Option<&'a crate::ReadonlyRepositoryMappingOptions>,
    ) -> Pin<Box<dyn Stream<Item = Result<T>> + Send + 'a>>;
    async fn read_single_where(
        &self,
        clause: &dyn IWhere,
        options: Option<&crate::ReadonlyRepositoryMappingOptions>,
    ) -> Result<Option<T>>;
    fn read_where<'a>(
        &'a self,
        clause: &'a dyn IWhere,
        options: Option<&'a crate::ReadonlyRepositoryMappingOptions>,
    ) -> Pin<Box<dyn Stream<Item = Result<T>> + Send + 'a>>;
}

#[async_trait]
pub trait ICRUDRepository<T: Entity = Row>: IReadonlyRepository<T> {
    async fn create(&self, item: T) -> Result<T>;
    async fn update(&self, item: T, by_where: Option<&dyn IWhere>) -> Result<Response>;
    async fn delete(&self, item: T, by_where: Option<&dyn IWhere>) -> Result<Response>;
    async fn read_single_by_id(&self, id: &dyn IdKey) -> Result<Option<T>>;

    fn id_names(&self) -> Vec<String> {
        Vec::new()
    }

    fn add_middleware(&self, _middleware: Arc<dyn CommandMiddleware>) {}
}

struct AsReadonly<T: Entity>(Arc<dyn ICRUDRepository<T>>);

impl<T: Entity> IRepository for AsReadonly<T> {
    fn entity_type(&self) -> TypeId {
        self.0.entity_type()
    }

    fn schema(&self) -> &Schema {
        self.0.schema()
    }
}

#[async_trait]
impl<T: Entity> IReadonlyRepository<T> for AsReadonly<T> {
    async fn read_single(
        &self,
        query: Option<&dyn Statement>,
        options: Option<&crate::ReadonlyRepositoryMappingOptions>,
    ) -> Result<Option<T>> {
        self.0.read_single(query, options).await
    }

    fn read<'a>(
        &'a self,
        query: Option<&'a dyn Statement>,
        options: Option<&'a crate::ReadonlyRepositoryMappingOptions>,
    ) -> Pin<Box<dyn Stream<Item = Result<T>> + Send + 'a>> {
        self.0.read(query, options)
    }

    async fn read_single_where(
        &self,
        clause: &dyn IWhere,
        options: Option<&crate::ReadonlyRepositoryMappingOptions>,
    ) -> Result<Option<T>> {
        self.0.read_single_where(clause, options).await
    }

    fn read_where<'a>(
        &'a self,
        clause: &'a dyn IWhere,
        options: Option<&'a crate::ReadonlyRepositoryMappingOptions>,
    ) -> Pin<Box<dyn Stream<Item = Result<T>> + Send + 'a>> {
        self.0.read_where(clause, options)
    }
}

pub fn as_readonly<T: Entity>(repo: Arc<dyn ICRUDRepository<T>>) -> Arc<dyn IReadonlyRepository<T>> {
    Arc::new(AsReadonly(repo))
}

pub(crate) fn map_row<T: Entity>(row: Row) -> Result<T> {
    T::object_converter().convert(&row)
}

pub(crate) fn to_stored<T: Entity>(item: &T) -> Result<Row> {
    T::object_converter().reverse_convert(item)
}

pub(crate) fn map_stream<'a, T: Entity>(
    rows: Pin<Box<dyn Stream<Item = Result<Row>> + Send + 'a>>,
) -> Pin<Box<dyn Stream<Item = Result<T>> + Send + 'a>> {
    Box::pin(rows.map(|row| row.and_then(map_row)))
}