puerto 0.13.0

Puerto — Rust full-stack DDD framework CLI. Scaffolds Clean Architecture projects with auto-wired DI, SQLx support, and zero manual wiring. Formerly puerto-framework.
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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

// Phase 11.0 (T-24): every CRUD entity's id is its own type.
use super::*;

/// Scaffolds a fieldless CRUD `Product` and returns the project directory.
fn scaffold_crud_product(name: &str, db: bool) -> PathBuf {
    let dir = temp_dir(name);
    cleanup(&dir);
    setup_puerto_stubs(&dir);
    if db {
        fs::create_dir_all(dir.join("infrastructure/migrations")).unwrap();
    }
    scaffold::run("Product", &dir, db, true, &[], &[]).unwrap();
    dir
}

fn read(dir: &Path, path: &str) -> String {
    fs::read_to_string(dir.join(path)).unwrap()
}

#[test]
fn model_declares_an_id_type_for_the_entity() {
    let dir = scaffold_crud_product("typed_id_model", false);

    let model = read(&dir, "business/src/domain/product/model.rs");
    assert!(model.contains("pub struct ProductId(Uuid);"));
    assert!(model.contains("pub fn generate() -> Self"));
    assert!(model.contains("pub fn from_uuid(value: Uuid) -> Self"));
    assert!(model.contains("pub fn value(&self) -> Uuid"));
    assert!(model.contains("impl std::fmt::Display for ProductId"));
    assert!(model.contains("pub id: ProductId,"));
    assert!(model.contains("id: ProductId::generate(),"));

    cleanup(&dir);
}

#[test]
fn use_case_params_and_repository_take_the_id_type() {
    let dir = scaffold_crud_product("typed_id_ports", false);

    for uc in ["get_product", "update_product", "delete_product"] {
        let content = read(
            &dir,
            &format!("business/src/domain/product/use_cases/{uc}.rs"),
        );
        assert!(content.contains("pub id: ProductId,"), "{uc}");
        assert!(!content.contains("Uuid"), "{uc} still names Uuid");
    }
    let repository = read(&dir, "business/src/domain/product/repository.rs");
    assert!(repository.contains("async fn find_by_id(&self, id: ProductId)"));
    assert!(!repository.contains("Uuid"));

    cleanup(&dir);
}

#[test]
fn application_tests_ask_for_a_missing_id_with_the_id_type() {
    let dir = scaffold_crud_product("typed_id_application", false);

    for uc in ["get_product", "update_product", "delete_product"] {
        let content = read(&dir, &format!("business/src/application/product/{uc}.rs"));
        assert!(content.contains("ProductId::generate()"), "{uc}");
        assert!(!content.contains("Uuid"), "{uc} still names Uuid");
    }

    cleanup(&dir);
}

#[test]
fn routes_and_dto_convert_at_the_edge() {
    let dir = scaffold_crud_product("typed_id_presentation", false);

    let routes = read(&dir, "presentation/src/api/product/routes.rs");
    assert!(routes.contains("ProductId::from_uuid(id.0)"));
    assert!(!routes.contains("{ id: id.0 }"));
    let dto = read(&dir, "presentation/src/api/product/dto.rs");
    assert!(dto.contains("pub id: Uuid,"));
    assert!(dto.contains("id: entity.id.value(),"));

    cleanup(&dir);
}

#[test]
fn postgres_row_keeps_a_uuid_and_converts() {
    let dir = scaffold_crud_product("typed_id_postgres", true);

    let entity = read(&dir, "infrastructure/src/product/entity.rs");
    assert!(entity.contains("pub id: Uuid,"));
    assert!(entity.contains("id: ProductId::from_uuid(row.id),"));
    assert!(entity.contains("id: entity.id.value(),"));
    let repository = read(&dir, "infrastructure/src/product/repository.rs");
    assert!(repository.contains("async fn find_by_id(&self, id: ProductId)"));
    assert!(repository.contains("id.value()"));
    assert!(repository.contains("find_by_id(ProductId::generate())"));
    assert!(!repository.contains("Uuid"));

    cleanup(&dir);
}

#[test]
fn inmemory_repository_takes_the_id_type() {
    let dir = scaffold_crud_product("typed_id_inmemory", false);

    let repository = read(&dir, "infrastructure/src/product/repository.rs");
    assert!(repository.contains("async fn find_by_id(&self, id: ProductId)"));
    assert!(!repository.contains("Uuid"));

    cleanup(&dir);
}

#[test]
fn a_uuid_field_still_imports_uuid_next_to_the_id_type() {
    let dir = temp_dir("typed_id_uuid_field");
    cleanup(&dir);
    setup_puerto_stubs(&dir);
    let fields = vec![scaffold_test_field("owner", "Uuid")];
    scaffold::run("Product", &dir, false, true, &fields, &[]).unwrap();

    let update = read(
        &dir,
        "business/src/domain/product/use_cases/update_product.rs",
    );
    assert!(update.contains("pub id: ProductId,"));
    assert!(update.contains("pub owner: Uuid,"));
    assert_eq!(update.matches("use uuid::Uuid;").count(), 1);

    cleanup(&dir);
}