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
50
51
52
53
54
55

use crate::spacedock::SpaceDockResolver;
use crate::CKANError;

use super::avc::AVCResolver;
use super::common::ModResolver;
use super::direct::DirectResolver;
use super::github::GitHubResolver;
use super::gitlab::GitLabResolver;
use super::jenkins::JenkinsResolver;
use super::netkan::NetKANResolver;

async fn end_resolve_kref(kref: String, token: String) -> Result<String, CKANError> {
    let avc = AVCResolver::default();
    let spacedock = SpaceDockResolver::default();
    let github = GitHubResolver::default();
    let gitlab = GitLabResolver::default();
    let jenkins = JenkinsResolver::default();
    let direct = DirectResolver::default();

    if avc.should_resolve(kref.clone()) {
        return avc.resolve_url(kref, token).await;
    }

    if spacedock.should_resolve(kref.clone()) {
        return spacedock.resolve_url(kref, token).await;
    }

    if github.should_resolve(kref.clone()) {
        return github.resolve_url(kref, token).await;
    }

    if gitlab.should_resolve(kref.clone()) {
        return gitlab.resolve_url(kref, token).await;
    }

    if jenkins.should_resolve(kref.clone()) {
        return jenkins.resolve_url(kref, token).await;
    }

    if direct.should_resolve(kref.clone()) {
        return direct.resolve_url(kref, token).await;
    }

    return Err(CKANError::UnresolvableKref);
}

pub async fn resolve_kref(kref: String, token: String) -> Result<String, CKANError> {
    let netkan = NetKANResolver::default();

    if netkan.should_resolve(kref.clone()) {
        return end_resolve_kref(netkan.resolve_url(kref, token.clone()).await?, token).await;
    }

    return end_resolve_kref(kref.clone(), token).await;
}