WIP: CloudWatch integration

.github/workflows/ci.yml

@@ -42,7 +42,7 @@ jobs:
         run: |
             ./script/ci
           
-      - name: Upload to riff-raff
+      - name: Upload to riff-raff (anghammarad)
         uses: guardian/actions-riff-raff@v2
         with:
           app: anghammarad
@@ -55,4 +55,18 @@ jobs:
             cfn:
               - cloudformation/cfn.yaml
 
+      - name: Upload to riff-raff (cloudwatch)
+        uses: guardian/actions-riff-raff@v2
+        with:
+          app: cloudwatch-to-anghammarad
+          configPath: cdk/cdk.out/riff-raff.yaml
+          projectName: tools::cloudwatch-to-anghammarad
+          contentDirectories: |
+            cloudwatch-to-anghammarad:
+              - cloudwatch/cloudwatch.jar
+            cdk.out:
+              - cdk/cdk.out/CloudwatchToAnghammarad-CODE.template.json
+              - cdk/cdk.out/CloudwatchToAnghammarad-PROD.template.json
+      
+
 

build.sbt

@@ -54,7 +54,7 @@ lazy val root = project
     publishTo := sonatypePublishTo.value,
     releaseProcess += releaseStepCommandAndRemaining("sonatypeRelease"),
   )
-  .aggregate(anghammarad, client, common, dev)
+  .aggregate(anghammarad, client, cloudwatch, common, dev)
 
 lazy val common = project
   .settings(
@@ -109,6 +109,27 @@ lazy val anghammarad = project
     assemblySettings,
   )
 
+lazy val cloudwatch = project
+  .enablePlugins(JavaAppPackaging, ScalafixPlugin)
+  .dependsOn(common)
+  .settings(
+    name := "cloudwatch",
+    libraryDependencies ++= Seq(
+      "com.amazonaws" % "aws-lambda-java-events" % "3.11.3",
+      "com.amazonaws" % "aws-lambda-java-core" % "1.2.3",
+      "com.amazonaws" % "aws-java-sdk-lambda" % awsSdkVersion,
+      "io.circe" %% "circe-core" % circeVersion,
+      "io.circe" %% "circe-generic" % circeVersion,
+      "io.circe" %% "circe-parser" % circeVersion,
+      "com.typesafe.scala-logging" %% "scala-logging" % scalaLoggingVersion,
+      "ch.qos.logback" % "logback-classic" % "1.4.11",
+      "org.scalatest" %% "scalatest" % scalaTestVersion % Test
+    ),
+    publish / skip := true,
+    assembly / assemblyOutputPath := file("cloudwatch/cloudwatch.jar"),
+    assemblySettings,
+  )
+
 lazy val dev = project
   .settings(
     name := "dev",

cdk/.gitignore

@@ -0,0 +1,11 @@
+*.js
+!jest.config.js
+!jest.setup.js
+!.eslintrc.js
+*.d.ts
+node_modules
+dist
+
+# CDK asset staging directory
+.cdk.staging
+cdk.out

cdk/README.md

@@ -0,0 +1,5 @@
+# Infrastructure
+
+This directory defines the components to be deployed to AWS.
+
+See [`package.json`](./package.json) for a list of available scripts.

cdk/bin/cdk.ts

@@ -0,0 +1,7 @@
+import "source-map-support/register";
+import { GuRoot } from "@guardian/cdk/lib/constructs/root";
+import { CloudwatchToAnghammarad } from "../lib/cloudwatch-to-anghammarad";
+
+const app = new GuRoot();
+new CloudwatchToAnghammarad(app, "CloudwatchToAnghammarad-CODE", { stack: "deploy", stage: "CODE", env: { region: "eu-west-1" } });
+new CloudwatchToAnghammarad(app, "CloudwatchToAnghammarad-PROD", { stack: "deploy", stage: "PROD", env: { region: "eu-west-1" } });

cdk/cdk.json

@@ -0,0 +1,7 @@
+{
+  "app": "npx ts-node bin/cdk.ts",
+  "context": {
+    "aws-cdk:enableDiffNoFail": "true",
+    "@aws-cdk/core:stackRelativeExports": "true"
+  }
+}

cdk/jest.setup.js

@@ -0,0 +1 @@
+jest.mock("@guardian/cdk/lib/constants/tracking-tag");