chore: test rule

storacha · Nov 29, 2022 · bebc39c · bebc39c
1 parent 380a19d
commit bebc39c
Showing 1 changed file with 50 additions and 11 deletions.
diff --git a/stacks/satnav-stack.js b/stacks/satnav-stack.js
@@ -2,9 +2,9 @@ import {
   Bucket,
   Function,
   Queue,
-  use
+  use,
 } from '@serverless-stack/resources'
-import { Duration } from 'aws-cdk-lib'
+import { Duration, aws_events as awsEvents } from 'aws-cdk-lib'
 
 import { BusStack } from './bus-stack.js'
 import { CarparkStack } from './carpark-stack.js'
@@ -62,14 +62,42 @@ export function SatnavStack({ stack }) {
     },
   })
 
-  const satnavWriterTarget = {
-    function: {
-      environment: {
-        SQS_SATNAV_WRITER_QUEUE_URL: satnavWriterQueue.queueUrl,
-      },
-      permissions: [satnavWriterQueue],
-      handler: 'events/satnav-writer.handler',
-    },
+  // const satnavWriterTarget = {
+  //   function: {
+  //     environment: {
+  //       SQS_SATNAV_WRITER_QUEUE_URL: satnavWriterQueue.queueUrl,
+  //     },
+  //     permissions: [satnavWriterQueue],
+  //     handler: 'events/satnav-writer.handler',
+  //   },
+  // }
+
+  // const queueTopic = new Topic(stack, 'topic', {
+  //   subscribers: {
+  //     subscriber: satnavWriterQueue
+  //   }
+  // })
+
+  // https://docs.aws.amazon.com/eventbridge/latest/APIReference/API_InputTransformer.html
+  // /** @type {import('aws-cdk-lib').aws_events.CfnRule.InputTransformerProperty} */
+  // const message = {
+  //   inputTemplate: '<region>/<bucket>/<key>',
+  //   inputPathsMap: {
+  //     'region': '$.detail.region',
+  //     'bucket': '$.detail.bucketName',
+  //     'key': '$.detail.key'
+  //   }
+  // }
+
+  /** @type {import('@serverless-stack/resources').EventBusQueueTargetProps} */
+  const targetQueue = {
+    type: 'queue',
+    queue: satnavWriterQueue,
+    cdk: {
+      target: {
+        message: awsEvents.RuleTargetInput.fromEventPath('$.detail.region/$.detail.bucketName/$.detail.key'),
+      }
+    }
   }
 
   eventBus.addRules(stack, {
@@ -78,11 +106,22 @@ export function SatnavStack({ stack }) {
         source: [CARPARK_EVENT_BRIDGE_SOURCE_EVENT],
       },
       targets: {
-        satnavWriterTarget
+        targetQueue,
       }
     }
   })
 
+  // eventBus.addRules(stack, {
+  //   newCarToWriteSatnav: {
+  //     pattern: {
+  //       source: [CARPARK_EVENT_BRIDGE_SOURCE_EVENT],
+  //     },
+  //     targets: {
+  //       satnavWriterTarget,
+  //     }
+  //   }
+  // })
+
   // Trigger satnav events when an Index is put into the bucket
   const satnavPutEventConsumer = new Function(stack, 'satnav-consumer', {
     environment: {