chore: test rule

carpark/event-bridge/eipfs-indexer.js

@@ -6,7 +6,7 @@ const SQS_INDEXER_QUEUE_URL =
 const SQS_INDEXER_QUEUE_REGION = 'us-west-2'
 
 /**
- * @param {import('.').EventBridgeEvent} event 
+ * @param {import('./source').EventBridgeEvent} event 
  * @param {SQSClient} client
  * @param {string} queueUrl
  */
@@ -24,7 +24,7 @@ export async function eipfsHandler(event, client, queueUrl) {
 }
 
 /**
- * @param {import('.').EventBridgeEvent} event 
+ * @param {import('./source').EventBridgeEvent} event 
  */
  export async function handler (event) {
   const sqsClient = new SQSClient({

carpark/event-bridge/replicator.js

@@ -4,7 +4,7 @@ const SQS_REPLICATOR_QUEUE_URL = process.env.SQS_REPLICATOR_QUEUE_URL || ''
 const SQS_REPLICATOR_QUEUE_REGION = 'us-west-2'
 
 /**
- * @param {import('.').EventBridgeEvent} event 
+ * @param {import('./source').EventBridgeEvent} event 
  * @param {SQSClient} client
  * @param {string} queueUrl
  */
@@ -22,7 +22,7 @@ export async function replicatorHandler(event, client, queueUrl) {
 }
 
 /**
- * @param {import('.').EventBridgeEvent} event 
+ * @param {import('./source').EventBridgeEvent} event 
  */
 export async function handler (event) {
   const sqsClient = new SQSClient({

carpark/event-bridge/index.js → carpark/event-bridge/source.js

@@ -9,7 +9,7 @@ export const CARPARK_EVENT_BRIDGE_SOURCE_EVENT = 'carpark_bucket'
  * @param {import('@aws-sdk/client-eventbridge').EventBridge} eventBridge
  * @param {string} eventBusName
  */
- export async function notifyBusNewCar(event, eventBridge, eventBusName) {
+ export async function notifyBus(event, eventBridge, eventBusName) {
   const entries = event.Records
     ? event.Records.map((r) => ({
         key: r?.s3?.object?.key,

carpark/functions/carpark-event.js → carpark/functions/carpark-bucket-event.js

@@ -1,16 +1,16 @@
 import { EventBridge } from '@aws-sdk/client-eventbridge'
 
-import { notifyBusNewCar } from '../event-bridge/index.js'
+import { notifyBus } from '../event-bridge/source.js'
 
-const CARPARK_BUS_ARN = process.env.CARPARK_BUS_ARN || ''
+const EVENT_BUS_ARN = process.env.EVENT_BUS_ARN || ''
 
 /**
  * @param {import('aws-lambda').S3Event} event
  */
 async function handler(event) {
   const bus = new EventBridge({})
 
-  return await notifyBusNewCar(event, bus, CARPARK_BUS_ARN)
+  return await notifyBus(event, bus, EVENT_BUS_ARN)
 }
 
 export const carparkBucketConsumer = handler

carpark/test/event-bridge.test.js

@@ -1,6 +1,6 @@
 import { test } from './helpers/context.js'
 
-import { notifyBusNewCar } from '../event-bridge/index.js'
+import { notifyBus } from '../event-bridge/source.js'
 import { eipfsHandler } from '../event-bridge/eipfs-indexer.js'
 import { replicatorHandler } from '../event-bridge/replicator.js'
 
@@ -33,7 +33,7 @@ test('notifies carpark event bridge when new carpark bucket is written', async t
     }
   }
 
-  const response = await notifyBusNewCar({
+  const response = await notifyBus({
       // @ts-expect-error incomplete S3 event metadata
       Records: fixtureS3PutValidRecords
     },
@@ -51,7 +51,7 @@ test('does not notify carpark event bridge when new carpark bucket is written wi
     }
   }
 
-  const response = await notifyBusNewCar({
+  const response = await notifyBus({
       // @ts-expect-error incomplete S3 event metadata
       Records: fixtureS3PutInvalidRecords
     },

satnav/event-bus/source.js

@@ -0,0 +1,36 @@
+export const SATNAV_EVENT_BRIDGE_SOURCE_EVENT = 'carpark_bucket'
+
+/**
+ * @typedef {{ detail: {key?: string, region: string, bucketName: string}}} EventBridgeEvent
+ */
+
+/**
+ * @param {import('aws-lambda').S3Event} event
+ * @param {import('@aws-sdk/client-eventbridge').EventBridge} eventBridge
+ * @param {string} eventBusName
+ */
+ export async function notifyBus(event, eventBridge, eventBusName) {
+  const entries = event.Records
+    ? event.Records.map((r) => ({
+        key: r?.s3?.object?.key,
+        region: r?.awsRegion || 'us-west-2',
+        bucketName: r?.s3?.bucket?.name,
+      })).filter((entry) => entry.key)
+    : []
+
+  if (entries.length > 0) {
+    const feedbackEntries = entries.map((entry) => ({
+      EventBusName: eventBusName,
+      Source: SATNAV_EVENT_BRIDGE_SOURCE_EVENT,
+      DetailType: 'satnav_index_added',
+      Detail: JSON.stringify(entry),
+    }))
+    await eventBridge.putEvents({ Entries: feedbackEntries })
+  }
+
+  return {
+    statusCode: 200,
+    headers: { 'Content-Type': 'text/plain' },
+    body: `File was added to satnav bucket`,
+  }
+}