log and quit on I/O error when echoing in wasi-http example (#1910)

Also, fix the relevant integration tests and ensure they run in CI.

Signed-off-by: Joel Dice <[email protected]>

Author: dicej

.github/workflows/build.yml

@@ -115,9 +115,9 @@ jobs:
           rust-cache: true
           nomad: true
 
-      - name: Cargo Unit Tests
+      - name: Cargo Unit and Integration Tests
         run: |
-          make test-unit
+          make test-unit test-integration
         env:
           CARGO_INCREMENTAL: 0
 

examples/wasi-http-rust-streaming-outgoing-body/spin.toml

@@ -7,7 +7,7 @@ version = "1.0.0"
 
 [[component]]
 id = "wasi-http-async"
-source = "target/wasm32-wasi/release/wasi_http_rust_async.wasm"
+source = "target/wasm32-wasi/release/wasi_http_rust_streaming_outgoing_body.wasm"
 [component.trigger]
 route = "/..."
 executor =  { type = "wasi" }

examples/wasi-http-rust-streaming-outgoing-body/src/lib.rs

@@ -67,9 +67,18 @@ async fn handle_request(request: IncomingRequest, response_out: ResponseOutparam
             ResponseOutparam::set(response_out, Ok(response));
 
             let mut stream = request.into_body_stream();
-            while let Ok(Some(chunk)) = stream.try_next().await {
-                if let Err(e) = body.send(chunk).await {
-                    eprintln!("Error sending body: {e}");
+            while let Some(chunk) = stream.next().await {
+                match chunk {
+                    Ok(chunk) => {
+                        if let Err(e) = body.send(chunk).await {
+                            eprintln!("Error sending body: {e}");
+                            break;
+                        }
+                    }
+                    Err(e) => {
+                        eprintln!("Error receiving body: {e}");
+                        break;
+                    }
                 }
             }
         }

tests/integration.rs

@@ -719,9 +719,12 @@ route = "/..."
             drop(future::select(server, rx).await);
         });
 
-        let controller =
-            SpinTestController::with_manifest("examples/wasi-http-rust-async/spin.toml", &[], &[])
-                .await?;
+        let controller = SpinTestController::with_manifest(
+            "examples/wasi-http-rust-streaming-outgoing-body/spin.toml",
+            &[],
+            &[],
+        )
+        .await?;
 
         let mut request = Client::new().get(format!("http://{}/hash-all", controller.url));
         for path in bodies.keys() {
@@ -765,9 +768,12 @@ route = "/..."
             .collect::<Vec<_>>()
         };
 
-        let controller =
-            SpinTestController::with_manifest("examples/wasi-http-rust-async/spin.toml", &[], &[])
-                .await?;
+        let controller = SpinTestController::with_manifest(
+            "examples/wasi-http-rust-streaming-outgoing-body/spin.toml",
+            &[],
+            &[],
+        )
+        .await?;
 
         let response = Client::new()
             .post(format!("http://{}/echo", controller.url))