Add APIGatewayProxyRequestEvent

lambda/shared/src/main/scala/feral/lambda/events/APIGatewayProxyRequestEvent.scala

@@ -0,0 +1,57 @@
+/*
+ * Copyright 2021 Typelevel
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package feral.lambda
+package events
+
+import io.circe.Decoder
+import natchez.Kernel
+import org.typelevel.ci.CIString
+
+final case class APIGatewayProxyRequestEvent(
+    body: Option[String],
+    resource: String,
+    path: String,
+    httpMethod: String,
+    isBase64Encoded: Boolean,
+    queryStringParameters: Option[Map[String, String]],
+    multiValueQueryStringParameters: Option[Map[String, List[String]]],
+    pathParameters: Option[Map[String, String]],
+    stageVariables: Option[Map[String, String]],
+    headers: Option[Map[String, String]],
+    multiValueHeaders: Option[Map[String, List[String]]]
+)
+
+object APIGatewayProxyRequestEvent {
+
+  implicit def decoder: Decoder[APIGatewayProxyRequestEvent] = Decoder.forProduct11(
+    "body",
+    "resource",
+    "path",
+    "httpMethod",
+    "isBase64Encoded",
+    "queryStringParameters",
+    "multiValueQueryStringParameters",
+    "pathParameters",
+    "stageVariables",
+    "headers",
+    "multiValueHeaders"
+  )(APIGatewayProxyRequestEvent.apply)
+
+  implicit def kernelSource: KernelSource[APIGatewayProxyRequestEvent] =
+    e => Kernel(e.headers.getOrElse(Map.empty).map { case (name, value) => CIString(name) -> value })
+
+}

lambda/shared/src/main/scala/feral/lambda/events/APIGatewayProxyResponseEvent.scala

@@ -0,0 +1,39 @@
+/*
+ * Copyright 2021 Typelevel
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package feral.lambda.events
+
+import io.circe.Encoder
+
+final case class APIGatewayProxyResponseEvent(
+    statusCode: Int,
+    body: String,
+    header: Map[String, String] = Map.empty,
+    multiValueHeaders: Map[String, List[String]] = Map.empty,
+    isBase64Encoded: Boolean = false
+)
+
+object APIGatewayProxyResponseEvent {
+
+  implicit def encoder: Encoder[APIGatewayProxyResponseEvent] = Encoder.forProduct5(
+    "statusCode",
+    "body",
+    "header",
+    "multiValueHeaders",
+    "isBase64Encoded"
+  )(r => (r.statusCode, r.body, r.header, r.multiValueHeaders, r.isBase64Encoded))
+
+}

lambda/shared/src/test/scala/feral/lambda/events/APIGatewayProxyEventSuite.scala

@@ -0,0 +1,160 @@
+/*
+ * Copyright 2021 Typelevel
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package feral.lambda.events
+
+import io.circe.literal._
+import munit.FunSuite
+
+class APIGatewayProxyEventSuite extends FunSuite {
+
+  import APIGatewayProxyEventSuite._
+
+  test("decoder") {
+    event.as[APIGatewayProxyRequestEvent].toTry.get
+  }
+
+}
+
+object APIGatewayProxyEventSuite {
+
+  def event = json"""
+  {
+    "body": "eyJ0ZXN0IjoiYm9keSJ9",
+    "resource": "/{proxy+}",
+    "path": "/path/to/resource",
+    "httpMethod": "POST",
+    "isBase64Encoded": true,
+    "queryStringParameters": {
+      "foo": "bar"
+    },
+    "multiValueQueryStringParameters": {
+      "foo": [
+        "bar"
+      ]
+    },
+    "pathParameters": {
+      "proxy": "/path/to/resource"
+    },
+    "stageVariables": {
+      "baz": "qux"
+    },
+    "headers": {
+      "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8",
+      "Accept-Encoding": "gzip, deflate, sdch",
+      "Accept-Language": "en-US,en;q=0.8",
+      "Cache-Control": "max-age=0",
+      "CloudFront-Forwarded-Proto": "https",
+      "CloudFront-Is-Desktop-Viewer": "true",
+      "CloudFront-Is-Mobile-Viewer": "false",
+      "CloudFront-Is-SmartTV-Viewer": "false",
+      "CloudFront-Is-Tablet-Viewer": "false",
+      "CloudFront-Viewer-Country": "US",
+      "Host": "1234567890.execute-api.us-east-1.amazonaws.com",
+      "Upgrade-Insecure-Requests": "1",
+      "User-Agent": "Custom User Agent String",
+      "Via": "1.1 08f323deadbeefa7af34d5feb414ce27.cloudfront.net (CloudFront)",
+      "X-Amz-Cf-Id": "cDehVQoZnx43VYQb9j2-nvCh-9z396Uhbp027Y2JvkCPNLmGJHqlaA==",
+      "X-Forwarded-For": "127.0.0.1, 127.0.0.2",
+      "X-Forwarded-Port": "443",
+      "X-Forwarded-Proto": "https"
+    },
+    "multiValueHeaders": {
+      "Accept": [
+        "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8"
+      ],
+      "Accept-Encoding": [
+        "gzip, deflate, sdch"
+      ],
+      "Accept-Language": [
+        "en-US,en;q=0.8"
+      ],
+      "Cache-Control": [
+        "max-age=0"
+      ],
+      "CloudFront-Forwarded-Proto": [
+        "https"
+      ],
+      "CloudFront-Is-Desktop-Viewer": [
+        "true"
+      ],
+      "CloudFront-Is-Mobile-Viewer": [
+        "false"
+      ],
+      "CloudFront-Is-SmartTV-Viewer": [
+        "false"
+      ],
+      "CloudFront-Is-Tablet-Viewer": [
+        "false"
+      ],
+      "CloudFront-Viewer-Country": [
+        "US"
+      ],
+      "Host": [
+        "0123456789.execute-api.us-east-1.amazonaws.com"
+      ],
+      "Upgrade-Insecure-Requests": [
+        "1"
+      ],
+      "User-Agent": [
+        "Custom User Agent String"
+      ],
+      "Via": [
+        "1.1 08f323deadbeefa7af34d5feb414ce27.cloudfront.net (CloudFront)"
+      ],
+      "X-Amz-Cf-Id": [
+        "cDehVQoZnx43VYQb9j2-nvCh-9z396Uhbp027Y2JvkCPNLmGJHqlaA=="
+      ],
+      "X-Forwarded-For": [
+        "127.0.0.1, 127.0.0.2"
+      ],
+      "X-Forwarded-Port": [
+        "443"
+      ],
+      "X-Forwarded-Proto": [
+        "https"
+      ]
+    },
+    "requestContext": {
+      "accountId": "123456789012",
+      "resourceId": "123456",
+      "stage": "prod",
+      "requestId": "c6af9ac6-7b61-11e6-9a41-93e8deadbeef",
+      "requestTime": "09/Apr/2015:12:34:56 +0000",
+      "requestTimeEpoch": 1428582896000,
+      "identity": {
+        "cognitoIdentityPoolId": null,
+        "accountId": null,
+        "cognitoIdentityId": null,
+        "caller": null,
+        "accessKey": null,
+        "sourceIp": "127.0.0.1",
+        "cognitoAuthenticationType": null,
+        "cognitoAuthenticationProvider": null,
+        "userArn": null,
+        "userAgent": "Custom User Agent String",
+        "user": null
+      },
+      "path": "/prod/path/to/resource",
+      "resourcePath": "/{proxy+}",
+      "httpMethod": "POST",
+      "apiId": "1234567890",
+      "protocol": "HTTP/1.1"
+    }
+  }
+  """
+
+}