aro-fletch 1.0.0

Fletch ORM persistence adapter for the Aro web framework
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

//! Error conversion from fletch errors to aro-core domain errors.

use aro_core::error::RepoError;
use fletch_orm::FletchError;

/// Convert a [`FletchError`] into a [`RepoError`].
#[doc(hidden)]
pub fn from_fletch_err(err: FletchError) -> RepoError {
    match err {
        FletchError::NotFound => RepoError::NotFound,
        other if FletchError::is_unique_violation(&other) => RepoError::Conflict,
        other => RepoError::Unknown(Box::new(other)),
    }
}

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

    #[test]
    fn not_found_maps_to_not_found() {
        let repo_err = from_fletch_err(FletchError::NotFound);
        assert!(matches!(repo_err, RepoError::NotFound));
    }

    #[test]
    fn unique_violation_variant_maps_to_conflict() {
        let err = FletchError::UniqueViolation("duplicate key".into());
        let repo_err = from_fletch_err(err);
        assert!(matches!(repo_err, RepoError::Conflict));
    }

    #[test]
    fn sqlite_unique_violation_maps_to_conflict() {
        let err = FletchError::Database(
            "error returned from database: (code: 2067) UNIQUE constraint failed: users.email"
                .into(),
        );
        let repo_err = from_fletch_err(err);
        assert!(matches!(repo_err, RepoError::Conflict));
    }

    #[test]
    fn postgres_unique_violation_maps_to_conflict() {
        let err = FletchError::Database(
            "error returned from database: duplicate key value violates unique constraint \"users_email_key\""
                .into(),
        );
        let repo_err = from_fletch_err(err);
        assert!(matches!(repo_err, RepoError::Conflict));
    }

    #[test]
    fn mysql_unique_violation_maps_to_conflict() {
        let err = FletchError::Database(
            "error returned from database: Duplicate entry 'alice@example.com' for key 'users.email'"
                .into(),
        );
        let repo_err = from_fletch_err(err);
        assert!(matches!(repo_err, RepoError::Conflict));
    }

    #[test]
    fn database_error_maps_to_unknown() {
        let repo_err = from_fletch_err(FletchError::Database("connection refused".into()));
        assert!(matches!(repo_err, RepoError::Unknown(_)));
    }

    #[test]
    fn pool_closed_maps_to_unknown() {
        let repo_err = from_fletch_err(FletchError::PoolClosed);
        assert!(matches!(repo_err, RepoError::Unknown(_)));
    }
}