docbox-database 0.11.1

Docbox database structures, logic, and migrations
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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

use chrono::Utc;
use docbox_database::{
    migrations::initialize_root_migrations,
    models::root_migration::{CreateRootMigration, RootMigration},
};

use crate::common::database::{test_database, test_database_container};

mod common;

/// Tests a root migration can be created
#[tokio::test]
async fn test_root_migration_create() {
    let db_container = test_database_container().await;
    let db = test_database(&db_container).await;
    initialize_root_migrations(&db).await.unwrap();

    RootMigration::create(
        &db,
        CreateRootMigration {
            name: "test".to_string(),
            applied_at: Utc::now(),
        },
    )
    .await
    .unwrap();

    let migrations = RootMigration::all(&db).await.unwrap();
    assert_eq!(migrations.len(), 1);
    let migration = migrations.first().unwrap();
    assert_eq!(migration.name, "test");
}

/// Tests that inserting a duplicate migration will result in a uniqueness error
#[tokio::test]
async fn test_root_migration_create_duplicate() {
    let db_container = test_database_container().await;
    let db = test_database(&db_container).await;
    initialize_root_migrations(&db).await.unwrap();

    RootMigration::create(
        &db,
        CreateRootMigration {
            name: "test".to_string(),
            applied_at: Utc::now(),
        },
    )
    .await
    .unwrap();

    let error = RootMigration::create(
        &db,
        CreateRootMigration {
            name: "test".to_string(),
            applied_at: Utc::now(),
        },
    )
    .await
    .unwrap_err();
    assert!(error.into_database_error().unwrap().is_unique_violation());
}

/// Tests that all root migrations can be retrieved
#[tokio::test]
async fn test_root_migration_all() {
    let db_container = test_database_container().await;
    let db = test_database(&db_container).await;
    initialize_root_migrations(&db).await.unwrap();

    let migrations = RootMigration::all(&db).await.unwrap();
    assert!(migrations.is_empty());

    RootMigration::create(
        &db,
        CreateRootMigration {
            name: "test".to_string(),
            applied_at: Utc::now(),
        },
    )
    .await
    .unwrap();

    let migrations = RootMigration::all(&db).await.unwrap();
    assert_eq!(migrations.len(), 1);
    let migration = migrations.first().unwrap();
    assert_eq!(migration.name, "test");

    RootMigration::create(
        &db,
        CreateRootMigration {
            name: "test_2".to_string(),
            applied_at: Utc::now(),
        },
    )
    .await
    .unwrap();

    let migrations = RootMigration::all(&db).await.unwrap();
    assert_eq!(migrations.len(), 2);
    let migration = migrations.first().unwrap();
    assert_eq!(migration.name, "test");
    let migration = migrations.get(1).unwrap();
    assert_eq!(migration.name, "test_2");
}