rustyroad 1.7.3

Rusty Road is a framework written in Rust that is based on Ruby on Rails. It is designed to provide the familiar conventions and ease of use of Ruby on Rails, while also taking advantage of the performance and efficiency of Rust.
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
56
57
58
59
60
61
62

//! Baselining records migrations in the ledger without executing them.

use super::support::sqlite_ledger;
use crate::database::migrations::{baseline, ledger, MigrationDirection};
use crate::database::DatabaseConnection;

#[tokio::test]
async fn baselined_migrations_are_then_skipped() {
    let connection = sqlite_ledger().await;
    let id = "20251120000000-zone_id_nullable";

    // Before: genuinely pending, so it would run against a schema that has
    // already moved on, which is the failure mode baseline exists to prevent.
    assert!(
        !ledger::should_skip(&connection, id, MigrationDirection::Up)
            .await
            .unwrap()
    );

    baseline::record_ids(&connection, &[id.to_string()])
        .await
        .unwrap();

    // After: recorded as baselined without executing any SQL.
    assert!(ledger::should_skip(&connection, id, MigrationDirection::Up)
        .await
        .unwrap());

    let DatabaseConnection::Sqlite(pool) = &connection else {
        panic!("expected sqlite connection");
    };
    let (provenance, checksum, verified_at): (String, Option<String>, Option<String>) =
        sqlx::query_as(
            "SELECT provenance, checksum, CAST(verified_at AS TEXT) \
             FROM _rustyroad_migrations WHERE name = ? AND direction = 'up'",
        )
        .bind(id)
        .fetch_one(pool.as_ref())
        .await
        .unwrap();
    assert_eq!(provenance, "baselined");
    assert_eq!(checksum, None);
    assert_eq!(verified_at, None);
}

#[tokio::test]
async fn baseline_reports_only_newly_recorded_migrations() {
    let connection = sqlite_ledger().await;
    let already = "20251114211514-add_columns";
    let pending = "20251120000000-zone_id_nullable";

    ledger::record(&connection, already, MigrationDirection::Up)
        .await
        .unwrap();

    let recorded = baseline::record_ids(&connection, &[already.to_string(), pending.to_string()])
        .await
        .unwrap();

    // The already-applied migration is not re-recorded.
    assert_eq!(recorded, vec![pending.to_string()]);
}