pubky-homeserver 0.9.1

Pubky core's homeserver.
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::persistence::files::layer_domain_error::LayerDomainError;

/// Error type for file operations.
#[derive(Debug, thiserror::Error)]
pub enum FileIoError {
    #[error("File not found")]
    NotFound,
    #[error("DB error: {0}")]
    SqlDb(#[from] sqlx::Error),
    #[error("OpenDAL error: {0}")]
    OpenDAL(opendal::Error),
    #[error("Temp file error: {0}")]
    TempFile(#[from] std::io::Error),
    #[error(transparent)]
    StreamBroken(#[from] WriteStreamError),
    #[error("Disk space quota exceeded")]
    DiskSpaceQuotaExceeded,
    #[error("Write to path is forbidden")]
    WritePathForbidden,
}

impl From<opendal::Error> for FileIoError {
    fn from(e: opendal::Error) -> Self {
        use std::error::Error as _;
        // Recover domain-specific errors embedded by our custom OpenDAL layers.
        if let Some(domain) = e
            .source()
            .and_then(|s| s.downcast_ref::<LayerDomainError>())
        {
            return match domain {
                LayerDomainError::WritePathForbidden => FileIoError::WritePathForbidden,
                LayerDomainError::DiskSpaceQuotaExceeded => FileIoError::DiskSpaceQuotaExceeded,
            };
        }
        match e.kind() {
            opendal::ErrorKind::NotFound => FileIoError::NotFound,
            _ => FileIoError::OpenDAL(e),
        }
    }
}

/// A unified error type for writing streams.
#[derive(Debug, thiserror::Error)]
pub enum WriteStreamError {
    #[error("Axum error: {0}")]
    Axum(#[from] axum::Error),
    #[error("Other error: {0}")]
    Other(#[from] anyhow::Error),
}