hammerwork 1.15.5

A high-performance, database-driven job queue for Rust with PostgreSQL and MySQL support, featuring job prioritization, cron scheduling, event streaming (Kafka/Kinesis/PubSub), webhooks, rate limiting, Prometheus metrics, and comprehensive monitoring
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

//! Debug test for result storage

mod test_utils;

#[tokio::test]
#[cfg(feature = "mysql")]
async fn test_mysql_direct_result_storage() {
    let queue = test_utils::setup_mysql_queue().await;

    // Create a simple job with result storage
    let job = Job::new("test_queue".to_string(), json!({"test": "data"}))
        .with_result_storage(ResultStorage::Database);

    let job_id = queue.enqueue(job).await.unwrap();

    // Manually store a result
    let result_data = json!({"success": true, "message": "Test result"});
    queue
        .store_job_result(job_id, result_data.clone(), None)
        .await
        .unwrap();

    // Retrieve the result
    let stored_result = queue.get_job_result(job_id).await.unwrap();
    assert!(stored_result.is_some());
    assert_eq!(stored_result.unwrap(), result_data);

    println!("Direct result storage works!");
}

#[tokio::test]
#[cfg(feature = "postgres")]
async fn test_postgres_direct_result_storage() {
    let queue = test_utils::setup_postgres_queue().await;

    // Create a simple job with result storage
    let job = Job::new("test_queue".to_string(), json!({"test": "data"}))
        .with_result_storage(ResultStorage::Database);

    let job_id = queue.enqueue(job).await.unwrap();

    // Manually store a result
    let result_data = json!({"success": true, "message": "Test result"});
    queue
        .store_job_result(job_id, result_data.clone(), None)
        .await
        .unwrap();

    // Retrieve the result
    let stored_result = queue.get_job_result(job_id).await.unwrap();
    assert!(stored_result.is_some());
    assert_eq!(stored_result.unwrap(), result_data);

    println!("Direct result storage works!");
}

#[tokio::test]
#[cfg(feature = "mysql")]
async fn test_mysql_job_completion() {
    let queue = test_utils::setup_mysql_queue().await;

    // Create and enqueue job
    let job = Job::new("completion_test".to_string(), json!({"test": "completion"}))
        .with_result_storage(ResultStorage::Database);

    let job_id = queue.enqueue(job).await.unwrap();

    // Dequeue the job
    let job = queue.dequeue("completion_test").await.unwrap().unwrap();
    println!("Job result config: {:?}", job.result_config);

    // Mark job as completed with result
    let result_data = json!({"completed": true});
    queue
        .store_job_result(job_id, result_data.clone(), None)
        .await
        .unwrap();
    queue.complete_job(job_id).await.unwrap();

    // Check result
    let result = queue.get_job_result(job_id).await.unwrap();
    assert!(result.is_some());
}