road-runner-common 0.4.0

Shared Rust utilities for exchange ecosystem backend services.
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

use serde::{Deserialize, Serialize};

#[cfg(feature = "openapi")]
use utoipa::ToSchema;

#[derive(Debug, Clone, Copy, Deserialize)]
#[cfg_attr(feature = "openapi", derive(ToSchema, utoipa::IntoParams))]
pub struct PageRequest {
    #[serde(default = "default_page")]
    pub page: u32, // 1'den başlar

    #[serde(default = "default_size")]
    pub size: u32,
}

fn default_page() -> u32 {
    1
}
fn default_size() -> u32 {
    10
}

impl Default for PageRequest {
    fn default() -> Self {
        Self {
            page: default_page(),
            size: default_size(),
        }
    }
}

impl PageRequest {
    pub fn normalized(self, max_page_size: u32) -> Self {
        let size = self.size.clamp(1, max_page_size.max(1));
        let page = self.page.max(1);
        Self { page, size }
    }

    pub fn offset_limit(self) -> (u32, u32) {
        let page = self.page.max(1);
        let size = self.size.max(1);
        let offset = (page - 1).saturating_mul(size);
        (offset, size)
    }
}

#[derive(Debug, Clone, Serialize)]
#[cfg_attr(feature = "openapi", derive(ToSchema))]
pub struct Paged<T> {
    pub items: Vec<T>,
    pub total_items: u64,
    pub page: u32,
    pub size: u32,
    pub total_pages: u32,
}

impl<T> Paged<T> {
    pub fn new(items: Vec<T>, total_items: u64, page: u32, size: u32) -> Self {
        let size = size.max(1);
        let total_pages = if total_items == 0 {
            0
        } else {
            ((total_items + size as u64 - 1) / size as u64) as u32
        };

        Self {
            items,
            total_items,
            page: page.max(1),
            size,
            total_pages,
        }
    }
}