anzar-shared 0.9.15

Anzar is a lightweight authentication and authorization framework that runs as a separate microservice
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

use sqlx::{Executor, Pool, Sqlite, SqlitePool};

use crate::error::Result;

pub struct SQLite {
    pub pool: Pool<Sqlite>,
}
impl SQLite {
    pub async fn start(conn: &str) -> Result<Self> {
        let pool = SqlitePool::connect(conn).await.inspect_err(|e| {
            tracing::error!(
                error_code = "InternalError::Database",
                "Failed to connect to database - {e}"
            );
        })?;

        pool.execute("PRAGMA foreign_keys = ON;").await?;

        Ok(Self { pool })
    }

    pub async fn run_migrations(&self) -> Result<()> {
        let path = std::path::Path::new("../../migrations/sqlite");
        if path.exists() {
            let migrator = sqlx::migrate::Migrator::new(path).await?;
            migrator.run(&self.pool).await.expect("migrations to run");
        }

        Ok(())
    }
}