teaql-runtime 0.9.6

TeaQL core, SQL, runtime, dialect, and macro crates for model-driven data access
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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

use teaql_core::EntityError;
use teaql_sql::SqlCompileError;

use crate::CheckResult;

#[derive(Debug)]
pub enum RuntimeError {
    MissingEntity(String),
    SqlCompile(SqlCompileError),
    Behavior(String),
    Event(String),
    Policy(String),
    Check(Vec<CheckResult>),
    Graph(String),
    IdGeneration(String),
    Language(String),
    Schema(String),
    MissingRelation { entity: String, relation: String },
    OptimisticLockConflict { entity: String, id: String },
}

impl std::fmt::Display for RuntimeError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Self::MissingEntity(entity) => write!(f, "missing entity descriptor: {entity}"),
            Self::SqlCompile(err) => err.fmt(f),
            Self::Behavior(message) => write!(f, "repository behavior error: {message}"),
            Self::Event(message) => write!(f, "entity event error: {message}"),
            Self::Policy(message) => write!(f, "request policy error: {message}"),
            Self::Check(results) => {
                let messages = results
                    .iter()
                    .map(ToString::to_string)
                    .collect::<Vec<_>>()
                    .join("; ");
                write!(f, "check failed: {messages}")
            }
            Self::Graph(message) => write!(f, "graph write error: {message}"),
            Self::IdGeneration(message) => write!(f, "id generation error: {message}"),
            Self::Language(message) => write!(f, "language error: {message}"),
            Self::Schema(message) => write!(f, "schema provider error: {message}"),
            Self::MissingRelation { entity, relation } => {
                write!(f, "missing relation {relation} on entity {entity}")
            }
            Self::OptimisticLockConflict { entity, id } => {
                write!(f, "optimistic lock conflict on {entity}({id})")
            }
        }
    }
}

impl std::error::Error for RuntimeError {}

impl From<SqlCompileError> for RuntimeError {
    fn from(value: SqlCompileError) -> Self {
        Self::SqlCompile(value)
    }
}

#[derive(Debug)]
pub enum ContextError {
    MissingResource(String),
    MissingTypedResource(&'static str),
    MissingRepository(String),
}

impl std::fmt::Display for ContextError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Self::MissingResource(name) => write!(f, "missing named resource: {name}"),
            Self::MissingTypedResource(name) => write!(f, "missing typed resource: {name}"),
            Self::MissingRepository(name) => write!(f, "missing repository for entity: {name}"),
        }
    }
}

impl std::error::Error for ContextError {}

#[derive(Debug)]
pub enum RepositoryError<ExecError> {
    Runtime(RuntimeError),
    Entity(EntityError),
    Executor(ExecError),
}

impl<ExecError> std::fmt::Display for RepositoryError<ExecError>
where
    ExecError: std::fmt::Display,
{
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Self::Runtime(err) => err.fmt(f),
            Self::Entity(err) => err.fmt(f),
            Self::Executor(err) => err.fmt(f),
        }
    }
}

impl<ExecError> std::error::Error for RepositoryError<ExecError> where
    ExecError: std::error::Error + 'static
{
}