feat: bring eventbridge

.github/workflows/eventbridge-pull.yaml

@@ -0,0 +1,29 @@
+name: eventbridge-pull
+on:
+  pull_request:
+    paths:
+      - eventbridge/**
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v3
+        with:
+          sparse-checkout: eventbridge
+      - name: Setup Node.js
+        uses: actions/setup-node@v3
+        with:
+          node-version: 18.x
+          registry-url: https://registry.npmjs.org
+      - name: Install winglang
+        run: npm i -g winglang
+      - name: Install dependencies
+        run: npm install --include=dev
+        working-directory: eventbridge
+      - name: Test
+        run: wing test
+        working-directory: eventbridge
+      - name: Pack
+        run: wing pack
+        working-directory: eventbridge

.github/workflows/eventbridge-release.yaml

@@ -0,0 +1,37 @@
+name: eventbridge-release
+on:
+  push:
+    branches:
+      - main
+    paths:
+      - eventbridge/**
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v3
+        with:
+          sparse-checkout: eventbridge
+      - name: Setup Node.js
+        uses: actions/setup-node@v3
+        with:
+          node-version: 18.x
+          registry-url: https://registry.npmjs.org
+      - name: Install winglang
+        run: npm i -g winglang
+      - name: Install dependencies
+        run: npm install --include=dev
+        working-directory: eventbridge
+      - name: Test
+        run: wing test
+        working-directory: eventbridge
+      - name: Pack
+        run: wing pack
+        working-directory: eventbridge
+      - name: Publish
+        run: npm publish --access=public --registry https://registry.npmjs.org --tag
+          latest *.tgz
+        working-directory: eventbridge
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}

eventbridge/.gitignore

@@ -0,0 +1,2 @@
+target/
+node_modules/

eventbridge/LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2023 Wing
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

eventbridge/README.md

@@ -0,0 +1,23 @@
+# eventbridge
+
+## Prerequisites
+
+* [winglang](https://winglang.io).
+
+## Installation
+
+`sh
+npm i @winglibs/eventbridge
+`
+
+## Usage
+
+`js
+bring eventbridge;
+
+let adder = new eventbridge.Adder();
+`
+
+## License
+
+This library is licensed under the [MIT License](./LICENSE).

eventbridge/lib.test.w

@@ -0,0 +1,80 @@
+bring cloud;
+bring expect;
+bring util;
+bring "./lib.w" as lib;
+bring "./types.w" as types;
+
+// this is the actual event bus, shouldn't be
+// referenced directly, but rather through the
+// EventBridge class for publishing or subscribing.
+new lib.EventBridgeInstance(
+  name: "test",
+);
+
+class InboundGithubEvents {
+  pub bucket: cloud.Bucket;
+
+  new() {
+    let eventBridge = new lib.EventBridge();
+
+    this.bucket = new cloud.Bucket();
+    let counter = new cloud.Counter();
+
+    let fn = new cloud.Function(inflight (event) => {
+      log("subscribed event received {event}");
+      this.bucket.put("test-{counter.inc()}", event);
+    });
+
+    eventBridge.subscribeFunction("github.pull-request.created", fn, {
+      "detail-type": [{"prefix": "pull-request."}],
+      "source": ["github.com"],
+    });
+  }
+}
+
+class Environments {
+  new() {
+    let eventBridge = new lib.EventBridge();
+    let queue = new cloud.Queue();
+
+    eventBridge.subscribeQueue("environments.created", queue, {
+      "detail-type": "test",
+      resources: ["test"],
+      source: "test",
+      version: 0,
+      detail: {
+        "test": "test",
+      },
+    });
+  }
+}
+
+let github = new InboundGithubEvents();
+new Environments();
+
+// this is the client, which needs to be created
+// preflight, so that the references are available
+let eventBridge = new lib.EventBridge();
+
+test "publish to eventbridge" {
+  eventBridge.publish(
+    detailType: "pull-request.created",
+    resources: ["test"],
+    source: "github.com",
+    version: 0,
+    detail: {
+      "test": "test",
+    },
+  );
+
+  util.waitUntil(inflight () => {
+    return github.bucket.exists("test-0");
+  }, {
+    timeout: 5s,
+  });
+
+  let published = types.Event.fromJson(github.bucket.getJson("test-0"));
+  expect.equal("pull-request.created", published.detailType);
+  expect.equal("test", published.resources.at(0));
+  expect.equal("github.com", published.source);
+}

eventbridge/lib.w

@@ -0,0 +1,32 @@
+bring cloud;
+bring "./types.w" as types;
+bring "./platform/sim" as sim;
+
+pub class EventBridgeInstance impl types.IEventBridgeInstance {
+  inner: types.IEventBridgeInstance;
+
+  new(props: types.EventBridgeProps) {
+    this.inner = new sim.EventBridgeInstance(props);
+    let node = std.Node.of(this);
+    node.hidden = true;
+  }
+}
+
+pub class EventBridge impl types.IEventBridge {
+  inner: types.IEventBridge;
+
+  new() {
+    this.inner = new sim.EventBridge();
+  }
+
+  pub inflight publish(event: types.PublishEvent): void {
+    this.inner.publish(event);
+  }
+
+  pub subscribeFunction(name: str, handler: cloud.Function, pattern: Json): void {
+    this.inner.subscribeFunction(name, handler, pattern);
+  }
+  pub subscribeQueue(name: str, queue: cloud.Queue, pattern: Json): void {
+    this.inner.subscribeQueue(name, queue, pattern);
+  }
+}