TEST: remove MQTT test to see if GH runner space issue

Signed-off-by: Kate Goldenring <[email protected]>

Author: kate-goldenring

.gitignore

@@ -9,4 +9,6 @@ target/
 
 .tmp
 
-test/*
+test/*
+
+.vscode/*

scripts/deploy-workloads.sh

@@ -26,11 +26,11 @@ echo ">>> apply workloads"
 kubectl apply -f tests/workloads-common
 
 if [ "$1" == "workloads-pushed-using-spin-registry-push" ]; then
-    update_mqtt_workload_with_broker_cluster_ip "tests/workloads-pushed-using-spin-registry-push"
+    # update_mqtt_workload_with_broker_cluster_ip "tests/workloads-pushed-using-spin-registry-push"
     echo "deploying spin apps pushed to registry using 'spin registry push' command"
     kubectl apply -f tests/workloads-pushed-using-spin-registry-push
 else
-    update_mqtt_workload_with_broker_cluster_ip "tests/workloads-pushed-using-docker-build-push"
+    # update_mqtt_workload_with_broker_cluster_ip "tests/workloads-pushed-using-docker-build-push"
     echo "deploying spin apps pushed to registry using 'docker build && k3d image import' command"
     kubectl apply -f tests/workloads-pushed-using-docker-build-push
 fi

scripts/pod-terminates-test.sh

@@ -7,5 +7,5 @@ kubectl delete pod -l app=wasm-spin --timeout 20s
 kubectl delete pod -l app=spin-keyvalue --timeout 20s
 kubectl delete pod -l app=spin-outbound-redis --timeout 20s
 kubectl delete pod -l app=spin-multi-trigger-app --timeout 20s
-kubectl delete pod -l app=spin-mqtt-message-logger --timeout 20s
+# kubectl delete pod -l app=spin-mqtt-message-logger --timeout 20s
 

tests/src/integration_test.rs

@@ -123,82 +123,82 @@ mod test {
         Ok(())
     }
 
-    #[tokio::test]
-    async fn spin_mqtt_trigger_app_test() -> Result<()> {
-        use std::time::Duration;
-        let mqtt_port = 1883;
-        let message = "MESSAGE";
-        let iterations = 5;
-
-        // Ensure kubectl is in PATH
-        if !is_kubectl_installed().await? {
-            anyhow::bail!("kubectl is not installed");
-        }
-
-        // Port forward the emqx mqtt broker
-        let forward_port = port_forward_emqx(mqtt_port).await?;
-
-        // Publish a message to the emqx broker
-        let mut mqttoptions = rumqttc::MqttOptions::new("123", "127.0.0.1", forward_port);
-        mqttoptions.set_keep_alive(std::time::Duration::from_secs(1));
-
-        let (client, mut eventloop) = rumqttc::AsyncClient::new(mqttoptions, 10);
-        client
-            .subscribe("hello", rumqttc::QoS::AtMostOnce)
-            .await
-            .unwrap();
-
-        // Publish a message several times for redundancy
-        tokio::task::spawn(async move {
-            for _i in 0..iterations {
-                client
-                    .publish(
-                        "hello",
-                        rumqttc::QoS::AtLeastOnce,
-                        false,
-                        message.as_bytes(),
-                    )
-                    .await
-                    .unwrap();
-                tokio::time::sleep(Duration::from_millis(100)).await;
-            }
-        });
-        tokio::time::sleep(Duration::from_secs(5)).await;
-
-        // Poll the event loop to ensure messages are published
-        for _i in 0..iterations {
-            eventloop.poll().await?;
-        }
-        thread::sleep(time::Duration::from_secs(5));
-
-        // Ensure that the message was received and logged by the spin app
-        let log = get_logs_by_label("app=spin-mqtt-message-logger").await?;
-        assert!(log.contains(message));
-        Ok(())
-    }
-
-    #[tokio::test]
-    async fn spin_static_assets_test() -> Result<()> {
-        let host_port = 8082;
-
-        // curl for static asset
-        println!(
-            " >>> curl http://localhost:{}/static-assets/jabberwocky.txt",
-            host_port
-        );
-        let res = retry_get(
-            &format!(
-                "http://localhost:{}/static-assets/jabberwocky.txt",
-                host_port
-            ),
-            RETRY_TIMES,
-            INTERVAL_IN_SECS,
-        )
-        .await?;
-        assert!(String::from_utf8_lossy(&res).contains("'Twas brillig, and the slithy toves"));
-
-        Ok(())
-    }
+    // #[tokio::test]
+    // async fn spin_mqtt_trigger_app_test() -> Result<()> {
+    //     use std::time::Duration;
+    //     let mqtt_port = 1883;
+    //     let message = "MESSAGE";
+    //     let iterations = 5;
+
+    //     // Ensure kubectl is in PATH
+    //     if !is_kubectl_installed().await? {
+    //         anyhow::bail!("kubectl is not installed");
+    //     }
+
+    //     // Port forward the emqx mqtt broker
+    //     let forward_port = port_forward_emqx(mqtt_port).await?;
+
+    //     // Publish a message to the emqx broker
+    //     let mut mqttoptions = rumqttc::MqttOptions::new("123", "127.0.0.1", forward_port);
+    //     mqttoptions.set_keep_alive(std::time::Duration::from_secs(1));
+
+    //     let (client, mut eventloop) = rumqttc::AsyncClient::new(mqttoptions, 10);
+    //     client
+    //         .subscribe("hello", rumqttc::QoS::AtMostOnce)
+    //         .await
+    //         .unwrap();
+
+    //     // Publish a message several times for redundancy
+    //     tokio::task::spawn(async move {
+    //         for _i in 0..iterations {
+    //             client
+    //                 .publish(
+    //                     "hello",
+    //                     rumqttc::QoS::AtLeastOnce,
+    //                     false,
+    //                     message.as_bytes(),
+    //                 )
+    //                 .await
+    //                 .unwrap();
+    //             tokio::time::sleep(Duration::from_millis(100)).await;
+    //         }
+    //     });
+    //     tokio::time::sleep(Duration::from_secs(5)).await;
+
+    //     // Poll the event loop to ensure messages are published
+    //     for _i in 0..iterations {
+    //         eventloop.poll().await?;
+    //     }
+    //     thread::sleep(time::Duration::from_secs(5));
+
+    //     // Ensure that the message was received and logged by the spin app
+    //     let log = get_logs_by_label("app=spin-mqtt-message-logger").await?;
+    //     assert!(log.contains(message));
+    //     Ok(())
+    // }
+
+    // #[tokio::test]
+    // async fn spin_static_assets_test() -> Result<()> {
+    //     let host_port = 8082;
+
+    //     // curl for static asset
+    //     println!(
+    //         " >>> curl http://localhost:{}/static-assets/jabberwocky.txt",
+    //         host_port
+    //     );
+    //     let res = retry_get(
+    //         &format!(
+    //             "http://localhost:{}/static-assets/jabberwocky.txt",
+    //             host_port
+    //         ),
+    //         RETRY_TIMES,
+    //         INTERVAL_IN_SECS,
+    //     )
+    //     .await?;
+    //     assert!(String::from_utf8_lossy(&res).contains("'Twas brillig, and the slithy toves"));
+
+    //     Ok(())
+    // }
 
     async fn is_kubectl_installed() -> anyhow::Result<bool> {
         let output: Result<std::process::Output, std::io::Error> = Command::new("kubectl")

tests/workloads-common/mqtt-broker.yaml

@@ -259,46 +259,46 @@ spec:
       targetPort: 80
   selector:
     app: spin-static-assets
----
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: spin-mqtt-message-logger
-spec:
-  replicas: 1
-  selector:
-    matchLabels:
-      app: spin-mqtt-message-logger
-  template:
-    metadata:
-      labels:
-        app: spin-mqtt-message-logger
-    spec:
-      runtimeClassName: wasmtime-spin
-      containers:
-      - name: spin-mqtt-message-logger
-        image: docker.io/library/spin-mqtt-message-logger:latest
-        imagePullPolicy: IfNotPresent
-        command: ["/"]
-        ports:
-        - containerPort: 80
-        env:
-        - name: SPIN_VARIABLE_MQTT_TOPIC
-          value: hello
-        # The MQTT trigger cannot do DNS resolution, so we need to use the IP address of the MQTT broker
-        # Substitute `EMQX_CLUSTER_IP` with the result of `kubectl get svc emqx -n default -o jsonpath='{.spec.clusterIP}'`
-        - name: SPIN_VARIABLE_MQTT_BROKER_URI
-          value: "mqtt://EMQX_CLUSTER_IP:1883"
----
-apiVersion: v1
-kind: Service
-metadata:
-  name: spin-mqtt-message-logger
-spec:
-  type: LoadBalancer
-  ports:
-    - protocol: TCP
-      port: 80
-      targetPort: 80
-  selector:
-    app: spin-mqtt-message-logger
+# ---
+# apiVersion: apps/v1
+# kind: Deployment
+# metadata:
+#   name: spin-mqtt-message-logger
+# spec:
+#   replicas: 1
+#   selector:
+#     matchLabels:
+#       app: spin-mqtt-message-logger
+#   template:
+#     metadata:
+#       labels:
+#         app: spin-mqtt-message-logger
+#     spec:
+#       runtimeClassName: wasmtime-spin
+#       containers:
+#       - name: spin-mqtt-message-logger
+#         image: docker.io/library/spin-mqtt-message-logger:latest
+#         imagePullPolicy: IfNotPresent
+#         command: ["/"]
+#         ports:
+#         - containerPort: 80
+#         env:
+#         - name: SPIN_VARIABLE_MQTT_TOPIC
+#           value: hello
+#         # The MQTT trigger cannot do DNS resolution, so we need to use the IP address of the MQTT broker
+#         # Substitute `EMQX_CLUSTER_IP` with the result of `kubectl get svc emqx -n default -o jsonpath='{.spec.clusterIP}'`
+#         - name: SPIN_VARIABLE_MQTT_BROKER_URI
+#           value: "mqtt://EMQX_CLUSTER_IP:1883"
+# ---
+# apiVersion: v1
+# kind: Service
+# metadata:
+#   name: spin-mqtt-message-logger
+# spec:
+#   type: LoadBalancer
+#   ports:
+#     - protocol: TCP
+#       port: 80
+#       targetPort: 80
+#   selector:
+#     app: spin-mqtt-message-logger

tests/workloads-pushed-using-docker-build-push/workloads.yaml

@@ -259,46 +259,46 @@ spec:
       targetPort: 80
   selector:
     app: spin-static-assets
----
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: spin-mqtt-message-logger
-spec:
-  replicas: 1
-  selector:
-    matchLabels:
-      app: spin-mqtt-message-logger
-  template:
-    metadata:
-      labels:
-        app: spin-mqtt-message-logger
-    spec:
-      runtimeClassName: wasmtime-spin
-      containers:
-        - name: spin-mqtt-message-logger
-          image: test-registry:5000/spin-registry-push/spin-mqtt-message-logger:latest
-          imagePullPolicy: IfNotPresent
-          command: ["/"]
-          ports:
-          - containerPort: 80
-          env:
-          - name: SPIN_VARIABLE_MQTT_TOPIC
-            value: hello
-          # The MQTT trigger cannot do DNS resolution, so we need to use the IP address of the MQTT broker
-          # Substitute `EMQX_CLUSTER_IP` with the result of `kubectl get svc emqx -n default -o jsonpath='{.spec.clusterIP}'`
-          - name: SPIN_VARIABLE_MQTT_BROKER_URI
-            value: "mqtt://EMQX_CLUSTER_IP:1883"
----
-apiVersion: v1
-kind: Service
-metadata:
-  name: spin-mqtt-message-logger
-spec:
-  type: LoadBalancer
-  ports:
-    - protocol: TCP
-      port: 80
-      targetPort: 80
-  selector:
-    app: spin-mqtt-message-logger
+# ---
+# apiVersion: apps/v1
+# kind: Deployment
+# metadata:
+#   name: spin-mqtt-message-logger
+# spec:
+#   replicas: 1
+#   selector:
+#     matchLabels:
+#       app: spin-mqtt-message-logger
+#   template:
+#     metadata:
+#       labels:
+#         app: spin-mqtt-message-logger
+#     spec:
+#       runtimeClassName: wasmtime-spin
+#       containers:
+#         - name: spin-mqtt-message-logger
+#           image: test-registry:5000/spin-registry-push/spin-mqtt-message-logger:latest
+#           imagePullPolicy: IfNotPresent
+#           command: ["/"]
+#           ports:
+#           - containerPort: 80
+#           env:
+#           - name: SPIN_VARIABLE_MQTT_TOPIC
+#             value: hello
+#           # The MQTT trigger cannot do DNS resolution, so we need to use the IP address of the MQTT broker
+#           # Substitute `EMQX_CLUSTER_IP` with the result of `kubectl get svc emqx -n default -o jsonpath='{.spec.clusterIP}'`
+#           - name: SPIN_VARIABLE_MQTT_BROKER_URI
+#             value: "mqtt://EMQX_CLUSTER_IP:1883"
+# ---
+# apiVersion: v1
+# kind: Service
+# metadata:
+#   name: spin-mqtt-message-logger
+# spec:
+#   type: LoadBalancer
+#   ports:
+#     - protocol: TCP
+#       port: 80
+#       targetPort: 80
+#   selector:
+#     app: spin-mqtt-message-logger