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
63
64
65
66
67
68
69
70
71
72
73
74
75

//! Tests for restricting breaking-change scanning to pending migrations.

use super::pending;
use crate::database::migrations::{ledger, MigrationDirection};
use crate::database::DatabaseConnection;
use std::path::PathBuf;
use std::sync::Arc;

/// Builds an in-memory SQLite ledger.
async fn sqlite_ledger() -> DatabaseConnection {
    let pool = sqlx::SqlitePool::connect("sqlite::memory:")
        .await
        .expect("failed to open in-memory sqlite database");
    let connection = DatabaseConnection::Sqlite(Arc::new(pool));
    ledger::ensure_table(&connection)
        .await
        .expect("failed to create ledger table");
    connection
}

#[tokio::test]
async fn applied_migrations_are_excluded() {
    let connection = sqlite_ledger().await;
    let applied = "20251114211514-add_targeting_metadata_columns";
    let pending_id = "20251120000000-zone_id_nullable";

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

    let directories = vec![
        PathBuf::from(format!("./config/database/migrations/{applied}")),
        PathBuf::from(format!("./config/database/migrations/{pending_id}")),
    ];

    // The scanner must not warn about (and therefore block on) a migration the
    // ledger already records, because applying it would be a no-op.
    let result = pending::filter(&connection, directories).await;

    assert_eq!(result.len(), 1);
    assert!(result[0].ends_with(pending_id));
}

#[tokio::test]
async fn legacy_bare_name_entries_are_excluded() {
    let connection = sqlite_ledger().await;

    // A ledger written by an older version stored bare names.
    ledger::record(
        &connection,
        "add_targeting_metadata_columns",
        MigrationDirection::Up,
    )
    .await
    .unwrap();

    let directories = vec![PathBuf::from(
        "./config/database/migrations/20251114211514-add_targeting_metadata_columns",
    )];

    assert!(pending::filter(&connection, directories).await.is_empty());
}

#[tokio::test]
async fn unrecorded_migrations_are_kept() {
    let connection = sqlite_ledger().await;
    let directories = vec![PathBuf::from(
        "./config/database/migrations/20251120000000-zone_id_nullable",
    )];

    assert_eq!(
        pending::filter(&connection, directories.clone()).await,
        directories
    );
}