AppFlowy/frontend/rust-lib/flowy-task/tests/task_test/task_order_test.rs

use crate::task_test::script::{
    make_text_background_task, make_text_user_interactive_task, SearchScript::*, SearchTest,
};

#[tokio::test]
async fn task_add_single_background_task_test() {
    let test = SearchTest::new().await;
    let (task, ret) = make_text_background_task(test.next_task_id().await, "");
    test.run_scripts(vec![AddTask { task }]).await;

    let result = ret.await.unwrap();
    assert!(result.state.is_done())
}

#[tokio::test]
async fn task_add_multiple_background_tasks_test() {
    let test = SearchTest::new().await;
    let (task_1, ret_1) = make_text_background_task(test.next_task_id().await, "");
    let (task_2, ret_2) = make_text_background_task(test.next_task_id().await, "");
    let (task_3, ret_3) = make_text_background_task(test.next_task_id().await, "");
    test.run_scripts(vec![
        AddTask { task: task_1 },
        AddTask { task: task_2 },
        AddTask { task: task_3 },
        AssertExecuteOrder {
            execute_order: vec![3, 2, 1],
            rets: vec![ret_1, ret_2, ret_3],
        },
    ])
    .await;
}

#[tokio::test]
async fn task_add_multiple_user_interactive_tasks_test() {
    let test = SearchTest::new().await;
    let (task_1, ret_1) = make_text_user_interactive_task(test.next_task_id().await, "");
    let (task_2, ret_2) = make_text_user_interactive_task(test.next_task_id().await, "");
    let (task_3, ret_3) = make_text_user_interactive_task(test.next_task_id().await, "");
    test.run_scripts(vec![
        AddTask { task: task_1 },
        AddTask { task: task_2 },
        AddTask { task: task_3 },
        AssertExecuteOrder {
            execute_order: vec![3, 2, 1],
            rets: vec![ret_1, ret_2, ret_3],
        },
    ])
    .await;
}
#[tokio::test]
async fn task_add_multiple_different_kind_tasks_test() {
    let test = SearchTest::new().await;
    let (task_1, ret_1) = make_text_background_task(test.next_task_id().await, "");
    let (task_2, ret_2) = make_text_user_interactive_task(test.next_task_id().await, "");
    let (task_3, ret_3) = make_text_background_task(test.next_task_id().await, "");
    test.run_scripts(vec![
        AddTask { task: task_1 },
        AddTask { task: task_2 },
        AddTask { task: task_3 },
        AssertExecuteOrder {
            execute_order: vec![2, 3, 1],
            rets: vec![ret_1, ret_2, ret_3],
        },
    ])
    .await;
}

#[tokio::test]
async fn task_add_multiple_different_kind_tasks_test2() {
    let test = SearchTest::new().await;
    let mut tasks = vec![];
    let mut rets = vec![];

    for i in 0..10 {
        let (task, ret) = if i % 2 == 0 {
            make_text_background_task(test.next_task_id().await, "")
        } else {
            make_text_user_interactive_task(test.next_task_id().await, "")
        };
        tasks.push(task);
        rets.push(ret);
    }

    test.run_scripts(vec![
        AddTasks { tasks },
        AssertExecuteOrder {
            execute_order: vec![10, 8, 6, 4, 2, 9, 7, 5, 3, 1],
            rets,
        },
    ])
    .await;
}

// #[tokio::test]
// async fn task_add_1000_tasks_test() {
//     let test = SearchTest::new().await;
//     let mut tasks = vec![];
//     let mut execute_order = vec![];
//     let mut rets = vec![];
//
//     for i in 1..1000 {
//         let (task, ret) = make_text_background_task(test.next_task_id().await, "");
//         execute_order.push(i);
//         tasks.push(task);
//         rets.push(ret);
//     }
//     execute_order.reverse();
//
//     test.run_scripts(vec![AddTasks { tasks }, AssertExecuteOrder { execute_order, rets }])
//         .await;
// }