htsget-storage 0.7.0

Storage interfaces and abstractions for htsget-rs.
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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

//! Error and result types for htsget-storage.
//!

use htsget_config::types::HtsGetError;
use std::io;
use std::net::AddrParseError;
use thiserror::Error;

/// The result type for storage.
pub type Result<T> = core::result::Result<T, StorageError>;

/// Storage error type.
#[derive(Error, Debug)]
pub enum StorageError {
  #[error("wrong key derived from ID: {0}")]
  InvalidKey(String),

  #[error("key not found in storage: {0}")]
  KeyNotFound(String),

  #[error("{0}: {1}")]
  IoError(String, io::Error),

  #[error("server error: {0}")]
  ServerError(String),

  #[error("invalid input: {0}")]
  InvalidInput(String),

  #[error("invalid uri: {0}")]
  InvalidUri(String),

  #[error("invalid address: {0}")]
  InvalidAddress(AddrParseError),

  #[error("unsupported format: {0}")]
  UnsupportedFormat(String),

  #[error("internal error: {0}")]
  InternalError(String),

  #[error("response error: {0}")]
  ResponseError(String),

  #[cfg(feature = "aws")]
  #[error("aws error: {0}, with key: {1}")]
  AwsS3Error(String, String),

  #[error("parsing url: {0}")]
  UrlParseError(String),
}

impl From<StorageError> for HtsGetError {
  fn from(err: StorageError) -> Self {
    match err {
      err @ StorageError::InvalidInput(_) => Self::InvalidInput(err.to_string()),
      err @ (StorageError::KeyNotFound(_)
      | StorageError::InvalidKey(_)
      | StorageError::ResponseError(_)) => Self::NotFound(err.to_string()),
      err @ StorageError::IoError(_, _) => Self::IoError(err.to_string()),
      err @ StorageError::UnsupportedFormat(_) => Self::UnsupportedFormat(err.to_string()),
      err @ (StorageError::ServerError(_)
      | StorageError::InvalidUri(_)
      | StorageError::InvalidAddress(_)
      | StorageError::InternalError(_)) => Self::InternalError(err.to_string()),
      #[cfg(feature = "aws")]
      err @ StorageError::AwsS3Error(_, _) => Self::IoError(err.to_string()),
      err @ StorageError::UrlParseError(_) => Self::ParseError(err.to_string()),
    }
  }
}

impl From<HtsGetError> for StorageError {
  fn from(err: HtsGetError) -> Self {
    match err {
      HtsGetError::NotFound(err) => Self::KeyNotFound(err),
      HtsGetError::UnsupportedFormat(err) => Self::UnsupportedFormat(err),
      HtsGetError::InvalidInput(err) | HtsGetError::InvalidRange(err) => Self::InvalidInput(err),
      HtsGetError::IoError(err) => Self::IoError(err.to_string(), io::Error::other(err)),
      HtsGetError::ParseError(err) | HtsGetError::InternalError(err) => Self::InternalError(err),
    }
  }
}

impl From<StorageError> for io::Error {
  fn from(err: StorageError) -> Self {
    match err {
      StorageError::IoError(_, ref io_error) => Self::new(io_error.kind(), err),
      err => Self::other(err),
    }
  }
}

impl From<io::Error> for StorageError {
  fn from(error: io::Error) -> Self {
    Self::IoError("io error".to_string(), error)
  }
}

#[cfg(test)]
mod tests {
  use super::*;
  use htsget_config::types::HtsGetError;

  #[test]
  fn htsget_error_from_storage_not_found() {
    let result = HtsGetError::from(StorageError::KeyNotFound("error".to_string()));
    assert!(matches!(result, HtsGetError::NotFound(_)));
  }

  #[test]
  fn htsget_error_from_storage_invalid_key() {
    let result = HtsGetError::from(StorageError::InvalidKey("error".to_string()));
    assert!(matches!(result, HtsGetError::NotFound(_)));
  }
}