toasty_driver_integration_suite/tests/

crud_create_macro.rs

use crate::prelude::*;

#[driver_test(id(ID), scenario(crate::scenarios::two_models))]
pub async fn create_macro_simple(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    // Create using the macro — translates to: User::create().name("Carl")
    let user = toasty::create!(User { name: "Carl" }).exec(&mut db).await?;

    assert_eq!(user.name, "Carl");

    // Verify it persisted
    let reloaded = User::get_by_id(&mut db, &user.id).await?;
    assert_eq!(reloaded.name, "Carl");

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::user_name_email))]
pub async fn create_macro_multiple_fields(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    // Create with multiple fields
    let user = toasty::create!(User {
        name: "Carl",
        email: "carl@example.com"
    })
    .exec(&mut db)
    .await?;

    assert_eq!(user.name, "Carl");
    assert_eq!(user.email, "carl@example.com");

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::two_models))]
pub async fn create_macro_with_variable(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    let name = "Carl";

    // Explicit `name: name` — field and variable have the same identifier
    let user = toasty::create!(User { name: name }).exec(&mut db).await?;

    assert_eq!(user.name, "Carl");

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::two_models))]
pub async fn create_macro_with_different_variable(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    let user_name = "Carl";

    // Explicit `name: expr` where the expression differs from the field name
    let user = toasty::create!(User { name: user_name })
        .exec(&mut db)
        .await?;

    assert_eq!(user.name, "Carl");

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::has_many_belongs_to))]
pub async fn create_macro_scoped(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    let user = User::create().name("Alice").exec(&mut db).await?;

    // Scoped create — translates to: user.todos().create().title("get something done")
    let todo = toasty::create!(in user.todos() { title: "get something done" })
        .exec(&mut db)
        .await?;

    assert_eq!(todo.title, "get something done");
    assert_eq!(todo.user_id, user.id);

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::two_models))]
pub async fn create_macro_batch(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    // Same-type batch — expands to toasty::batch([...]), returns Vec<User>
    let users = toasty::create!(User::[
        { name: "Carl" },
        { name: "Bob" },
    ])
    .exec(&mut db)
    .await?;

    assert_struct!(users, [{ name: "Carl" }, { name: "Bob" }]);

    Ok(())
}

#[driver_test(id(ID), requires(scan), scenario(crate::scenarios::two_models))]
pub async fn create_macro_tuple(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    // Tuple syntax — returns (User, Post)
    let (user, post) = toasty::create!((User { name: "Carl" }, Post { title: "Hello" },))
        .exec(&mut db)
        .await?;

    assert_struct!(user, { name: "Carl" });
    assert_struct!(post, { title: "Hello" });

    Ok(())
}

#[driver_test(id(ID), requires(scan), scenario(crate::scenarios::two_models))]
pub async fn create_macro_tuple_mixed(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    // Mixed tuple: typed batch + single create — returns (Vec<User>, Post)
    let (users, post) = toasty::create!((
        User::[ { name: "Carl" }, { name: "Bob" } ],
        Post { title: "Hello" },
    ))
    .exec(&mut db)
    .await?;

    assert_struct!(users, [{ name: "Carl" }, { name: "Bob" }]);
    assert_struct!(post, { title: "Hello" });

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::has_many_belongs_to))]
pub async fn create_macro_nested_association(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    // Nested association — no type prefix needed; type inferred from field.
    let user = toasty::create!(User {
        name: "Carl",
        todos: [{ title: "get something done" }]
    })
    .exec(&mut db)
    .await?;

    assert_eq!(user.name, "Carl");

    let todos: Vec<_> = user.todos().exec(&mut db).await?;
    assert_eq!(todos.len(), 1);
    assert_eq!(todos[0].title, "get something done");

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::has_many_belongs_to))]
pub async fn create_macro_nested_multiple(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    // Multiple nested associations
    let user = toasty::create!(User {
        name: "Carl",
        todos: [{ title: "first" }, { title: "second" }]
    })
    .exec(&mut db)
    .await?;

    assert_eq!(user.name, "Carl");

    let mut todos: Vec<_> = user.todos().exec(&mut db).await?;
    assert_eq!(todos.len(), 2);

    todos.sort_by(|a, b| a.title.cmp(&b.title));
    assert_eq!(todos[0].title, "first");
    assert_eq!(todos[1].title, "second");

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::has_many_belongs_to))]
pub async fn create_macro_with_belongs_to(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    // Create a todo with an inline belongs_to user
    let todo = toasty::create!(Todo {
        title: "buy milk",
        user: { name: "Carl" }
    })
    .exec(&mut db)
    .await?;

    assert_eq!(todo.title, "buy milk");

    // The user should have been created inline
    let user = User::get_by_id(&mut db, &todo.user_id).await?;
    assert_eq!(user.name, "Carl");

    Ok(())
}

