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

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

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

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

    return kinesisStream;
};