autumn-plugin-turso 0.3.0

TursoDB plugin for Autumn: an embedded, SQLite-compatible database handle with config, migrations, health and metrics
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

//! The plugin error type.

/// An error from the Turso plugin.
#[derive(Debug, thiserror::Error)]
#[non_exhaustive]
pub enum TursoError {
    /// The configuration is not valid. The message names the key.
    #[error("invalid turso config: {0}")]
    Config(String),

    /// The database file or its directory is not available.
    #[error("cannot open turso database at `{path}`: {source}")]
    Open {
        /// The database path.
        path: String,
        /// The cause.
        #[source]
        source: Box<dyn std::error::Error + Send + Sync>,
    },

    /// The engine returned an error.
    #[error("turso: {0}")]
    Database(#[from] turso::Error),

    /// A migration failed. The plugin tried to roll it back.
    #[error("turso migration `{id}` failed: {message}")]
    Migration {
        /// The migration id.
        id: String,
        /// The cause.
        message: String,
    },

    /// A migration id is empty.
    #[error("a turso migration id is empty")]
    InvalidMigration,

    /// An applied migration changed after it was applied.
    #[error(
        "turso migration `{id}` changed after it was applied \
         (applied checksum {applied}, current checksum {current}); add a new migration instead"
    )]
    MigrationChecksum {
        /// The migration id.
        id: String,
        /// The checksum in the database.
        applied: String,
        /// The checksum of the current SQL.
        current: String,
    },

    /// Two migrations use the same id.
    #[error("turso migration id `{0}` is used more than once")]
    DuplicateMigration(String),

    /// The database is read-only and migrations are pending.
    #[error("turso database is read-only and these migrations are pending: {}", .0.join(", "))]
    ReadOnlyPending(Vec<String>),

    /// The plugin started a second time in one app.
    #[error("turso plugin is already started")]
    AlreadyStarted,

    /// The handle is closed.
    #[error("turso database is closed")]
    Closed,

    /// The plugin is not installed or is disabled.
    #[error("turso plugin is not installed or is disabled")]
    NotInstalled,

    /// The config has `[turso.sync]`, but the crate has no `sync` feature.
    #[error("`[turso.sync]` is set, but the `sync` feature of autumn-plugin-turso is off")]
    SyncFeatureDisabled,

    /// You called a sync operation on a local database.
    #[error("turso sync is not configured for this database")]
    SyncNotConfigured,

    /// A sync operation failed.
    #[error("turso sync failed: {0}")]
    Sync(String),
}

/// A result with [`TursoError`].
pub type Result<T, E = TursoError> = std::result::Result<T, E>;