constructor()

in source/cdk-infrastructure/lib/real-time-processing/real-time-processing-construct.ts [34:140]
95 lines of code
1 McCabe index (conditional complexity)

    constructor(scope: Construct, id: string, props: IRealTimeProcessingProps) {
        super(scope, id);

        const sourceCodeBucket = Bucket.fromBucketName(this, 'sourceCodeBucket', props.sourceCodeBucketName);

        const streamFirehoseS3Construct = new KinesisStreamsToKinesisFirehoseToS3(this, 'StreamFirehoseS3', {
            existingLoggingBucketObj: props.s3LoggingBucket,
            bucketProps: {
                serverAccessLogsPrefix: 'data/'
            }
        });
        this.streamName = streamFirehoseS3Construct.kinesisStream.streamName;
        this.rawDataBucketName = streamFirehoseS3Construct.s3Bucket!.bucketName;

        const streamLambdaConstruct = new KinesisStreamsToLambda(this, 'StreamFilter', {
            kinesisEventSourceProps: {
                startingPosition: StartingPosition.TRIM_HORIZON,
                batchSize: 100
            },
            deploySqsDlqQueue: false,
            lambdaFunctionProps: {
                runtime: Runtime.NODEJS_14_X,
                handler: 'filter-kinesis-stream/index.handler',
                timeout: Duration.minutes(2),
                description: 'Filters messages from the Kinesis Stream. Forwards status and production count updates to the real-time data table',
                code: Code.fromBucket(sourceCodeBucket, [props.sourceCodeKeyPrefix, 'filter-kinesis-stream.zip'].join('/')),
                memorySize: 256,
                environment: {
                    GRAPHQL_API_ENDPOINT: props.graphqlApi.graphqlUrl,
                    CONFIG_TABLE_NAME: props.configTable.tableName,
                    UI_REFERENCE_TABLE_NAME: props.uiReferenceTable.tableName,
                    REAL_TIME_TABLE_NAME: props.realTimeDataTable.tableName,
                    REAL_TIME_DATA_EXPIRATION_IN_HOURS: '24',
                    SEND_ANONYMOUS_DATA: props.sendAnonymousData,
                    ANONYMOUS_DATA_UUID: props.anonymousDataUUID,
                    SOLUTION_ID: props.solutionId,
                    SOLUTION_VERSION: props.solutionVersion,
                    VERBOSE_LOGGING: 'No'
                }
            },
            existingStreamObj: streamFirehoseS3Construct.kinesisStream
        });

        props.graphqlApi.grantMutation(streamLambdaConstruct.lambdaFunction);
        props.configTable.grantReadData(streamLambdaConstruct.lambdaFunction);
        props.configTable.grantWriteData(streamLambdaConstruct.lambdaFunction);
        props.uiReferenceTable.grantReadWriteData(streamLambdaConstruct.lambdaFunction);
        props.realTimeDataTable.grantWriteData(streamLambdaConstruct.lambdaFunction);

        // Suppress CFN Nag warning(s)
        (streamLambdaConstruct.lambdaFunction.role!.node.findChild('DefaultPolicy').node.defaultChild as CfnPolicy)
            .cfnOptions.metadata = {
            cfn_nag: {
                rules_to_suppress: [
                    {
                        id: 'W76',
                        reason: 'SPCM for IAM policy document is higher than 25: Permissions are required'
                    },
                    {
                        id: 'W12',
                        reason: '* permission is needed for X-Ray'

                    }
                ]
            }
        };

        const configTableStreamUpdateConstruct = new DynamoDBStreamToLambda(this, 'ConfigStreamToUpdateLambda', {
            existingTableObj: props.configTable,
            deploySqsDlqQueue: false,
            lambdaFunctionProps: {
                runtime: Runtime.NODEJS_14_X,
                handler: 'update-filter-function/index.handler',
                timeout: Duration.minutes(2),
                description: 'Receives messages from the DDB Streams for the Config and UI Reference Tables. When an update is detected, update an environment variable on the Filter Kinesis Stream lambda so its container will be refreshed',
                code: Code.fromBucket(sourceCodeBucket, [props.sourceCodeKeyPrefix, 'update-filter-function.zip'].join('/')),
                environment: {
                    FILTER_FUNCTION_NAME: streamLambdaConstruct.lambdaFunction.functionName,
                    CONFIG_TABLE_STREAM_ARN: props.configTable.tableStreamArn!,
                    UI_REFERENCE_TABLE_STREAM_ARN: props.uiReferenceTable.tableStreamArn!,
                    SEND_ANONYMOUS_DATA: props.sendAnonymousData,
                    ANONYMOUS_DATA_UUID: props.anonymousDataUUID,
                    SOLUTION_ID: props.solutionId,
                    SOLUTION_VERSION: props.solutionVersion
                }
            }
        });

        // Allows the update function to get and update environment variables for the filter lambda
        configTableStreamUpdateConstruct.lambdaFunction.role!
            .attachInlinePolicy(new Policy(this, 'AllowUpdateFilterLambdaPolicy', {
                statements: [new PolicyStatement({
                    effect: Effect.ALLOW,
                    actions: ['lambda:GetFunctionConfiguration', 'lambda:UpdateFunctionConfiguration'],
                    resources: [streamLambdaConstruct.lambdaFunction.functionArn]
                })]
            }));

        // Configure the stream event source for the UI reference table
        props.uiReferenceTable.grantStreamRead(configTableStreamUpdateConstruct.lambdaFunction);
        configTableStreamUpdateConstruct.lambdaFunction.addEventSource(new DynamoEventSource(props.uiReferenceTable, {
            startingPosition: StartingPosition.TRIM_HORIZON,
            bisectBatchOnError: true,
            maxRecordAge: Duration.hours(24),
            retryAttempts: 500
        }));
    }