fusion-common 0.1.0

A data fusion platform with scheduler, ai agent studio and core libraries
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

use serde::Serialize;
use thiserror::Error;

pub trait DataError: core::error::Error + core::fmt::Debug + core::fmt::Display + Serialize {
  fn code(&self) -> i32;

  fn msg(&self) -> &str;

  fn data(&self) -> Option<&serde_json::Value>;

  fn source(&self) -> Option<&(dyn core::error::Error + 'static)>;
}

pub type Result<T> = core::result::Result<T, Error>;

#[derive(Debug, Error)]
pub enum Error {
  // -- Base64
  #[error("Decode base64 fail, string is {0}")]
  FailToB64uDecode(String),

  #[error("Parse date fail, data is {0}")]
  DateFailParse(String),

  #[error("Key fail.")]
  KeyFail,

  #[error("Password not match.")]
  PwdNotMatching,

  #[error("Missing env: {0}")]
  MissingEnv(String),

  #[error("Wrong format: {0}")]
  WrongFormat(String),

  #[error("Failed to set env: {0}, value: {1}, error: {2}")]
  FailedToSetEnv(String, String, String),

  #[error("Failed to remove env: {0}, error: {1}")]
  FailedToRemoveEnv(String, String),
}

impl From<chrono::ParseError> for Error {
  fn from(value: chrono::ParseError) -> Self {
    Error::DateFailParse(value.to_string())
  }
}