add tests for eventbridge and sqs types

Author: Ryan Miville

birdie_snapshots/event_bridge_event.accepted

@@ -0,0 +1,21 @@
+---
+version: 1.2.3
+title: EventBridge event
+file: ./test/glambda_test.gleam
+test_name: eventbridge_event_test
+---
+EventBridgeEvent(
+  id: "2ae770d1-0fca-7b58-8c30-9eb62405a12f",
+  version: "0",
+  account: "000000000000",
+  time: "2024-10-24T17:20:54Z",
+  region: "us-east-1",
+  resources: [],
+  source: "eventbridge.ryanmiville",
+  detail: dict.from_list([
+    #("metadata", dict.from_list([])),
+    #("properties", dict.from_list([
+      #("foo", "hello"),
+    ])),
+  ]),
+)

birdie_snapshots/sqs_batch_response.accepted

@@ -0,0 +1,13 @@
+---
+version: 1.2.3
+title: SQS batch response
+file: ./test/glambda_test.gleam
+test_name: sqs_response_test
+---
+{
+  "batchItemFailures": [
+    {
+      "itemIdentifier": "item_id"
+    }
+  ]
+}

birdie_snapshots/sqs_event.accepted

@@ -0,0 +1,31 @@
+---
+version: 1.2.3
+title: SQS event
+file: ./test/glambda_test.gleam
+test_name: sqs_event_test
+---
+SqsEvent(records: [
+  SqsRecord(
+    message_id: "6cfbd0a8-f7ff-4a02-ba30-5c903f1a8b63",
+    receipt_handle: "AQEBR3x8seJWvgENTZDqpZv6inIs+Bi496ihA/djTyAALXS9JsAwNnOzgip1vnzUNlVb8oFtbvBem64Ea+oonUWRfMKXS1Xi22PsPfbrmb8j8XK4U1tG2LIfMEv+gTwb0Y5079y/Jp+Z0tN1uf2CjgisgA3DqCGs/sNWjH3qfCkdnx3CfQjjw5PHvvJNMEs2b+so9KyexTHiS1NkQQRbIE2aMPdQd4H96OW6KciGAvgphqWBlxkY6/Qrr1HP+2C7W446DTVIfD9LoWS//UzDX CvaNeW8aAE+ZkF2CDjnRQO9K0uVypxXE+aA9fQnq3gyumAQ+GvvhrfXiw4MHnAvrDL0EcX+znQpk4WYNR6mfsXFGuTzST5M9bWbwa3VfRvXvt0Ngk28pxvd5Clhe4gL9DtknXC6/7vDHndiYEOhaC7lqqE=",
+    body: "Hello from the subscriber",
+    attributes: SqsRecordAttributes(
+      aws_trace_header: None,
+      approximate_receive_count: "1",
+      sent_timestamp: "1729789931673",
+      sender_id: "AROA4MTWMMW6B2A6JRWWH:sqs-ryanmiville-MyAppFunction",
+      approximate_first_receive_timestamp: "1729789931679",
+      sequence_number: None,
+      message_group_id: None,
+      message_deduplication_id: None,
+      dead_letter_queue_source_arn: None,
+    ),
+    message_attributes: dict.from_list([
+      ,
+    ]),
+    md5_of_body: "e09fb73883f28f5d83a8ddbedcd8a1f5",
+    event_source: "aws:sqs",
+    event_source_arn: "arn:aws:sqs:us-east-1:000000000000:sqs-ryanmiville-MyQueueQueue",
+    aws_region: "us-east-1",
+  ),
+])

test/glambda_test.gleam

@@ -1,6 +1,7 @@
 import birdie
 import glambda.{
   type ApiGatewayProxyResultV2, type JsEvent, ApiGatewayProxyResultV2,
+  SqsBatchItemFailure, SqsBatchResponse,
 }
 import gleam/dict
 import gleam/option.{None, Some}
@@ -96,6 +97,27 @@ pub fn api_gateway_v2_http_response_valid_empty_fields_test() {
   |> birdie.snap("API Gateway V2 HTTP Response with valid empty fields")
 }
 
+pub fn eventbridge_event_test() {
+  js_event("./test/testdata/eventbridge-event.json")
+  |> glambda.to_eventbridge_event
+  |> format
+  |> birdie.snap("EventBridge event")
+}
+
+pub fn sqs_event_test() {
+  js_event("./test/testdata/sqs-event.json")
+  |> glambda.to_sqs_event
+  |> format
+  |> birdie.snap("SQS event")
+}
+
+pub fn sqs_response_test() {
+  SqsBatchResponse([SqsBatchItemFailure("item_id")])
+  |> glambda.from_sqs_batch_response
+  |> stringify
+  |> birdie.snap("SQS batch response")
+}
+
 // pub fn wisp_request_test() {
 //   js_event("./test/testdata/apigw-v2-request-jwt-authorizer.json")
 //   |> glambda.to_api_gateway_proxy_event_v2

test/testdata/eventbridge-event.json

@@ -0,0 +1,11 @@
+{
+  "version": "0",
+  "id": "2ae770d1-0fca-7b58-8c30-9eb62405a12f",
+  "detail-type": "app.myevent",
+  "source": "eventbridge.ryanmiville",
+  "account": "000000000000",
+  "time": "2024-10-24T17:20:54Z",
+  "region": "us-east-1",
+  "resources": [],
+  "detail": { "metadata": {}, "properties": { "foo": "hello" } }
+}

test/testdata/sqs-event.json

@@ -0,0 +1,20 @@
+{
+  "Records": [
+    {
+      "messageId": "6cfbd0a8-f7ff-4a02-ba30-5c903f1a8b63",
+      "receiptHandle": "AQEBR3x8seJWvgENTZDqpZv6inIs+Bi496ihA/djTyAALXS9JsAwNnOzgip1vnzUNlVb8oFtbvBem64Ea+oonUWRfMKXS1Xi22PsPfbrmb8j8XK4U1tG2LIfMEv+gTwb0Y5079y/Jp+Z0tN1uf2CjgisgA3DqCGs/sNWjH3qfCkdnx3CfQjjw5PHvvJNMEs2b+so9KyexTHiS1NkQQRbIE2aMPdQd4H96OW6KciGAvgphqWBlxkY6/Qrr1HP+2C7W446DTVIfD9LoWS//UzDX CvaNeW8aAE+ZkF2CDjnRQO9K0uVypxXE+aA9fQnq3gyumAQ+GvvhrfXiw4MHnAvrDL0EcX+znQpk4WYNR6mfsXFGuTzST5M9bWbwa3VfRvXvt0Ngk28pxvd5Clhe4gL9DtknXC6/7vDHndiYEOhaC7lqqE=",
+      "body": "Hello from the subscriber",
+      "attributes": {
+        "ApproximateReceiveCount": "1",
+        "SentTimestamp": "1729789931673",
+        "SenderId": "AROA4MTWMMW6B2A6JRWWH:sqs-ryanmiville-MyAppFunction",
+        "ApproximateFirstReceiveTimestamp": "1729789931679"
+      },
+      "messageAttributes": {},
+      "md5OfBody": "e09fb73883f28f5d83a8ddbedcd8a1f5",
+      "eventSource": "aws:sqs",
+      "eventSourceARN": "arn:aws:sqs:us-east-1:000000000000:sqs-ryanmiville-MyQueueQueue",
+      "awsRegion": "us-east-1"
+    }
+  ]
+}