force-sync 0.2.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

//! `Postgres` test helpers for force-sync integration tests.

use std::env;

use deadpool_postgres::{Config, Pool, Runtime};
use tokio_postgres::NoTls;

use force_sync::ForceSyncError;

/// Builds a `Postgres` pool from `FORCE_SYNC_TEST_DATABASE_URL`.
#[must_use]
pub fn test_pool() -> Pool {
    let url = env::var("FORCE_SYNC_TEST_DATABASE_URL").unwrap_or_else(|_| {
        panic!("FORCE_SYNC_TEST_DATABASE_URL must be set for force-sync PostgreSQL tests")
    });
    let mut config = Config::new();
    config.url = Some(url);

    config
        .create_pool(Some(Runtime::Tokio1), NoTls)
        .unwrap_or_else(|err| {
            panic!("failed to create PostgreSQL pool for force-sync tests: {err}")
        })
}

/// Drops and recreates the `public` schema for a clean test environment.
pub async fn reset_schema(pool: &Pool) -> Result<(), ForceSyncError> {
    let client = pool.get().await?;
    client
        .batch_execute("drop schema if exists public cascade; create schema public;")
        .await?;
    Ok(())
}