ckandex 0.6.3

An indexer and API for CKAN, written in Rust.
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

use crate::{CacheClient, Mod, QueryFilterContainer, QueryResponse};

pub struct Query {
    pub filters: Vec<QueryFilterContainer>,
}

impl Default for Query {
    fn default() -> Self {
        return Self {
            filters: Vec::new(),
        };
    }
}

impl Query {
    pub fn new() -> Self {
        return Self {
            filters: Vec::new(),
        };
    }

    pub fn execute(&self, cache: CacheClient) -> QueryResponse {
        let netkans = cache.netkans.unwrap();
        let frozen = cache.frozen.unwrap();

        let netkans = netkans
            .iter()
            .map(|v| Mod::from_netkan(v.clone()))
            .collect::<Vec<Mod>>();

        let frozen = frozen
            .iter()
            .map(|v| Mod::from_frozen(v.clone()))
            .collect::<Vec<Mod>>();

        let mut res_netkan: Vec<Mod> = netkans;
        let mut res_frozen: Vec<Mod> = frozen;

        for filter in &self.filters {
            res_netkan = filter.inner.filter(res_netkan);
            res_frozen = filter.inner.filter(res_frozen);
        }

        return QueryResponse {
            netkans: res_netkan,
            frozen: res_frozen,
        };
    }
}