EventBridge Bus

import { EventBridgeBus } from "@fjall/components-infrastructure";

const bus = new EventBridgeBus(scope, "AppEvents", {});

import { MessagingFactory } from "@fjall/components-infrastructure";

const events = app.addMessaging(
  MessagingFactory.build("AppEvents", {
    type: "eventBus",
  }),
);

const domainEvents = app.addMessaging(
  MessagingFactory.build("DomainEvents", {
    type: "eventBus",
  }),
);

domainEvents.grantPutEventsTo(apiService);

import { Rule } from "aws-cdk-lib/aws-events";
import { LambdaFunction } from "aws-cdk-lib/aws-events-targets";

const bus = app.addMessaging(
  MessagingFactory.build("AppEvents", {
    type: "eventBus",
  }),
);

// Route order events to a processing Lambda
new Rule(scope, "OrderRule", {
  eventBus: bus.getEventBus(),
  eventPattern: {
    source: ["orders"],
    detailType: ["OrderCreated"],
  },
  targets: [new LambdaFunction(processorLambda.getFunction())],
});