feat: Create dashboard

Author: greynewell

lib/eventMonitoring.ts

@@ -3,7 +3,7 @@ import { Construct } from 'constructs';
 import { EventRouter } from './eventRouter';
 import { EventProducer } from './eventProducer';
 import { EventConsumer } from './eventConsumer';
-import { Alarm, Metric, TreatMissingData } from 'aws-cdk-lib/aws-cloudwatch';
+import { Alarm, Dashboard, GraphWidget, Metric, TextWidget, TreatMissingData } from 'aws-cdk-lib/aws-cloudwatch';
 import { Queue } from 'aws-cdk-lib/aws-sqs';
 
 export interface EventMonitoringProps {
@@ -179,5 +179,139 @@ export class EventMonitoring extends Construct {
         metric: queueApproximateAgeOfOldestMessage
       });
     });
+
+        // Create a new dashboard
+        const dashboard = new Dashboard(this, 'EventMonitoringDashboard', {
+          dashboardName: `${id}-monitoring-dashboard`
+        });
+    
+        // Add a title
+        dashboard.addWidgets(new TextWidget({
+          markdown: '# Event-Driven Architecture Monitoring',
+          width: 24,
+          height: 1
+        }));
+    
+        // API Gateway metrics
+        dashboard.addWidgets(
+          new GraphWidget({
+            title: 'API Gateway Metrics',
+            width: 12,
+            height: 6,
+            left: [
+              props?.producer.api.metricClientError()!,
+              props?.producer.api.metricServerError()!,
+            ],
+            right: [
+              props?.producer.api.metricLatency()!
+            ]
+          })
+        );
+    
+        // EventBridge Bus metrics
+        dashboard.addWidgets(
+          new GraphWidget({
+            title: 'EventBridge Bus Metrics',
+            width: 12,
+            height: 6,
+            left: [
+              busInvocations,
+              busFailedInvocations
+            ]
+          })
+        );
+    
+        // EventBridge Rule metrics
+        const ruleWidgets = props?.router.rules?.map((rule) => {
+          return new GraphWidget({
+            title: `EventBridge Rule: ${rule.ruleName}`,
+            width: 8,
+            height: 6,
+            left: [
+              new Metric({
+                namespace: 'AWS/Events',
+                metricName: 'Invocations',
+                dimensionsMap: { RuleName: rule.ruleName },
+                period: cdk.Duration.minutes(5),
+                statistic: 'Sum'
+              }),
+              new Metric({
+                namespace: 'AWS/Events',
+                metricName: 'FailedInvocations',
+                dimensionsMap: { RuleName: rule.ruleName },
+                period: cdk.Duration.minutes(5),
+                statistic: 'Sum'
+              }),
+              new Metric({
+                namespace: 'AWS/Events',
+                metricName: 'ThrottledRules',
+                dimensionsMap: { RuleName: rule.ruleName },
+                period: cdk.Duration.minutes(5),
+                statistic: 'Sum'
+              })
+            ]
+          });
+        }) || [];
+    
+        if (ruleWidgets.length > 0) {
+          dashboard.addWidgets(...ruleWidgets);
+        }
+    
+        // SNS Topic metrics
+        const topicWidgets = props?.router.topics?.map((topic, index) => {
+          return new GraphWidget({
+            title: `SNS Topic: ${topic.topicName}`,
+            width: 8,
+            height: 6,
+            left: [
+              topic.metricNumberOfNotificationsFailed(),
+              topic.metricNumberOfNotificationsDelivered(),
+              topic.metricNumberOfMessagesPublished()
+            ]
+          });
+        }) || [];
+    
+        if (topicWidgets.length > 0) {
+          dashboard.addWidgets(...topicWidgets);
+        }
+    
+        // SQS Queue metrics for consumers
+        const queueWidgets = props?.consumers?.map((consumer) => {
+          return new GraphWidget({
+            title: `SQS Queue: ${consumer.queue.queueName}`,
+            width: 12,
+            height: 6,
+            left: [
+              consumer.queue.metricApproximateNumberOfMessagesVisible(),
+              consumer.queue.metricApproximateAgeOfOldestMessage(),
+              consumer.queue.metricNumberOfMessagesReceived(),
+              consumer.queue.metricNumberOfMessagesDeleted()
+            ]
+          });
+        }) || [];
+    
+        if (queueWidgets.length > 0) {
+          dashboard.addWidgets(...queueWidgets);
+        }
+    
+        // Dead Letter Queue metrics
+        const dlqWidgets = props?.deadLetterQueues?.map((queue) => {
+          return new GraphWidget({
+            title: `Dead Letter Queue: ${queue.queueName}`,
+            width: 12,
+            height: 6,
+            left: [
+              queue.metricApproximateNumberOfMessagesVisible(),
+              queue.metricApproximateAgeOfOldestMessage()
+            ]
+          });
+        }) || [];
+    
+        if (dlqWidgets.length > 0) {
+          dashboard.addWidgets(...dlqWidgets);
+        }
+    
+        // Store the dashboard name for reference
+        this.dashboardName = dashboard.dashboardName;
   }
 }