Terraform fix

Author: stevebux

infrastructure/terraform/components/api/module_lambda_letter_stream_forwarder.tf

@@ -36,7 +36,7 @@ module "letter_stream_forwarder" {
   log_subscription_role_arn = local.acct.log_subscription_role_arn
 
   lambda_env_vars = merge(local.common_lambda_env_vars, {
-    LETTER_CHANGE_STREAM_NAME = "letter_change_stream"
+    LETTER_CHANGE_STREAM_ARN = "${aws_kinesis_stream.letter_change_stream.arn}"
   })
 }
 

lambdas/letter-stream-forwarder/src/env.ts

@@ -1,7 +1,7 @@
 import { z } from 'zod';
 
 const EnvVarsSchema = z.object({
-  LETTER_CHANGE_STREAM_NAME: z.string(),
+  LETTER_CHANGE_STREAM_ARN: z.string(),
 });
 
 export type EnvVars = z.infer<typeof EnvVarsSchema>;

lambdas/letter-stream-forwarder/src/letter-stream-forwarder.ts

@@ -15,7 +15,7 @@ export function createHandler(deps: Deps): Handler<DynamoDBStreamEvent> {
       const newImage = record.dynamodb?.NewImage!;
       const letter = unmarshall(newImage as any) as LetterBase;
       await deps.kinesisClient.send(new PutRecordCommand({
-        StreamName: deps.env.LETTER_CHANGE_STREAM_NAME,
+        StreamARN: deps.env.LETTER_CHANGE_STREAM_ARN,
         PartitionKey: letter.id,
         Data: Buffer.from(JSON.stringify(letter)),
       }));