errors.rs 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100
  1. use derive_more::Display;
  2. use flowy_derive::{ProtoBuf, ProtoBuf_Enum};
  3. use flowy_dispatch::prelude::{EventResponse, ResponseBuilder};
  4. use std::convert::TryInto;
  5. #[derive(Debug, Default, Clone, ProtoBuf)]
  6. pub struct WorkspaceError {
  7. #[pb(index = 1)]
  8. pub code: WorkspaceErrorCode,
  9. #[pb(index = 2)]
  10. pub msg: String,
  11. }
  12. impl WorkspaceError {
  13. pub fn new(code: WorkspaceErrorCode, msg: &str) -> Self {
  14. Self {
  15. code,
  16. msg: msg.to_owned(),
  17. }
  18. }
  19. }
  20. #[derive(Debug, Clone, ProtoBuf_Enum, Display, PartialEq, Eq)]
  21. pub enum WorkspaceErrorCode {
  22. #[display(fmt = "Unknown")]
  23. Unknown = 0,
  24. #[display(fmt = "Workspace name is invalid")]
  25. WorkspaceNameInvalid = 1,
  26. #[display(fmt = "Workspace id is invalid")]
  27. WorkspaceIdInvalid = 2,
  28. #[display(fmt = "App color style format error")]
  29. AppColorStyleInvalid = 3,
  30. #[display(fmt = "App id is invalid")]
  31. AppIdInvalid = 4,
  32. #[display(fmt = "Get database connection failed")]
  33. DatabaseConnectionFail = 5,
  34. #[display(fmt = "Database internal error")]
  35. WorkspaceDatabaseError = 6,
  36. #[display(fmt = "User internal error")]
  37. UserInternalError = 10,
  38. #[display(fmt = "User not login yet")]
  39. UserNotLoginYet = 11,
  40. }
  41. impl std::default::Default for WorkspaceErrorCode {
  42. fn default() -> Self { WorkspaceErrorCode::Unknown }
  43. }
  44. impl std::convert::From<flowy_database::result::Error> for WorkspaceError {
  45. fn from(error: flowy_database::result::Error) -> Self {
  46. ErrorBuilder::new(WorkspaceErrorCode::WorkspaceDatabaseError)
  47. .error(error)
  48. .build()
  49. }
  50. }
  51. impl flowy_dispatch::Error for WorkspaceError {
  52. fn as_response(&self) -> EventResponse {
  53. let bytes: Vec<u8> = self.clone().try_into().unwrap();
  54. ResponseBuilder::Err().data(bytes).build()
  55. }
  56. }
  57. pub struct ErrorBuilder {
  58. pub code: WorkspaceErrorCode,
  59. pub msg: Option<String>,
  60. }
  61. impl ErrorBuilder {
  62. pub fn new(code: WorkspaceErrorCode) -> Self { ErrorBuilder { code, msg: None } }
  63. pub fn msg<T>(mut self, msg: T) -> Self
  64. where
  65. T: Into<String>,
  66. {
  67. self.msg = Some(msg.into());
  68. self
  69. }
  70. pub fn error<T>(mut self, msg: T) -> Self
  71. where
  72. T: std::fmt::Debug,
  73. {
  74. self.msg = Some(format!("{:?}", msg));
  75. self
  76. }
  77. pub fn build(mut self) -> WorkspaceError {
  78. WorkspaceError::new(self.code, &self.msg.take().unwrap_or("".to_owned()))
  79. }
  80. }