#[driver_test(id(ID))]
pub async fn create_macro_deeply_nested(test: &mut Test) -> Result<()> {
    #[derive(Debug, toasty::Model)]
    struct User {
        #[key]
        #[auto]
        id: ID,

        name: String,

        #[has_many]
        todos: toasty::Deferred<Vec<Todo>>,
    }

    #[derive(Debug, toasty::Model)]
    struct Todo {
        #[key]
        #[auto]
        id: ID,

        #[index]
        user_id: ID,

        #[belongs_to(key = user_id, references = id)]
        user: toasty::Deferred<User>,

        title: String,

        #[has_many]
        tags: toasty::Deferred<Vec<Tag>>,
    }

    #[derive(Debug, toasty::Model)]
    struct Tag {
        #[key]
        #[auto]
        id: ID,

        #[index]
        todo_id: ID,

        #[belongs_to(key = todo_id, references = id)]
        todo: toasty::Deferred<Todo>,

        name: String,
    }

    let mut db = test.setup_db(models!(User, Todo, Tag)).await;

    // Three levels deep: User → Todo → Tag
    let user = toasty::create!(User {
        name: "Carl",
        todos: [{
            title: "get something done",
            tags: [{ name: "urgent" }, { name: "work" }]
        }]
    })
    .exec(&mut db)
    .await?;

    assert_eq!(user.name, "Carl");

    let todos: Vec<_> = user.todos().exec(&mut db).await?;
    assert_eq!(todos.len(), 1);
    assert_eq!(todos[0].title, "get something done");

    let mut tags: Vec<_> = todos[0].tags().exec(&mut db).await?;
    tags.sort_by(|a, b| a.name.cmp(&b.name));
    assert_eq!(tags.len(), 2);
    assert_eq!(tags[0].name, "urgent");
    assert_eq!(tags[1].name, "work");

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::two_models))]
pub async fn create_macro_field_shorthand(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    let name = "Carl".to_string();

    // Field shorthand — `name` is equivalent to `name: name`
    let user = toasty::create!(User { name }).exec(&mut db).await?;

    assert_eq!(user.name, "Carl");

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::user_name_email))]
pub async fn create_macro_field_shorthand_multiple(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    let name = "Carl".to_string();
    let email = "carl@example.com".to_string();

    // Multiple shorthand fields
    let user = toasty::create!(User { name, email }).exec(&mut db).await?;

    assert_eq!(user.name, "Carl");
    assert_eq!(user.email, "carl@example.com");

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::user_name_email))]
pub async fn create_macro_field_shorthand_mixed(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    let name = "Carl".to_string();

    // Mix shorthand and explicit fields
    let user = toasty::create!(User {
        name,
        email: "carl@example.com"
    })
    .exec(&mut db)
    .await?;

    assert_eq!(user.name, "Carl");
    assert_eq!(user.email, "carl@example.com");

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::has_many_belongs_to))]
pub async fn create_macro_field_shorthand_scoped(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    let user = User::create().name("Alice").exec(&mut db).await?;

    let title = "get something done".to_string();

    // Shorthand in scoped create
    let todo = toasty::create!(in user.todos() { title })
        .exec(&mut db)
        .await?;

    assert_eq!(todo.title, "get something done");
    assert_eq!(todo.user_id, user.id);

    Ok(())
}

#[driver_test(id(ID), scenario(crate::scenarios::two_models))]
pub async fn create_macro_field_shorthand_batch(test: &mut Test) -> Result<()> {
    let mut db = setup(test).await;

    let name = "Carl".to_string();

    // Shorthand in batch create
    let users = toasty::create!(User::[
        { name },
        { name: "Bob" },
    ])
    .exec(&mut db)
    .await?;

    assert_struct!(users, [{ name: "Carl" }, { name: "Bob" }]);

    Ok(())
}