microsandbox 0.7.0

`microsandbox` is the core library for the microsandbox project.
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
62
63
64
65
66
67

//! Select a persisted format without upgrading the shared catalog.

use microsandbox_db::catalog::{has_column, has_table};
use sea_orm::{ConnectionTrait, DbBackend, Statement};

use crate::{MicrosandboxError, MicrosandboxResult, SandboxConfig};

//--------------------------------------------------------------------------------------------------
// Functions
//--------------------------------------------------------------------------------------------------

pub(crate) async fn encode_new<C: ConnectionTrait>(
    db: &C,
    config: &SandboxConfig,
) -> MicrosandboxResult<String> {
    let current_migrations =
        microsandbox_migration::schema_metadata::migration_ids().count() as i64;
    let count = db
        .query_one_raw(Statement::from_string(
            DbBackend::Sqlite,
            "SELECT COUNT(*) FROM seaql_migrations",
        ))
        .await?
        .expect("COUNT returns one row")
        .try_get_by_index::<i64>(0)?;
    if count == current_migrations {
        return Ok(serde_json::to_string(config)?);
    }
    // Pre-placement catalogs belong to several incompatible serializers. An
    // existing row supplies the owning representation; schema 14 by itself
    // cannot distinguish v0.6.4's format from v0.6.5's.
    let rows = db
        .query_all_raw(Statement::from_string(
            DbBackend::Sqlite,
            "SELECT config FROM sandbox ORDER BY id",
        ))
        .await?;
    let mut encoded = None;
    for row in rows {
        let original = row.try_get_by_index::<String>(0)?;
        let candidate = super::encoding::encode_like(config, &original)?;
        let value: serde_json::Value = serde_json::from_str(&candidate)?;
        if let Some((_, previous)) = &encoded {
            if previous != &value {
                return Err(ambiguous());
            }
        } else {
            encoded = Some((candidate, value));
        }
    }
    if let Some((encoded, _)) = encoded {
        return Ok(encoded);
    }
    if has_table(db, "cpu_allocation").await? {
        return super::encoding::encode_like(config, include_str!("fixtures/config-0.6.9.json"));
    }
    if !has_column(db, "sandbox", "active_config").await? {
        return super::encoding::encode_like(config, include_str!("fixtures/config-0.6.0.json"));
    }
    Err(ambiguous())
}

fn ambiguous() -> MicrosandboxError {
    MicrosandboxError::InvalidConfig(
        "cannot identify one compatible configuration format for this historical catalog; create the initial sandbox with its owning older CLI before adding sandboxes with this SDK".into(),
    )
}