libnoa 0.3.2

AI-native distributed version control
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

pub use anyhow::Result;

#[derive(Debug, thiserror::Error)]
pub enum NoaError {
    #[error("object not found: {id}")]
    ObjectNotFound { id: String },

    #[error("snapshot not found: {id}")]
    SnapshotNotFound { id: String },

    #[error("workspace already exists: {name}")]
    WorkspaceAlreadyExists { name: String },

    #[error("workspace not found: {name}")]
    WorkspaceNotFound { name: String },

    #[error("repository already exists at {path}")]
    RepositoryAlreadyExists { path: String },

    #[error("repository not found at {path}")]
    RepositoryNotFound { path: String },

    #[error("IPFS error: {message}")]
    IpfsError { message: String },

    #[error("IPFS daemon unreachable: {endpoint}")]
    IpfsDaemonUnreachable { endpoint: String },

    #[error("invalid CID: {cid}")]
    InvalidCid { cid: String },

    #[error("remote store error ({backend}): {message}")]
    RemoteStoreError { backend: String, message: String },

    #[error("transport error ({backend}): {message}")]
    TransportError { backend: String, message: String },
}

pub fn is_object_not_found(e: &anyhow::Error) -> bool {
    e.downcast_ref::<NoaError>()
        .is_some_and(|ne| matches!(ne, NoaError::ObjectNotFound { .. }))
}

pub fn is_workspace_already_exists(e: &anyhow::Error) -> bool {
    e.downcast_ref::<NoaError>()
        .is_some_and(|ne| matches!(ne, NoaError::WorkspaceAlreadyExists { .. }))
}

pub fn is_snapshot_not_found(e: &anyhow::Error) -> bool {
    e.downcast_ref::<NoaError>()
        .is_some_and(|ne| matches!(ne, NoaError::SnapshotNotFound { .. }))
}

pub fn is_eof_error(e: &anyhow::Error) -> bool {
    e.downcast_ref::<std::io::Error>()
        .is_some_and(|io_err| io_err.kind() == std::io::ErrorKind::UnexpectedEof)
}

pub fn is_ipfs_daemon_unreachable(e: &anyhow::Error) -> bool {
    e.downcast_ref::<NoaError>()
        .is_some_and(|ne| matches!(ne, NoaError::IpfsDaemonUnreachable { .. }))
}

pub fn remote_err(backend: &str, message: impl std::fmt::Display) -> anyhow::Error {
    NoaError::RemoteStoreError {
        backend: backend.to_string(),
        message: message.to_string(),
    }
    .into()
}

pub fn transport_err(backend: &str, message: impl std::fmt::Display) -> anyhow::Error {
    NoaError::TransportError {
        backend: backend.to_string(),
        message: message.to_string(),
    }
    .into()
}