cgx-core 0.0.9

Core library for cgx, the Rust equivalent of uvx or npx for running Rust crates quickly and easily
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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92

use super::Message;
use crate::{crate_resolver::ResolvedCrate, cratespec::CrateSpec};
use serde::{Deserialize, Serialize};
use std::{path::PathBuf, time::Duration};

/// Messages related to crate resolution and resolution cache operations.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(tag = "event", rename_all = "snake_case")]
pub enum CrateResolutionMessage {
    CacheLookup {
        spec: CrateSpec,
    },
    CacheHit {
        path: PathBuf,
        age_secs: u64,
        ttl_remaining_secs: u64,
    },
    CacheMiss {
        spec: CrateSpec,
    },
    CacheStale {
        spec: CrateSpec,
        age_secs: u64,
    },
    Resolving {
        spec: CrateSpec,
    },
    Resolved {
        resolved: ResolvedCrate,
    },
    CacheStored {
        path: PathBuf,
    },
    UsingStaleFallback {
        spec: CrateSpec,
        age_secs: u64,
    },
}

impl CrateResolutionMessage {
    pub fn cache_lookup(spec: &CrateSpec) -> Self {
        Self::CacheLookup { spec: spec.clone() }
    }

    pub fn cache_hit(path: &std::path::Path, age: Duration, ttl_remaining: Duration) -> Self {
        Self::CacheHit {
            path: path.to_path_buf(),
            age_secs: age.as_secs(),
            ttl_remaining_secs: ttl_remaining.as_secs(),
        }
    }

    pub fn cache_miss(spec: &CrateSpec) -> Self {
        Self::CacheMiss { spec: spec.clone() }
    }

    pub fn cache_stale(spec: &CrateSpec, age: Duration) -> Self {
        Self::CacheStale {
            spec: spec.clone(),
            age_secs: age.as_secs(),
        }
    }

    pub fn resolving(spec: &CrateSpec) -> Self {
        Self::Resolving { spec: spec.clone() }
    }

    pub fn resolved(resolved: &ResolvedCrate) -> Self {
        Self::Resolved {
            resolved: resolved.clone(),
        }
    }

    pub fn cache_stored(path: &std::path::Path) -> Self {
        Self::CacheStored {
            path: path.to_path_buf(),
        }
    }

    pub fn using_stale_fallback(spec: &CrateSpec, age: Duration) -> Self {
        Self::UsingStaleFallback {
            spec: spec.clone(),
            age_secs: age.as_secs(),
        }
    }
}

impl From<CrateResolutionMessage> for Message {
    fn from(msg: CrateResolutionMessage) -> Self {
        Message::CrateResolution(msg)
    }
}