carpark-stack.js

import {
  Bucket,
  Function,
  Queue,
  use
} from 'sst/constructs'
import * as sqs from 'aws-cdk-lib/aws-sqs'

import { BusStack } from './bus-stack.js'
import { CARPARK_EVENT_BRIDGE_SOURCE_EVENT } from '../carpark/event-bus/source.js'
import { getBucketConfig, setupSentry } from './config.js'
import { mustGetEnv } from '../lib/env.js'

/**
 * @param {import('sst/constructs').StackContext} properties
 */
export function CarparkStack({ stack, app }) {
  // Setup app monitoring with Sentry
  setupSentry(app, stack)

  // Get eventBus reference
  const { eventBus } = use(BusStack)
  const { EIPFS_INDEXER_SQS_ARN, EIPFS_INDEXER_SQS_URL } = getEnv()

  const carparkBucket = new Bucket(stack, 'car-store', {
    cors: true,
    cdk: {
      bucket: getBucketConfig('carpark', app.stage)
    }
  })

  // Elastic IPFS event for indexing
  const indexerTopicQueue = new Queue(stack, 'indexer-topic-queue', {
    cdk: {
      queue: sqs.Queue.fromQueueArn(
        stack,
        'indexer-topic',
        EIPFS_INDEXER_SQS_ARN
      ),
    },
  })

  // Event Bus targets
  const eIpfsIndexTarget = {
    function: {
      environment: {
        EIPFS_INDEXER_SQS_URL
      },
      permissions: [indexerTopicQueue],
      handler: 'carpark/event-bus/eipfs-indexer.handler',
    },
  }

  eventBus.addRules(stack, {
    newCar: {
      pattern: {
        source: [CARPARK_EVENT_BRIDGE_SOURCE_EVENT],
      },
      targets: {
        eIpfsIndexTarget
      }
    }
  })

  // Trigger carpark events when a CAR is put into the bucket.
  const carparkPutEventConsumer = new Function(stack, 'carpark-consumer', {
    environment: {
      EVENT_BUS_ARN: eventBus.eventBusArn,
    },
    permissions: [eventBus],
    handler: 'carpark/functions/carpark-bucket-event.carparkBucketConsumer',
  })
  carparkBucket.addNotifications(stack, {
    newCarPut: {
      function: carparkPutEventConsumer,
      events: ['object_created'],
    }
  })

  stack.addOutputs({
    BucketName: carparkBucket.bucketName,
    Region: stack.region
  })

  return {
    carparkBucket
  }
}

/**
 * Get Env validating it is set.
 */
function getEnv() {
  return {
    EIPFS_INDEXER_SQS_ARN: mustGetEnv('EIPFS_INDEXER_SQS_ARN'),
    EIPFS_INDEXER_SQS_URL: mustGetEnv('EIPFS_INDEXER_SQS_URL'),
  }
}