edc-dataplane-core 0.2.0

An EDC compatible dataplane
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

use miwa::{
    core::{Extension, ExtensionConfig, MiwaContext, MiwaResult},
    derive::{extension, ExtensionConfig},
};
use serde::Deserialize;

use crate::core::db::{sqlite::transfer::SqliteTransferRepo, transfer::TransferRepoRef};

pub struct SqliteRepoExtension {}

#[async_trait::async_trait]
impl Extension for SqliteRepoExtension {
    async fn start(&self) -> MiwaResult<()> {
        Ok(())
    }

    async fn shutdown(&self) -> MiwaResult<()> {
        Ok(())
    }
}

#[derive(Deserialize, ExtensionConfig)]
#[config(prefix = "db.transfers")]
#[serde(rename_all = "lowercase")]
pub enum TransferDbConfig {
    Sqlite { path: String },
}

#[extension(
    name = "Sqlite store extensions for dataplane",
    provides(TransferRepoRef)
)]
pub async fn sql_repo_extension(
    ctx: &MiwaContext,
    ExtensionConfig(cfg): ExtensionConfig<TransferDbConfig>,
) -> MiwaResult<SqliteRepoExtension> {
    ctx.register(create_transfer_store(cfg).await?);
    Ok(SqliteRepoExtension {})
}

async fn create_transfer_store(cfg: TransferDbConfig) -> anyhow::Result<TransferRepoRef> {
    match cfg {
        TransferDbConfig::Sqlite { path } => {
            let store = SqliteTransferRepo::connect(&format!("sqlite:{}", path)).await?;
            store.migrate().await?;

            Ok(TransferRepoRef::of(store))
        }
    }
}