A Cloud Coach - Tutorial - Serverless Stripe Store - 008 - Pipeline Cache Function

index.js

const AWS = require('aws-sdk');
exports.handler = (event, context, callback) => {
    const cloudfront = new AWS.CloudFront();
    const codepipeline = new AWS.CodePipeline();
    
    //job id passed into fn by CP
    const jobId = event["CodePipeline.job"].id;
    
    let cfInvalidationParams = {
        DistributionId: process.env.CloudfrontDistId,
        InvalidationBatch: {
            CallerReference: Date.now().toString(),
            Paths: {
                Quantity: 1,
                Items: ['/*']
            }
        }
    };
    
    cloudfront.createInvalidation(cfInvalidationParams, (err, data) => {
        
                //define job success
    let putJobSuccess = (jobSuccessMessage) => {
        let successParams = {
            jobId: jobId
        }
        
        codepipeline.putJobSuccessResult(successParams, (err, data) => {
            if (err) {
                callback(err, null);
            } else {
                callback(null, jobSuccessMessage);
            }
        })
    }
    
    //define job failure
    let putJobFailure = (jobFailureMessage) => {
        let failureParams = {
            jobId: jobId,
            failureDetails: {
                message: JSON.stringify(jobFailureMessage),
                type: 'JobFailed',
                externalExecutionId: context.invokeid
            }
        };
        
        codepipeline.putJobFailureResult(failureParams, (err, data) => {
            callback(jobFailureMessage, null);
        })
    }
        
        
        if (err) {
            putJobFailure('Failed to invalidate cache: ' + err);
        } else {
            //CP job successful after all files copied
            putJobSuccess('Successfully invalidated CloudFront cache!');
        }  
    }) 
};