synd-persistence 0.4.0

Persistence adapters for syndicationd
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

#![allow(clippy::needless_raw_string_hashes)]

use sqlx::{Sqlite, Transaction};
use synd_registry::{
    RegistryDbError, RegistryDbResult,
    db::{CommitTx, FeedRegistryDb},
};

use self::error::{IntoDbResult, SqliteResult};
use super::SqliteDatabase;

mod blob;
mod codec;
mod crawl;
mod entry;
mod error;
mod feed;

mod journal;
mod pagination;
mod subscription;
#[cfg(test)]
mod test_support;
mod timeline;

/// SQLite-backed registry database handle.
#[derive(Clone)]
pub struct SqliteFeedRegistryDb {
    db: SqliteDatabase,
}

/// `SQLite` transaction used to atomically update registry state and event progress.
pub struct SqliteRegistryTx<'a> {
    tx: Transaction<'a, Sqlite>,
}

impl SqliteFeedRegistryDb {
    pub fn new(db: SqliteDatabase) -> Self {
        Self { db }
    }
}

impl FeedRegistryDb for SqliteFeedRegistryDb {
    type Tx<'a> = SqliteRegistryTx<'a>;

    async fn begin(&self) -> Result<Self::Tx<'_>, RegistryDbError> {
        let tx = self.db.begin().await?;
        Ok(SqliteRegistryTx { tx })
    }
}

impl CommitTx for SqliteRegistryTx<'_> {
    async fn commit(self) -> RegistryDbResult<()> {
        commit_tx(self.tx).await.db()
    }
}

async fn commit_tx(tx: Transaction<'_, Sqlite>) -> SqliteResult<()> {
    tx.commit().await?;
    Ok(())
}