context69_contracts/
common.rs

1use schemars::JsonSchema;
2use serde::{Deserialize, Serialize};
3use utoipa::ToSchema;
4
5#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize, ToSchema, JsonSchema)]
6pub struct Pagination {
7    pub page: u32,
8    pub page_size: u32,
9    pub total: u64,
10    pub total_pages: u32,
11}
12
13impl Pagination {
14    pub fn try_new(page: u32, page_size: u32, total: u64) -> anyhow::Result<Self> {
15        if page == 0 {
16            return Err(anyhow::anyhow!("page must be greater than 0"));
17        }
18        if !(1..=100).contains(&page_size) {
19            return Err(anyhow::anyhow!("page_size must be between 1 and 100"));
20        }
21        let total_pages = if total == 0 {
22            0
23        } else {
24            u32::try_from(total.div_ceil(u64::from(page_size)))?
25        };
26        Ok(Self {
27            page,
28            page_size,
29            total,
30            total_pages,
31        })
32    }
33
34    pub fn offset(page: u32, page_size: u32) -> anyhow::Result<i64> {
35        if page == 0 {
36            return Err(anyhow::anyhow!("page must be greater than 0"));
37        }
38        if !(1..=100).contains(&page_size) {
39            return Err(anyhow::anyhow!("page_size must be between 1 and 100"));
40        }
41        i64::from(page - 1)
42            .checked_mul(i64::from(page_size))
43            .ok_or_else(|| anyhow::anyhow!("page offset is too large"))
44    }
45}
46
47#[derive(Debug, Clone, Serialize, Deserialize, ToSchema)]
48#[serde(rename_all = "snake_case")]
49pub enum HealthStatus {
50    Ok,
51    Degraded,
52}
53
54#[derive(Debug, Clone, Serialize, Deserialize, ToSchema)]
55pub struct HealthResponse {
56    pub status: HealthStatus,
57    #[serde(skip_serializing_if = "Option::is_none")]
58    pub indexed_chunks: Option<u64>,
59    #[serde(skip_serializing_if = "Option::is_none")]
60    pub db_ok: Option<bool>,
61    #[serde(skip_serializing_if = "Option::is_none")]
62    pub qdrant_ok: Option<bool>,
63    #[serde(skip_serializing_if = "Option::is_none")]
64    pub library_processing_ready: Option<bool>,
65    #[serde(skip_serializing_if = "Option::is_none")]
66    pub library_dependency_gates: Option<Vec<crate::LibraryDependencyGateResponse>>,
67    #[serde(skip_serializing_if = "Option::is_none")]
68    pub library_processing_queue: Option<crate::LibraryProcessingQueueHealth>,
69}
70
71#[derive(Debug, Clone, Serialize, Deserialize, ToSchema)]
72pub struct ApiErrorResponse {
73    pub error: String,
74}
context69_contracts/common.rs

context69_contracts/
common.rs
