@@ -12,7 +12,7 @@ describe('letter-stream-forwarder Lambda', () => {
1212 kinesisClient : { send : jest . fn ( ) } as unknown as KinesisClient ,
1313 logger : { info : jest . fn ( ) , error : jest . fn ( ) } as unknown as pino . Logger ,
1414 env : {
15- LETTER_CHANGE_STREAM_NAME : "test-stream" ,
15+ LETTER_CHANGE_STREAM_ARN : "test-stream.arn " ,
1616 } as unknown as EnvVars
1717 } as Deps ;
1818
@@ -41,7 +41,7 @@ describe('letter-stream-forwarder Lambda', () => {
4141 expect ( mockedDeps . kinesisClient . send ) . toHaveBeenCalledWith (
4242 expect . objectContaining ( {
4343 input : expect . objectContaining ( {
44- StreamName : 'test-stream' ,
44+ StreamARN : 'test-stream.arn ' ,
4545 PartitionKey : '123' ,
4646 } ) ,
4747 } )
@@ -69,7 +69,7 @@ describe('letter-stream-forwarder Lambda', () => {
6969 expect ( mockedDeps . kinesisClient . send ) . toHaveBeenCalledWith (
7070 expect . objectContaining ( {
7171 input : expect . objectContaining ( {
72- StreamName : 'test-stream' ,
72+ StreamARN : 'test-stream.arn ' ,
7373 PartitionKey : '123' ,
7474 } ) ,
7575 } )
@@ -97,7 +97,7 @@ describe('letter-stream-forwarder Lambda', () => {
9797 expect ( mockedDeps . kinesisClient . send ) . toHaveBeenCalledWith (
9898 expect . objectContaining ( {
9999 input : expect . objectContaining ( {
100- StreamName : 'test-stream' ,
100+ StreamARN : 'test-stream.arn ' ,
101101 PartitionKey : '123' ,
102102 } ) ,
103103 } )
0 commit comments