canic-core 0.86.1

Canic — a canister orchestration and management toolkit for the Internet Computer
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

//! Module: workflow::pool::query
//!
//! Responsibility: expose read-only pool workflow queries.
//! Does not own: pool storage mutation, endpoint authorization, or DTO schemas.
//! Boundary: workflow query facade over pool storage ops.

use crate::{
    cdk::types::Principal,
    dto::pool::{CanisterPoolEntry, CanisterPoolResponse},
    ops::storage::pool::{
        PoolOps,
        mapper::{CanisterPoolEntryMapper, CanisterPoolResponseMapper},
    },
};

///
/// PoolQuery
///

pub struct PoolQuery;

impl PoolQuery {
    /// Return a view of a single pool entry (if present).
    #[must_use]
    pub fn pool_entry(pid: Principal) -> Option<CanisterPoolEntry> {
        let data = PoolOps::data();

        data.entries
            .into_iter()
            .find(|entry| entry.pid == pid)
            .map(|entry| CanisterPoolEntryMapper::record_to_view(entry.pid, entry.record))
    }

    /// Return a view of the entire pool
    #[must_use]
    pub fn pool_list() -> CanisterPoolResponse {
        let data = PoolOps::data();
        CanisterPoolResponseMapper::data_to_response(data)
    }
}