bios-basic 0.2.0

An embeddable message queue system
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

use std::env;

use bios_basic::process::task_processor::TaskProcessor;
use bios_basic::test::init_test_container;
use tardis::basic::result::TardisResult;
use tardis::{testcontainers, tokio, TardisFuns};

#[tokio::test]
async fn test_task_processor() -> TardisResult<()> {
    env::set_var("RUST_LOG", "debug,test_iam_serv=trace,sqlx::query=off,sqlparser=off");
    let _x = init_test_container::init(None).await?;

    let cache_client = TardisFuns::inst("".to_string(), None).cache();

    TaskProcessor::set_status("test1", 1, true, &cache_client).await?;
    assert!(TaskProcessor::check_status("test1", 1, &cache_client).await?);
    assert!(!TaskProcessor::check_status("test1", u32::MAX as u64, &cache_client).await?);
    assert!(!TaskProcessor::check_status("test1", u32::MAX as u64 + 1, &cache_client).await?);
    assert!(!TaskProcessor::check_status("test1", u64::MAX, &cache_client).await?);

    TaskProcessor::set_status("test1", u32::MAX as u64, true, &cache_client).await?;
    assert!(TaskProcessor::check_status("test1", 1, &cache_client).await?);
    assert!(TaskProcessor::check_status("test1", u32::MAX as u64, &cache_client).await?);
    assert!(!TaskProcessor::check_status("test1", u32::MAX as u64 + 1, &cache_client).await?);
    assert!(!TaskProcessor::check_status("test1", u64::MAX, &cache_client).await?);

    TaskProcessor::set_status("test1", u32::MAX as u64 + 1, true, &cache_client).await?;
    assert!(TaskProcessor::check_status("test1", 1, &cache_client).await?);
    assert!(TaskProcessor::check_status("test1", u32::MAX as u64, &cache_client).await?);
    assert!(TaskProcessor::check_status("test1", u32::MAX as u64 + 1, &cache_client).await?);
    assert!(!TaskProcessor::check_status("test1", u64::MAX, &cache_client).await?);

    TaskProcessor::set_status("test1", u64::MAX, true, &cache_client).await?;
    assert!(TaskProcessor::check_status("test1", 1, &cache_client).await?);
    assert!(TaskProcessor::check_status("test1", u32::MAX as u64, &cache_client).await?);
    assert!(TaskProcessor::check_status("test1", u32::MAX as u64 + 1, &cache_client).await?);
    assert!(TaskProcessor::check_status("test1", u64::MAX, &cache_client).await?);

    TaskProcessor::set_status("test1", 1, false, &cache_client).await?;
    assert!(!TaskProcessor::check_status("test1", 1, &cache_client).await?);
    assert!(TaskProcessor::check_status("test1", u32::MAX as u64, &cache_client).await?);
    assert!(TaskProcessor::check_status("test1", u32::MAX as u64 + 1, &cache_client).await?);
    assert!(TaskProcessor::check_status("test1", u64::MAX, &cache_client).await?);

    assert!(!TaskProcessor::check_status("test2", u32::MAX as u64 + 1, &cache_client).await?);

    Ok(())
}