exports.handler = function()

in pca-ui/src/lambda/bucket.js [7:78]
59 lines of code
2 McCabe index (conditional complexity)

exports.handler = function (event, context) {
    const props = event.ResourceProperties;

    const bucketName = props.BucketName;
    const prefix = props.Prefix;
    const queueArn = props.QueueArn;

    const resourceId = `${stackName}::${bucketName}/${prefix}`

    console.log("Event:", JSON.stringify(event, null, 4));

    s3.getBucketNotificationConfiguration({
        Bucket: bucketName,
    })
        .promise()
        .then((data) => {
            console.log("Existing config:", JSON.stringify(data, null, 4));

            // Remove our config
            data.QueueConfigurations = data.QueueConfigurations.filter(
                (config) => {
                    return config.Id != resourceId;
                }
            );

            console.log("Removed us:", JSON.stringify(data, null, 4));

            if (event.RequestType != "Delete") {
                // Add it back in
                data.QueueConfigurations.push({
                    Id: resourceId,
                    QueueArn: queueArn,
                    Events: ["s3:ObjectCreated:*", "s3:ObjectRemoved:*"],
                    Filter: {
                        Key: {
                            FilterRules: [
                                {
                                    Name: "prefix",
                                    Value: `${prefix}/`,
                                },
                                {
                                    Name: "suffix",
                                    Value: `.json`,
                                },
                            ],
                        },
                    },
                });

                console.log("Added us:", JSON.stringify(data, null, 4));
            }

            return s3
                .putBucketNotificationConfiguration({
                    Bucket: bucketName,
                    NotificationConfiguration: data,
                })
                .promise();
        })
        .then((data) => {
            console.log("Win:", JSON.stringify(data, null, 4));

            response.send(event, context, response.SUCCESS, {}, resourceId);
        })
        .catch((err) => {
            console.log("Lose:", err);

            response.send(event, context, response.FAILED, {
                error: err,
            }, resourceId);
        });
};