megane 0.0.8

AWS Cloudwatch cli viewer
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

use std::sync::{Arc, Mutex};

use megane::{
    client::LogClient,
    event::LogGroupEvent,
    handler::{loggroup_event_handler::LogGroupEventHandler, EventHandler},
    state::loggroups_state::LogGroupsState,
};

mod common;

#[tokio::test]
async fn test_run() {
    let state = Arc::new(Mutex::new(LogGroupsState::new()));
    let (mut inst_tx, inst_rx) = tokio::sync::mpsc::channel::<LogGroupEvent>(1);
    let mock_client = common::get_mock_client("loggroups_01.json");
    let mut handler =
        LogGroupEventHandler::new(LogClient::new(mock_client), Arc::clone(&state), inst_rx);
    let handle = tokio::spawn(async move {
        handler.run().await.unwrap();
    });
    assert!(inst_tx.send(LogGroupEvent::FetchLogGroups).await.is_ok());
    assert!(inst_tx.send(LogGroupEvent::Abort).await.is_ok());

    let _ = handle.await.unwrap();

    for i in 0..=2 {
        assert_eq!(
            Some(format!("log_group_{}", (i + 1).to_string())),
            state
                .lock()
                .unwrap()
                .log_groups
                .get_item(i)
                .unwrap()
                .log_group_name
        );
        assert_eq!(
            Some((i + 1).to_string()),
            state.lock().unwrap().log_groups.get_item(i).unwrap().arn,
        );
    }
}