created single producer and consumer solution

Author: jfan9

typescript/eventbridge-mesh/lib/app.ts

@@ -1,20 +1,26 @@
 #!/usr/bin/env node
 import * as cdk from 'aws-cdk-lib';
-import { EventbridgeMeshStack } from '../lib/eventbridge-mesh-stack';
+import { consumerStack } from './single-consumer-stack';
+import { producerStack } from './single-producer-stack';
 
 const app = new cdk.App();
-new EventbridgeMeshStack(app, 'EventbridgeMeshStack', {
-  /* If you don't specify 'env', this stack will be environment-agnostic.
-   * Account/Region-dependent features and context lookups will not work,
-   * but a single synthesized template can be deployed anywhere. */
 
-  /* Uncomment the next line to specialize this stack for the AWS Account
-   * and Region that are implied by the current CLI configuration. */
-  // env: { account: process.env.CDK_DEFAULT_ACCOUNT, region: process.env.CDK_DEFAULT_REGION },
+const region            = 'us-east-1'
+const producerAccountId = '111111111111';
+const consumerAccountId = '222222222222';
 
-  /* Uncomment the next line if you know exactly what Account and Region you
-   * want to deploy the stack to. */
-  // env: { account: '123456789012', region: 'us-east-1' },
+new producerStack(app, 'producerStack', {
+  env: {
+    account: producerAccountId,
+    region:  region,
+  },
+  consumerAccountId,
+});
 
-  /* For more information, see https://docs.aws.amazon.com/cdk/latest/guide/environments.html */
-});
+new consumerStack(app, 'consumerStack', {
+  env: {
+    account: consumerAccountId,
+    region:  region,
+  },
+  producerAccountId,
+});

typescript/eventbridge-mesh/lib/eventbridge-mesh-stack.ts

@@ -0,0 +1,45 @@
+import * as cdk from 'aws-cdk-lib';
+import { EventBus, EventBusPolicy, Rule } from 'aws-cdk-lib/aws-events';
+import { CloudWatchLogGroup } from 'aws-cdk-lib/aws-events-targets';
+import { AccountPrincipal, Effect, PolicyStatement } from 'aws-cdk-lib/aws-iam';
+import { LogGroup } from 'aws-cdk-lib/aws-logs';
+import { Construct } from 'constructs';
+
+export interface consumerStackProps extends cdk.StackProps {
+  readonly producerAccountId: string;
+}
+
+export class consumerStack extends cdk.Stack {
+  constructor(scope: Construct, id: string, props: consumerStackProps) {
+    super(scope, id, props);
+
+    // Create or reference the consumer event bus
+    const consumerEventBus = new EventBus(this, 'ConsumerEventBus');
+
+    // Add policy to allow producer account to put events
+    consumerEventBus.addToResourcePolicy(new PolicyStatement({
+      sid: 'allowProducerAccount',
+      effect: Effect.ALLOW,
+      principals: [new AccountPrincipal(props.producerAccountId)],
+      actions: ['events:PutEvents'],
+      resources: [consumerEventBus.eventBusArn]
+    }));
+
+    // Create consumer rules
+    const consumerRule = new Rule(this, 'ConsumerRule', {
+      eventBus: consumerEventBus,
+      eventPattern: {
+        // Define more specific filtering here
+        source: ['com.myapp.events'],
+        detail: {
+          type: ['specific-event-type']
+        }
+      }
+    });
+
+    // Add target (e.g., CloudWatch)
+    consumerRule.addTarget(new CloudWatchLogGroup(
+      new LogGroup(this, 'ConsumerLogs')
+    ));
+  }
+}

typescript/eventbridge-mesh/lib/single-consumer-stack.ts

@@ -0,0 +1,42 @@
+import * as cdk from 'aws-cdk-lib';
+import * as targets from 'aws-cdk-lib/aws-events-targets';
+import { EventBus, Rule } from 'aws-cdk-lib/aws-events';
+import { LogGroup } from 'aws-cdk-lib/aws-logs';
+import { Construct } from 'constructs';
+
+export interface producerStackProps extends cdk.StackProps {
+  readonly consumerAccountId: string;
+}
+
+export class producerStack extends cdk.Stack {
+    constructor(scope: Construct, id: string, props: producerStackProps) {
+      super(scope, id, props);
+  
+      // Create the EventBus
+      const producerEventBus = new EventBus(this, 'ProducerEventBus');
+  
+      // Create rule to forward events to consumer account
+      const rule = new Rule(this, 'ForwardToConsumerRule', {
+        eventBus: producerEventBus,
+        eventPattern: {
+          // Define your event pattern here
+          source: ['com.myapp.events'],
+        },
+      });
+  
+      // Add target to forward to consumer account's event bus
+      rule.addTarget(new targets.EventBus(
+        EventBus.fromEventBusArn(
+          this, 
+          'ConsumerEventBus',
+          `arn:aws:events:${cdk.Stack.of(this).region}:${props.consumerAccountId}:event-bus/default`
+        )
+      ));
+  
+      // Optional: Add CloudWatch target for monitoring
+      rule.addTarget(new targets.CloudWatchLogGroup(
+        new LogGroup(this, 'producerLogs')
+      ));
+    }
+  }
+