force-sync 0.1.0

Correctness-first bidirectional Salesforce and Postgres sync engine
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
51
52
53
54
55

//! Embedded Postgres migration runner for force-sync.

use deadpool_postgres::Pool;

use crate::error::ForceSyncError;

const MIGRATIONS: &[(i32, &str)] = &[
    (1, include_str!("../../../migrations/0001_init.sql")),
    (
        2,
        include_str!("../../../migrations/0002_force_sync_outbox.sql"),
    ),
];

/// Applies the force-sync schema migrations in version order.
///
/// # Errors
///
/// Returns a database or pool error if the migration cannot be applied.
pub async fn migrate(pool: &Pool) -> Result<(), ForceSyncError> {
    let mut client = pool.get().await?;
    let transaction = client.transaction().await?;

    let mut migration_table_exists: bool = transaction
        .query_one(
            "select to_regclass('public.force_sync_schema_migrations') is not null",
            &[],
        )
        .await?
        .get(0);

    for &(version, sql) in MIGRATIONS {
        let already_applied = if migration_table_exists {
            transaction
                .query_opt(
                    "select 1 from force_sync_schema_migrations where version = $1",
                    &[&version],
                )
                .await?
                .is_some()
        } else {
            false
        };

        if already_applied {
            continue;
        }

        transaction.batch_execute(sql).await?;
        migration_table_exists = true;
    }

    transaction.commit().await?;
    Ok(())
}