docbox-management 0.3.0

Management core library for managing docbox used by the cli and other tools
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

use crate::database::{DatabaseProvider, close_pool_on_drop};
use docbox_database::{
    DbErr, ROOT_DATABASE_NAME,
    models::{tenant::Tenant, tenant_migration::TenantMigration},
};
use docbox_search::{SearchError, SearchIndexFactory};
use thiserror::Error;

#[derive(Debug, Error)]
pub enum GetPendingTenantMigrationsError {
    #[error(transparent)]
    Database(#[from] DbErr),

    #[error("failed to apply migration: {0}")]
    GetPendingMigrations(SearchError),
}

#[tracing::instrument(skip(db_provider, search_factory))]
pub async fn get_pending_tenant_search_migrations(
    db_provider: &impl DatabaseProvider,
    search_factory: &SearchIndexFactory,
    tenant: &Tenant,
) -> Result<Vec<String>, GetPendingTenantMigrationsError> {
    // Connect to the root database
    let root_db = db_provider.connect(ROOT_DATABASE_NAME).await?;
    let _guard = close_pool_on_drop(&root_db);

    let applied_migrations =
        TenantMigration::find_by_tenant(&root_db, tenant.id, &tenant.env).await?;
    let search = search_factory.create_search_index(tenant);
    let migrations = search
        .get_pending_migrations(
            applied_migrations
                .into_iter()
                .map(|value| value.name)
                .collect(),
        )
        .await
        .map_err(GetPendingTenantMigrationsError::GetPendingMigrations)?;

    Ok(migrations)
}