camber 0.4.2

Opinionated async Rust for IO-bound services on top of Tokio
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

#![cfg(feature = "sqs")]

use camber::RuntimeError;
use camber::mq::sqs;
use std::time::Duration;

#[test]
fn sqs_rejects_invalid_max_messages() {
    [0, -1, 11].into_iter().for_each(|max_messages| {
        let err = camber::__private::validate_sqs_receive(max_messages, Duration::from_secs(1))
            .unwrap_err();
        assert!(
            matches!(err, RuntimeError::MessageQueue(_)),
            "expected MessageQueue, got: {err:?}"
        );
    });
}

#[test]
fn sqs_rejects_wait_times_above_service_limit() {
    [Duration::from_secs(21), Duration::MAX]
        .into_iter()
        .for_each(|wait_time| {
            let error = camber::__private::validate_sqs_receive(1, wait_time)
                .expect_err("wait times above twenty seconds must be rejected");
            assert!(matches!(error, RuntimeError::MessageQueue(_)));
        });
}

#[tokio::test(flavor = "current_thread")]
async fn sqs_sync_facade_rejects_current_thread_runtime() {
    let error = match sqs::connect() {
        Ok(_) => panic!("sync SQS unexpectedly accepted a current-thread runtime"),
        Err(error) => error,
    };

    assert!(matches!(error, RuntimeError::MessageQueue(_)));
    assert!(error.to_string().contains("multi-thread"));
}

#[test]
fn sqs_sync_facade_rejects_missing_tokio_runtime() {
    let error = match sqs::connect() {
        Ok(_) => panic!("sync SQS unexpectedly accepted a missing Tokio runtime"),
        Err(error) => error,
    };

    assert!(matches!(error, RuntimeError::MessageQueue(_)));
    assert!(error.to_string().contains("multi-thread"));
}

#[test]
fn sqs_missing_send_message_id_is_an_error() {
    [None, Some("")].into_iter().for_each(|message_id| {
        let error = camber::__private::sqs_message_id(message_id)
            .expect_err("a successful response without a message ID is malformed");

        assert!(matches!(error, RuntimeError::MessageQueue(_)));
    });
}