Function test_log_request

chirpstack/src/stream/api_request.rs:39–72

()

    #[tokio::test]
    async fn test_log_request() {
        let _guard = test::prepare().await;

        let pl = stream::ApiRequestLog {
            service: "ap.Foo".to_string(),
            method: "bar".to_string(),
            metadata: [("user_id".to_string(), "foo_user".to_string())]
                .iter()
                .cloned()
                .collect(),
        };
        log_request(&pl).await.unwrap();

        let key = redis_key("api:stream:request".to_string());
        let srr: StreamReadReply = redis::cmd("XREAD")
            .arg("COUNT")
            .arg(1_usize)
            .arg("STREAMS")
            .arg(&key)
            .arg("0")
            .query_async(&mut get_async_redis_conn().await.unwrap())
            .await
            .unwrap();

        assert_eq!(1, srr.keys.len());
        assert_eq!(1, srr.keys[0].ids.len());

        if let Some(redis::Value::BulkString(b)) = srr.keys[0].ids[0].map.get("request") {
            let pl_recv = stream::ApiRequestLog::decode(&mut Cursor::new(b)).unwrap();
            assert_eq!(pl, pl_recv);
        } else {
            panic!("No request log");
        }
    }
}