csm-rs 0.96.0

A library for Shasta
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

use std::io;

use manta_backend_dispatcher::error::Error as MantaError;
use serde_json::Value;

#[derive(thiserror::Error, Debug)]
pub enum Error {
  #[error("CSM-RS: {0}")]
  Message(String),
  #[error("CSM-RS > IO: {0}")]
  IoError(#[from] io::Error),
  #[error("CSM-RS > Serde: {0}")]
  SerdeError(#[from] serde_json::Error),
  #[error("CSM-RS > Net: {0}")]
  NetError(#[from] reqwest::Error),
  #[error("http request:\nresponse: {response}\npayload: {payload}")]
  RequestError {
    response: reqwest::Error,
    payload: String, // NOTE: CSM/OCHAMI Apis either returns plain text or a json therefore, we
                     // will just return a String
  },
  #[error("CSM-RS > CSM: {}", .0.get("detail").and_then(|detail| detail.as_str()).unwrap_or("Unknown error"))]
  CsmError(Value),
  #[error("CSM-RS > Console: {0}")]
  ConsoleError(String),
  #[error("CSM-RS > K8s: {0}")]
  K8sError(String),
  #[error("CSM-RS > Image '{0}' not found")]
  ImageNotFound(String),
  #[error("CSM-RS > Group '{0}' not found")]
  GroupNotFound(String),
  #[error("ERROR - No derivatives found for CFS Configuration: {0}")]
  ConfigurationDerivativesNotFound(String),
  #[error("ERROR - CFS Configuration already exists: {0}")]
  ConfigurationAlreadyExists(String),
  #[error("ERROR - CFS Configuration used as a runtime configuration for a cluster and/or used to build an image used to boot node(s)")]
  ConfigurationUsedAsRuntimeConfigurationOrUsedToBuildBootImageUsed,
}

// Convert Error to manta_backend_dispatcher::error::Error
impl Into<MantaError> for crate::error::Error {
  fn into(self) -> MantaError {
    match self {
      Error::IoError(e) => MantaError::IoError(e),
      Error::SerdeError(e) => MantaError::SerdeError(e),
      Error::NetError(e) => MantaError::NetError(e),
      Error::RequestError { response, payload } => {
        MantaError::RequestError { response, payload }
      }
      // Error::CsmError(e) => MantaError::CsmError(e),
      Error::CsmError(serde_value) => {
        if serde_value.get("title")
          == Some(&Value::String("Session not found.".to_string()))
        {
          MantaError::SessionNotFound
        } else if serde_value.get("title")
          == Some(&Value::String("Configuration not found".to_string()))
        {
          MantaError::ConfigurationNotFound
        } else {
          MantaError::CsmError(serde_value)
        }
      }
      _ => MantaError::Message(self.to_string()),
    }
  }
}