index.js

/* eslint-env node */
'use strict';

var RSVP = require('rsvp');
var BasePlugin = require('ember-cli-deploy-plugin');
var CloudFront = require('./lib/cloudfront');

module.exports = {
  name: require('./package').name,

  createDeployPlugin: function (options) {
    var DeployPlugin = BasePlugin.extend({
      name: options.name,
      defaultConfig: {
        region: 'us-east-1',
        objectPaths: ['/index.html'],
        invalidationClient: function (context) {
          return context.invalidationClient; // if you want to provide your own invalidation client to be used instead of one from this plugin
        },
        cloudfrontClient: function (context) {
          return context.cloudfrontClient; // if you want to provide your own CloudFront client to be used instead of one from aws-sdk
        },
        waitForInvalidation: false,
      },
      requiredConfig: ['distribution', 'region'],

      didActivate: function (/*context*/) {
        var self = this;

        var distribution = this.readConfig('distribution');
        var objectPaths = this.readConfig('objectPaths');
        var waitForInvalidation = this.readConfig('waitForInvalidation');

        var cloudfront =
          this.readConfig('invalidationClient') ||
          new CloudFront({
            plugin: this,
          });

        var distributions = Array.isArray(distribution)
          ? distribution
          : [distribution];
        var distributionInvalidations = distributions.map(function (
          distribution
        ) {
          var options = {
            objectPaths: objectPaths,
            distribution: distribution,
            waitForInvalidation: waitForInvalidation,
          };

          self.log(
            'preparing to create invalidation for CloudFront distribution `' +
              distribution +
              '`',
            { verbose: true }
          );

          return cloudfront
            .invalidate(options)
            .then(function (invalidationId) {
              self.log(
                'invalidation process finished for invalidation ' +
                  invalidationId,
                { verbose: true }
              );
            })
            .catch(self._errorMessage.bind(self));
        });

        return RSVP.Promise.all(distributionInvalidations);
      },

      _errorMessage: function (error) {
        this.log(error, { color: 'red' });
        if (error) {
          this.log(error.stack, { color: 'red' });
        }
        return RSVP.reject(error);
      },
    });

    return new DeployPlugin();
  },
};