constructor()

in cdk/lib/kinesis-firehose-infrastructure.ts [19:66]

• 43 lines of code
• 1 McCabe index (conditional complexity)

    constructor(scope: cdk.Construct, id: string, props: FirehoseProps) {
        super(scope, id);
      
        const firehoseRole = new iam.Role(this, 'FirehoseRole', {
            assumedBy: new iam.ServicePrincipal('firehose.amazonaws.com')
        });

        props.inputStream.grantRead(firehoseRole);
        props.inputStream.grant(firehoseRole, 'kinesis:DescribeStream');
        props.bucket.grantReadWrite(firehoseRole);
        props.lambda.grantInvoke(firehoseRole);
    
        const firehose = new kdf.CfnDeliveryStream(this, 'FirehoseDeliveryStream', {
            deliveryStreamType: 'KinesisStreamAsSource',
            kinesisStreamSourceConfiguration: {
                kinesisStreamArn: props.inputStream.streamArn,
                roleArn: firehoseRole.roleArn,
            },
            extendedS3DestinationConfiguration: {
                bucketArn: props.bucket.bucketArn,
                bufferingHints: {
                    intervalInSeconds: 60,
                    sizeInMBs: 128
                },
                compressionFormat: 'GZIP',
                roleArn: firehoseRole.roleArn,
                prefix: 'kinesis-stream-data/',
                processingConfiguration: {
                    enabled: true,
                    processors: [
                        {
                            type: 'Lambda',
                            parameters: [
                                {
                                    parameterName: 'LambdaArn',
                                    parameterValue: props.lambda.functionArn
                                }
                            ]
                        }
                    ]
                }
            }
        });

        //arificially delay creation of the delivery stream; due to bug in cdk, creation would fail
        firehose.node.addDependency(props.buildSuccessWaitCondition);
        firehose.node.addDependency(props.emptyBucket)
    }