Function test_gateway_duty_cycle_stats

chirpstack/src/api/gateway.rs:1245–1476

()

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

        // setup admin user
        let u = user::User {
            is_admin: true,
            is_active: true,
            email: "admin@admin".into(),
            email_verified: true,
            ..Default::default()
        };
        let u = user::create(u).await.unwrap();

        // create tenant
        let t = tenant::create(tenant::Tenant {
            name: "test-tenant".into(),
            can_have_gateways: true,
            max_gateway_count: 10,
            ..Default::default()
        })
        .await
        .unwrap();

        // create gateway
        let _ = gateway::create(gateway::Gateway {
            gateway_id: EUI64::from_be_bytes([1, 2, 3, 4, 5, 6, 7, 8]),
            tenant_id: t.id,
            name: "test-gw".into(),
            ..Default::default()
        })
        .await
        .unwrap();

        let now = Local::now();

        // insert stats
        let mut m = metrics::Record {
            kind: metrics::Kind::COUNTER,
            time: now,
            metrics: HashMap::new(),
        };

        m.metrics
            .insert("window_perc_M_868000000_868600000_10".into(), 0.5);
        m.metrics
            .insert("max_load_perc_L_865000000_868000000_10".into(), 5.0);

        metrics::save(
            "gw:dc:0102030405060708",
            &m,
            &[metrics::Aggregation::MINUTE],
        )
        .await
        .unwrap();

        // setup api
        let service = Gateway::new(RequestValidator::new());