acts-store-postgres 0.17.2

acts store plugin for postgres
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

//! Acts postgres store

#![allow(rustdoc::bare_urls)]
#![doc = include_str!("../README.md")]

mod collection;
mod database;
mod synclient;

// #[cfg(test)]
// mod tests;

use acts::{ActError, ActPlugin, Result};

#[derive(Clone)]
pub struct PostgresStore;

#[derive(serde::Deserialize)]
struct ProgresConfig {
    database_url: String,
}

#[async_trait::async_trait]
impl ActPlugin for PostgresStore {
    async fn on_init(&self, engine: &acts::Engine) -> Result<()> {
        let config = engine
            .config()
            .get::<ProgresConfig>("postgres")
            .map_err(|err| ActError::Config(format!("get postgres config error: {}", err)))?;

        let db = database::Database::new(&config.database_url);
        db.init();

        engine.extender().register_collection(db.packages());
        engine.extender().register_collection(db.models());
        engine.extender().register_collection(db.procs());
        engine.extender().register_collection(db.tasks());
        engine.extender().register_collection(db.messages());
        engine.extender().register_collection(db.events());

        Ok(())
    }
}