framework-cqrs-lib 0.4.0

handle state-machine with data persist in journal and store mongo for restfull actix api
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

use async_trait::async_trait;

use crate::cqrs::core::repositories::can_fetch_all::CanFetchAll;
use crate::cqrs::core::repositories::query::{InfoPaged, Page, Paged, Query};
use crate::cqrs::models::errors::ResultErr;

pub mod query;
pub mod can_fetch_all;
pub mod filter;
pub mod entities;
pub mod events;

#[async_trait]
pub trait CanFetchMany<ENTITY: Clone>: CanFetchAll<ENTITY> {
    async fn fetch_many(&self, query: Query) -> ResultErr<Paged<ENTITY>> {
        let entities = self.fetch_all(query.clone()).await?;
        let total_records = entities.len();
        let start = query.pagination.page_number * query.pagination.page_size;
        let end = start.clone() + query.pagination.page_size;
        let max_page = f64::ceil(entities.len() as f64 / query.pagination.page_size as f64) as usize;

        let paged_entities = if entities.is_empty() {
            vec![]
        } else {
            if start > entities.len() {
                vec![]
            } else {
                let sanitize_end = if end > total_records {
                    total_records
                } else {
                    end
                };
                entities.clone().iter().as_slice()[start..sanitize_end].to_vec()
            }
        };

        Ok(
            Paged {
                data: paged_entities,
                meta: InfoPaged {
                    total_pages: max_page,
                    total_records,
                    page: Page {
                        number: query.pagination.page_number,
                        size: query.pagination.page_size,
                    },
                },
            }
        )
    }
}