1use thiserror::Error;
2
3#[derive(Debug, Error)]
4pub enum AwaError {
5 #[error("job not found: {id}")]
6 JobNotFound { id: i64 },
7
8 #[error("callback not found: {callback_id}")]
9 CallbackNotFound { callback_id: String },
10
11 #[error("unique conflict")]
12 UniqueConflict { constraint: Option<String> },
13
14 #[error("schema not migrated: expected version {expected}, found {found}")]
15 SchemaNotMigrated { expected: i32, found: i32 },
16
17 #[error("unknown job kind: {kind}")]
18 UnknownJobKind { kind: String },
19
20 #[error("validation error: {0}")]
21 Validation(String),
22
23 #[error("serialization error: {0}")]
24 Serialization(#[from] serde_json::Error),
25
26 #[error("database error: {0}")]
27 Database(#[source] sqlx::Error),
28
29 #[cfg(feature = "tokio-postgres")]
30 #[error("tokio-postgres error: {0}")]
31 TokioPg(#[source] tokio_postgres::Error),
32}
33
34impl From<sqlx::Error> for AwaError {
35 fn from(err: sqlx::Error) -> Self {
36 AwaError::Database(err)
37 }
38}