wip: otel flaky test

Signed-off-by: José Guilherme Vanz <jguilhermevanz@suse.com>

Author: jvanz

tests/integration_test.rs

@@ -941,11 +941,22 @@ async fn test_otel() {
         "OTEL_EXPORTER_OTLP_CLIENT_KEY",
         client_key_file.path().to_str().unwrap(),
     );
+    std::env::set_var("OTEL_METRIC_EXPORT_INTERVAL", "1");
 
     println!("Starting policy server");
     let mut config = default_test_config();
     config.metrics_enabled = true;
     config.log_fmt = "otlp".to_string();
+    // config.policies = HashMap::from([(
+    //     "pod-privileged".to_owned(),
+    //     PolicyOrPolicyGroup::Policy {
+    //         module: "ghcr.io/kubewarden/tests/pod-privileged:v0.2.1".to_owned(),
+    //         policy_mode: PolicyMode::Protect,
+    //         allowed_to_mutate: None,
+    //         settings: None,
+    //         context_aware_resources: BTreeSet::new(),
+    //     },
+    // )]);
     let host = config.addr.ip().to_string();
     let port = config.addr.port().to_string();
     let readiness_probe_port = config.readiness_probe_addr.port().to_string();
@@ -1022,43 +1033,43 @@ async fn test_otel() {
     assert_eq!(spans["scope"]["name"], "kubewarden-policy-server");
     println!("traces check");
 
-    // let metrics_output_json = (|| async {
-    //     let out = otelc.stdout_to_vec().await.unwrap();
-    //     println!(
-    //         "stdout: {}",
-    //         String::from_utf8(out).unwrap_or("cannot get stdout".to_string())
-    //     );
-    //     let out = otelc.stderr_to_vec().await.unwrap();
-    //     println!(
-    //         "stderr: {}",
-    //         String::from_utf8(out).unwrap_or("cannot get stderr".to_string())
-    //     );
-    //     parse_exporter_output(metrics_output_file.as_file()).await
-    // })
-    // .retry(exponential_backoff)
-    // .await
-    // .unwrap();
-    // let metrics = &metrics_output_json["resourceMetrics"][0]["scopeMetrics"][0];
-    // assert_eq!(metrics["scope"]["name"], "kubewarden");
-    // assert!(
-    //     metrics["metrics"]
-    //         .as_array()
-    //         .unwrap()
-    //         .iter()
-    //         .any(|m| { m["name"] == "kubewarden_policy_evaluation_latency_milliseconds" }),
-    //     "metrics_output_json: {}",
-    //     serde_json::to_string_pretty(&metrics_output_json).unwrap()
-    // );
-    // assert!(
-    //     metrics["metrics"]
-    //         .as_array()
-    //         .unwrap()
-    //         .iter()
-    //         .any(|m| { m["name"] == "kubewarden_policy_evaluations_total" }),
-    //     "metrics_output_json: {}",
-    //     serde_json::to_string_pretty(&metrics_output_json).unwrap()
-    // );
-    // println!("metrics check");
+    let metrics_output_json = (|| async {
+        let out = otelc.stdout_to_vec().await.unwrap();
+        println!(
+            "stdout: {}",
+            String::from_utf8(out).unwrap_or("cannot get stdout".to_string())
+        );
+        let out = otelc.stderr_to_vec().await.unwrap();
+        println!(
+            "stderr: {}",
+            String::from_utf8(out).unwrap_or("cannot get stderr".to_string())
+        );
+        parse_exporter_output(metrics_output_file.as_file()).await
+    })
+    .retry(exponential_backoff)
+    .await
+    .unwrap();
+    let metrics = &metrics_output_json["resourceMetrics"][0]["scopeMetrics"][0];
+    assert_eq!(metrics["scope"]["name"], "kubewarden");
+    assert!(
+        metrics["metrics"]
+            .as_array()
+            .unwrap()
+            .iter()
+            .any(|m| { m["name"] == "kubewarden_policy_evaluation_latency_milliseconds" }),
+        "metrics_output_json: {}",
+        serde_json::to_string_pretty(&metrics_output_json).unwrap()
+    );
+    assert!(
+        metrics["metrics"]
+            .as_array()
+            .unwrap()
+            .iter()
+            .any(|m| { m["name"] == "kubewarden_policy_evaluations_total" }),
+        "metrics_output_json: {}",
+        serde_json::to_string_pretty(&metrics_output_json).unwrap()
+    );
+    println!("metrics check");
 
     otelc.stop().await.unwrap();
 }