observation-tools 0.0.13

Observation Tools Client Library
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

mod common;

use common::TestServer;
use observation_tools::observe;
use observation_tools::server_client::types::LogLevel;
use observation_tools::server_client::types::ObservationType;
use observation_tools::ObservationLogger;

#[tokio::test]
async fn test_logger() -> anyhow::Result<()> {
  ObservationLogger::init()?;

  let server = TestServer::new().await;
  let client = server.create_client()?;

  let execution = client
    .begin_execution("test-logger")?
    .wait_for_upload()
    .await?;
  let execution_id = execution.id();
  observation_tools::with_execution(execution, async {
    log::info!("info-log");
    observe!("direct-log", "direct-log-payload")
      .wait_for_upload()
      .await?;
    Ok::<_, anyhow::Error>(())
  })
  .await?;
  client.shutdown().await?;

  let observations = server.list_observations(&execution_id).await?;

  assert_eq!(observations.len(), 2);
  let obs = &observations[0];
  assert_eq!(obs.payload.as_str(), Some("info-log"));
  assert_eq!(obs.observation_type, ObservationType::LogEntry);
  assert_eq!(obs.log_level, LogLevel::Info);

  Ok(())
}