import { Construct } from 'constructs';
import * as kinesis from 'aws-cdk-lib/aws-kinesis';
import { Tags, Duration } from 'aws-cdk-lib';

export const createEventLoggerKinesis = (scope: Construct, accountStage: string, region: string) => {
  const cdkTagKey = 'CreatedBy';
  const cdkTagValue = 'CDK';

  const kinesisStream = new kinesis.Stream(scope, 'EventLoggerStream', {
    streamName: `event-logger-${region}`,
    streamMode: kinesis.StreamMode.ON_DEMAND,
    retentionPeriod: Duration.days(1),
  });

  Tags.of(kinesisStream).add(cdkTagKey, cdkTagValue);

  return kinesisStream;
};