Update Spin and Go versions for actions

.github/workflows/ci.yaml

@@ -46,7 +46,7 @@ jobs:
       - uses: azure/setup-kubectl@v4
       - uses: fermyon/actions/spin/setup@v1
         with:
-          version: "v2.4.2"
+          version: "v2.7.0"
 
       - name: Setup build env
         run: |

.gitignore

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

images/spin/Dockerfile

@@ -1,12 +1,12 @@
-FROM --platform=${BUILDPLATFORM} rust:1.71 AS build
+FROM --platform=${BUILDPLATFORM} rust:1.79 AS build
 WORKDIR /opt/build
 COPY . .
 RUN rustup target add wasm32-wasi && cargo build --target wasm32-wasi --release
 
-FROM --platform=linux/amd64 golang:1.21.3-bullseye AS build-go
+FROM --platform=linux/amd64 golang:1.23.2-bullseye AS build-go
 WORKDIR /opt/build
 COPY . .
-RUN curl -LO https://github.com/tinygo-org/tinygo/releases/download/v0.30.0/tinygo_0.30.0_amd64.deb && dpkg -i tinygo_0.30.0_amd64.deb
+RUN curl -LO https://github.com/tinygo-org/tinygo/releases/download/v0.34.0/tinygo_0.34.0_amd64.deb && dpkg -i tinygo_0.34.0_amd64.deb
 RUN cd go-hello && tinygo build -target=wasi -o spin_go_hello.wasm main.go
 
 FROM scratch

scripts/deploy-workloads.sh

@@ -9,28 +9,16 @@ if ! command -v kubectl &> /dev/null; then
     sudo install -o root -g root -m 0755 kubectl /usr/local/bin/kubectl;
 fi
 
-update_mqtt_workload_with_broker_cluster_ip() {
-    local dir=$1
-    echo "Waiting for emqx pod to be ready"
-    kubectl wait --for=condition=ready --timeout=20s pod/emqx
-    # The MQTT trigger cannot do DNS resolution, so we need to use the IP address of the MQTT broker
-    # Replace "EMQX_CLUSTER_IP" with the actual ClusterIP of the EMQX service
-    local cluster_ip=$(kubectl get svc emqx -o jsonpath='{.spec.clusterIP}')
-    sed -i "s/EMQX_CLUSTER_IP/$cluster_ip/g" $dir/workloads.yaml
-    echo "Updated workloads.yaml with ClusterIP: $cluster_ip"
-}
-
-
 # apply the workloads
 echo ">>> apply workloads"
 kubectl apply -f tests/workloads-common
+# wait for all the pods to be ready
+kubectl wait --for=condition=ready --timeout=120s pod --all
 
 if [ "$1" == "workloads-pushed-using-spin-registry-push" ]; then
-    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"
     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/setup-linux.sh

@@ -8,6 +8,6 @@ sudo rustup target add wasm32-wasi && sudo rustup target add wasm32-unknown-unkn
 
 ## setup tinygo. required for building test spin app
 echo "setting up tinygo"
-wget https://github.com/tinygo-org/tinygo/releases/download/v0.30.0/tinygo_0.30.0_amd64.deb
-sudo dpkg -i tinygo_0.30.0_amd64.deb
-rm tinygo_0.30.0_amd64.deb
+wget https://github.com/tinygo-org/tinygo/releases/download/v0.34.0/tinygo_0.34.0_amd64.deb
+sudo dpkg -i tinygo_0.34.0_amd64.deb
+rm tinygo_0.34.0_amd64.deb

tests/src/integration_test.rs

@@ -135,16 +135,16 @@ mod test {
             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);
+        // Publish a message to the MQTT broker
+        let mut mqttoptions = rumqttc::MqttOptions::new("123", "test.mosquitto.org", mqtt_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)
+            .subscribe(
+                "containerd-shim-spin/mqtt-test-17h24d",
+                rumqttc::QoS::AtMostOnce,
+            )
             .await
             .unwrap();
 
@@ -153,7 +153,7 @@ mod test {
             for _i in 0..iterations {
                 client
                     .publish(
-                        "hello",
+                        "containerd-shim-spin/mqtt-test-17h24d",
                         rumqttc::QoS::AtLeastOnce,
                         false,
                         message.as_bytes(),
@@ -227,20 +227,6 @@ mod test {
         Ok(port)
     }
 
-    async fn port_forward_emqx(emqx_port: u16) -> Result<u16> {
-        let port = get_random_port()?;
-
-        println!(" >>> kubectl portforward emqx {}:{} ", port, emqx_port);
-
-        Command::new("kubectl")
-            .arg("port-forward")
-            .arg("emqx")
-            .arg(format!("{}:{}", port, emqx_port))
-            .spawn()?;
-        tokio::time::sleep(tokio::time::Duration::from_secs(2)).await;
-        Ok(port)
-    }
-
     async fn get_logs_by_label(label: &str) -> Result<String> {
         let output = Command::new("kubectl")
             .arg("logs")

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

@@ -284,11 +284,10 @@ spec:
         - containerPort: 80
         env:
         - name: SPIN_VARIABLE_MQTT_TOPIC
-          value: hello
+          value: containerd-shim-spin/mqtt-test-17h24d
         # 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"
+          value: "mqtt://test.mosquitto.org"
 ---
 apiVersion: v1
 kind: Service

tests/workloads-pushed-using-spin-registry-push/workloads.yaml

@@ -284,11 +284,10 @@ spec:
           - containerPort: 80
           env:
           - name: SPIN_VARIABLE_MQTT_TOPIC
-            value: hello
+            value: containerd-shim-spin/mqtt-test-17h24d
           # 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"
+            value: "mqtt://test.mosquitto.org"
 ---
 apiVersion: v1
 kind: Service