eventbridge example

Author: Ryan Miville

examples/eventbridge/.github/workflows/test.yml

@@ -0,0 +1,23 @@
+name: test
+
+on:
+  push:
+    branches:
+      - master
+      - main
+  pull_request:
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: erlef/setup-beam@v1
+        with:
+          otp-version: "26.0.2"
+          gleam-version: "1.5.1"
+          rebar3-version: "3"
+          # elixir-version: "1.15.4"
+      - run: gleam deps download
+      - run: gleam test
+      - run: gleam format --check src test

examples/eventbridge/.gitignore

@@ -0,0 +1,9 @@
+.DS_Store
+node_modules
+*.beam
+*.ez
+/build
+erl_crash.dump
+
+# sst
+.sst

examples/eventbridge/README.md

@@ -0,0 +1,24 @@
+# eventbridge
+
+[![Package Version](https://img.shields.io/hexpm/v/eventbridge)](https://hex.pm/packages/eventbridge)
+[![Hex Docs](https://img.shields.io/badge/hex-docs-ffaff3)](https://hexdocs.pm/eventbridge/)
+
+```sh
+gleam add eventbridge@1
+```
+```gleam
+import eventbridge
+
+pub fn main() {
+  // TODO: An example of the project in use
+}
+```
+
+Further documentation can be found at <https://hexdocs.pm/eventbridge>.
+
+## Development
+
+```sh
+gleam run   # Run the project
+gleam test  # Run the tests
+```

examples/eventbridge/bun.lockb

@@ -0,0 +1,24 @@
+name = "eventbridge"
+version = "1.0.0"
+target = "javascript"
+
+# Fill out these fields if you intend to generate HTML documentation or publish
+# your project to the Hex package manager.
+#
+# description = ""
+# licences = ["Apache-2.0"]
+# repository = { type = "github", user = "", repo = "" }
+# links = [{ title = "Website", href = "" }]
+#
+# For a full reference of all the available options, you can have a look at
+# https://gleam.run/writing-gleam/gleam-toml/.
+
+[dependencies]
+gleam_stdlib = ">= 0.34.0 and < 2.0.0"
+glambda = { path = "../.." }
+gleam_http = ">= 3.7.0 and < 4.0.0"
+gleam_javascript = ">= 0.13.0 and < 1.0.0"
+
+
+[dev-dependencies]
+gleeunit = ">= 1.0.0 and < 2.0.0"

examples/eventbridge/gleam.toml

@@ -0,0 +1,17 @@
+# This file was generated by Gleam
+# You typically do not need to edit this file
+
+packages = [
+  { name = "glambda", version = "0.1.0", build_tools = ["gleam"], requirements = ["gleam_http", "gleam_javascript", "gleam_stdlib"], source = "local", path = "../.." },
+  { name = "gleam_http", version = "3.7.0", build_tools = ["gleam"], requirements = ["gleam_stdlib"], otp_app = "gleam_http", source = "hex", outer_checksum = "EA66440C2269F7CED0F6845E5BD0DB68095775D627FA709A841CA78A398D6D56" },
+  { name = "gleam_javascript", version = "0.13.0", build_tools = ["gleam"], requirements = ["gleam_stdlib"], otp_app = "gleam_javascript", source = "hex", outer_checksum = "F98328FCF573DA6F3A35D7F6CB3F9FF19FD5224CCBA9151FCBEAA0B983AF2F58" },
+  { name = "gleam_stdlib", version = "0.40.0", build_tools = ["gleam"], requirements = [], otp_app = "gleam_stdlib", source = "hex", outer_checksum = "86606B75A600BBD05E539EB59FABC6E307EEEA7B1E5865AFB6D980A93BCB2181" },
+  { name = "gleeunit", version = "1.2.0", build_tools = ["gleam"], requirements = ["gleam_stdlib"], otp_app = "gleeunit", source = "hex", outer_checksum = "F7A7228925D3EE7D0813C922E062BFD6D7E9310F0BEE585D3A42F3307E3CFD13" },
+]
+
+[requirements]
+glambda = { path = "../.." }
+gleam_http = { version = ">= 3.7.0 and < 4.0.0" }
+gleam_javascript = { version = ">= 0.13.0 and < 1.0.0" }
+gleam_stdlib = { version = ">= 0.34.0 and < 2.0.0" }
+gleeunit = { version = ">= 1.0.0 and < 2.0.0" }

examples/eventbridge/manifest.toml

@@ -0,0 +1,19 @@
+{
+  "name": "eventbridge",
+  "type": "module",
+  "scripts": {
+    "dev": "gleam build && sst dev"
+  },
+  "devDependencies": {
+    "@types/aws-lambda": "8.10.145",
+    "@types/bun": "latest"
+  },
+  "peerDependencies": {
+    "typescript": "^5.0.0"
+  },
+  "dependencies": {
+    "sst": "3.2.48",
+    "valibot": "^0.42.1",
+    "zod": "^3.23.8"
+  }
+}

examples/eventbridge/package.json

@@ -0,0 +1,12 @@
+import glambda.{type Context, type EventBridgeEvent}
+import gleam/io
+import gleam/javascript/promise.{type Promise}
+
+pub fn handle_request(event: EventBridgeEvent, _ctx: Context) -> Promise(Nil) {
+  io.debug(event)
+  promise.resolve(Nil)
+}
+
+pub fn handler(event, ctx) {
+  glambda.eventbridge_handler(handle_request)(event, ctx)
+}

examples/eventbridge/src/eventbridge.gleam

@@ -0,0 +1,24 @@
+import { event } from "sst/event";
+import { bus } from "sst/aws/bus";
+
+import { z } from "zod";
+import { Resource } from "sst";
+import { ZodValidator } from "sst/event/validator";
+
+const defineEvent = event.builder({
+  validator: ZodValidator,
+});
+
+export const MyEvent = defineEvent(
+  "app.myevent",
+  z.object({
+    foo: z.string(),
+  }),
+);
+
+export async function handler() {
+  await bus.publish(Resource.Bus, MyEvent, { foo: "hello" });
+  return {
+    statusCode: 200,
+  };
+}

examples/eventbridge/src/producer.js

@@ -0,0 +1,20 @@
+/* This file is auto-generated by SST. Do not edit. */
+/* tslint:disable */
+/* eslint-disable */
+/* deno-fmt-ignore-file */
+import "sst"
+export {}
+declare module "sst" {
+  export interface Resource {
+    "Bus": {
+      "arn": string
+      "name": string
+      "type": "sst.aws.Bus"
+    }
+    "Fn": {
+      "name": string
+      "type": "sst.aws.Function"
+      "url": string
+    }
+  }
+}

examples/eventbridge/sst-env.d.ts

@@ -0,0 +1,31 @@
+/// <reference path="./.sst/platform/config.d.ts" />
+
+export default $config({
+  app(input) {
+    return {
+      name: "eventbridge",
+      removal: input?.stage === "production" ? "retain" : "remove",
+      home: "aws",
+      providers: {
+        aws: {
+          region: "us-east-1",
+          profile: "personal",
+        },
+      },
+    };
+  },
+  async run() {
+    const bus = new sst.aws.Bus("Bus");
+
+    const fn = new sst.aws.Function("Fn", {
+      handler: "build/dev/javascript/eventbridge/producer.handler",
+      url: true,
+      link: [bus],
+    });
+    bus.subscribe("build/dev/javascript/eventbridge/eventbridge.handler");
+
+    return {
+      url: fn.url,
+    };
+  },
+});

examples/eventbridge/sst.config.ts

@@ -0,0 +1,5 @@
+import gleeunit
+
+pub fn main() {
+  gleeunit.main()
+}

examples/eventbridge/test/eventbridge_test.gleam

@@ -0,0 +1,27 @@
+{
+  "compilerOptions": {
+    // Enable latest features
+    "lib": ["ESNext", "DOM"],
+    "target": "ESNext",
+    "module": "ESNext",
+    "moduleDetection": "force",
+    "jsx": "react-jsx",
+    "allowJs": true,
+
+    // Bundler mode
+    "moduleResolution": "bundler",
+    "allowImportingTsExtensions": true,
+    "verbatimModuleSyntax": true,
+    "noEmit": true,
+
+    // Best practices
+    "strict": true,
+    "skipLibCheck": true,
+    "noFallthroughCasesInSwitch": true,
+
+    // Some stricter flags (disabled by default)
+    "noUnusedLocals": false,
+    "noUnusedParameters": false,
+    "noPropertyAccessFromIndexSignature": false
+  }
+}

examples/eventbridge/tsconfig.json

@@ -193,6 +193,58 @@ pub type EventBridgeEvent {
   )
 }
 
+// --- SQS --------------------------------------------------------------------
+
+pub type SqsEvent {
+  SqsEvent(records: List(SqsRecord))
+}
+
+pub type SqsRecord {
+  SqsRecord(
+    message_id: String,
+    receipt_handle: String,
+    body: String,
+    attributes: SqsRecordAttributes,
+    message_attributes: Dict(String, SqsMessageAttribute),
+    md5_of_body: String,
+    event_source: String,
+    event_source_arn: String,
+    aws_region: String,
+  )
+}
+
+pub type SqsRecordAttributes {
+  SqsRecordAttributes(
+    aws_trace_header: Option(String),
+    approximate_receive_count: String,
+    sent_timestamp: String,
+    sender_id: String,
+    approximate_first_receive_timestamp: String,
+    sequence_number: Option(String),
+    message_group_id: Option(String),
+    message_deduplication_id: Option(String),
+    dead_letter_queue_source_arn: Option(String),
+  )
+}
+
+pub type SqsMessageAttribute {
+  SqsMessageAttribute(
+    string_value: Option(String),
+    binary_value: Option(String),
+    string_list_values: Option(List(String)),
+    binary_list_values: Option(List(String)),
+    data_type: String,
+  )
+}
+
+pub type SqsBatchResponse {
+  SqsBatchResponse(batch_item_failures: List(SqsBatchItemFailure))
+}
+
+pub type SqsBatchItemFailure {
+  SqsBatchItemFailure(item_identifier: String)
+}
+
 // --- Adapters ---------------------------------------------------------------
 
 pub fn http_handler(