show how to decode the payload

Author: Sebastien Stormacq

Examples/Streaming+APIGateway/Package.swift

@@ -10,10 +10,11 @@ let package = Package(
     ],
     dependencies: [
         // For local development (default)
-        .package(name: "swift-aws-lambda-runtime", path: "../..")
+        .package(name: "swift-aws-lambda-runtime", path: "../.."),
 
         // For standalone usage, comment the line above and uncomment below:
         // .package(url: "https://github.com/awslabs/swift-aws-lambda-runtime.git", from: "1.0.0"),
+        .package(url: "https://github.com/awslabs/swift-aws-lambda-events.git", from: "1.0.0"),
     ],
     targets: [
         .executableTarget(

Examples/Streaming+APIGateway/Sources/main.swift

@@ -13,6 +13,7 @@
 //
 //===----------------------------------------------------------------------===//
 
+import AWSLambdaEvents
 import AWSLambdaRuntime
 import NIOCore
 
@@ -29,6 +30,11 @@ struct SendNumbersWithPause: StreamingLambdaHandler {
         context: LambdaContext
     ) async throws {
 
+        // the payload here is an API Gateway V1 request 
+        // Check the body of the request to extract the business event
+        let payload = try JSONDecoder().decode(APIGatewayRequest.self, from: Data(event.readableBytesView))
+        let _ = payload.body
+        
         // Send HTTP status code and headers before streaming the response body
         try await responseWriter.writeStatusAndHeaders(
             StreamingLambdaStatusAndHeadersResponse(

Examples/Streaming+FunctionUrl/Package.swift

@@ -10,10 +10,12 @@ let package = Package(
     ],
     dependencies: [
         // For local development (default)
-        .package(name: "swift-aws-lambda-runtime", path: "../..")
+        .package(name: "swift-aws-lambda-runtime", path: "../.."),
 
         // For standalone usage, comment the line above and uncomment below:
         // .package(url: "https://github.com/awslabs/swift-aws-lambda-runtime.git", from: "1.0.0"),
+
+        .package(url: "https://github.com/awslabs/swift-aws-lambda-events.git", from: "1.0.0"),
     ],
     targets: [
         .executableTarget(

Examples/Streaming+FunctionUrl/Sources/main.swift

@@ -13,6 +13,7 @@
 //
 //===----------------------------------------------------------------------===//
 
+import AWSLambdaEvents
 import AWSLambdaRuntime
 import NIOCore
 
@@ -29,6 +30,11 @@ struct SendNumbersWithPause: StreamingLambdaHandler {
         context: LambdaContext
     ) async throws {
 
+        // The payload here is a FunctionURLRequest.  
+        // Check the body parameters for the business event
+        let payload = try JSONDecoder().decode(FunctionURLRequest.self, from: Data(event.readableBytesView))
+        let _ = payload.body
+        
         // Send HTTP status code and headers before streaming the response body
         try await responseWriter.writeStatusAndHeaders(
             StreamingLambdaStatusAndHeadersResponse(