ic-query 0.2.17

Internet Computer query CLI for NNS, SNS, and related public network metadata
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::cache_file::{
    CacheFileError, RefreshLockRequest, create_parent_directory, with_refresh_lock,
};
use std::path::Path;

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub struct LockedSnapshotRefreshRequest<'a> {
    pub snapshot_path: &'a Path,
    pub refresh_lock_path: &'a Path,
    pub network: &'a str,
    pub now_unix_secs: u64,
    pub lock_stale_after_seconds: u64,
}

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub struct LockedSnapshotRefreshState {
    pub replaced_existing_snapshot: bool,
}

pub fn with_locked_snapshot_refresh<T, Error>(
    request: LockedSnapshotRefreshRequest<'_>,
    cache_error: impl Fn(CacheFileError) -> Error,
    action: impl FnOnce(LockedSnapshotRefreshState) -> Result<T, Error>,
) -> Result<T, Error> {
    create_parent_directory(request.snapshot_path).map_err(&cache_error)?;
    let state = LockedSnapshotRefreshState {
        replaced_existing_snapshot: request.snapshot_path.is_file(),
    };
    with_refresh_lock(
        RefreshLockRequest {
            lock_path: request.refresh_lock_path,
            target_path: request.snapshot_path,
            network: request.network,
            now_unix_secs: request.now_unix_secs,
            lock_stale_after_seconds: request.lock_stale_after_seconds,
        },
        cache_error,
        || action(state),
    )
}

pub fn run_snapshot_refresh_with_attempts<Output, Error>(
    write_running_attempt: impl FnOnce() -> Result<(), Error>,
    run_refresh: impl FnOnce() -> Result<Output, Error>,
    write_failed_attempt: impl FnOnce(&Error),
) -> Result<Output, Error> {
    write_running_attempt()?;
    match run_refresh() {
        Ok(output) => Ok(output),
        Err(err) => {
            write_failed_attempt(&err);
            Err(err)
        }
    }
}