'use strict'; /** * Action: ProjectInit * - Takes a project and initializes it * - Creates a _meta folder * - Creates a new project S3 bucket and puts env and CF files * - Creates CF stack by default, unless noExeCf option is set to true * * Options: * - name (String) a new name for this project * - domain (String) a domain for new project to create the bucket name with * - notificationEmail (String) email to use for AWS alarms * - profile (String) an AWS profile to create the project in. Must be available in ~/.aws/credentials * - region (String) the first region for your new project * - noExeCf: (Boolean) Don't execute CloudFormation */ module.exports = function(SPlugin, serverlessPath) { const path = require('path'), SError = require( path.join( serverlessPath, 'ServerlessError' ) ), SCli = require( path.join( serverlessPath, 'utils/cli' ) ), SUtils = require( path.join( serverlessPath, 'utils' ) ), os = require('os'), fs = require('fs'), fse = require('fs-extra'), BbPromise = require('bluebird'), awsMisc = require( path.join( serverlessPath, 'utils/aws/Misc' ) ); BbPromise.promisifyAll(fs); /** * ProjectInit Class */ class ProjectInit extends SPlugin { constructor(S, config) { super(S, config); } static getName() { return 'serverless.core.' + ProjectInit.name; } registerActions() { this.S.addAction(this.projectInit.bind(this), { handler: 'projectInit', description: 'Initializes a Serverless project', context: 'project', contextAction: 'init', options: [ { option: 'name', shortcut: 'n', description: 'A new name for this Serverless project' }, { option: 'domain', shortcut: 'd', description: 'Domain of your Serverless project' }, { option: 'stage', shortcut: 's', description: 'Initial project stage' }, { option: 'region', shortcut: 'r', description: 'Initial Lambda supported AWS region' }, { option: 'notificationEmail', shortcut: 'e', description: 'email to use for AWS alarms' }, { option: 'profile', // we need profile option for CLI API (non interactive) shortcut: 'p', description: 'AWS profile that is set in your aws config file' }, { option: 'noExeCf', shortcut: 'c', description: 'Optional - Don\'t execute CloudFormation, just generate it. Default: false' } ] }); return BbPromise.resolve(); } /** * Action */ projectInit(evt) { let _this = this; this.evt = evt; // Check for AWS Profiles let profilesList = awsMisc.profilesMap(); this.profiles = Object.keys(profilesList); // Greet if (_this.S.config.interactive) SCli.asciiGreeting(); /** * Control Flow */ return BbPromise.try(function() { console.log(''); SCli.log('Initializing Serverless Project...'); }) .bind(_this) .then(_this._prompt) .then(_this._validateAndPrepare) .then(_this._scaffold) .then(_this._createStageAndRegion) .then(_this._installComponentDeps) .then(function() { SCli.log('Successfully initialized project "' + _this.evt.options.name +'"'); /** * Return EVT */ _this.evt.data.projectPath = _this.S.config.projectPath; return _this.evt; }); } /** * Prompt */ _prompt() { let _this = this; // Set temp name let name = _this.evt.options.name || ('serverless' + SUtils.generateShortId(6)).toLowerCase(); // Skip if non-interactive if (!_this.S.config.interactive) return BbPromise.resolve(); // Values that exist will not be prompted let overrides = { name: _this.evt.options.name, domain: _this.evt.options.domain, notificationEmail: _this.evt.options.notificationEmail, awsAdminKeyId: _this.evt.options.awsAdminKeyId, awsAdminSecretKey: _this.evt.options.awsAdminSecretKey }; let prompts = { properties: { name: { description: 'Enter a name for this project: '.yellow, default: name, message: 'Name must be only letters, numbers or dashes', required: true, conform: function(name) { let re = /^[a-zA-Z0-9-_]+$/; // This hack updates the defaults in the other prompts if (re.test(name)) _this.evt.options.name = name; return re.test(name); } }, domain: { description: 'Enter a domain for this project (used for the Serverless Project Bucket): '.yellow, default: name + '.com', message: 'Domain must only contain lowercase letters, numbers, periods and dashes', required: true, conform: function(bucket) { let re = /^[a-z0-9-.]+$/; return re.test(bucket); } }, notificationEmail: { description: 'Enter an email to use for AWS alarms: '.yellow, required: true, message: 'Please enter a valid email', default: 'me@' + name + '.com', conform: function(email) { let re = /^([\w-]+(?:\.[\w-]+)*)@((?:[\w-]+\.)*\w[\w-]{0,66})\.([a-z]{2,6}(?:\.[a-z]{2})?)$/i; return re.test(email); } } } }; if (!_this.profiles || !_this.profiles.length) { prompts.properties.awsAdminKeyId = { description: 'Enter the ACCESS KEY ID for your Admin AWS IAM User: '.yellow, required: true, message: 'Please enter a valid access key ID', conform: function(key) { return (key) ? true : false; } }; prompts.properties.awsAdminSecretKey = { description: 'Enter the SECRET ACCESS KEY for your Admin AWS IAM User: '.yellow, required: true, message: 'Please enter a valid secret access key', conform: function(key) { return (key) ? true : false; } }; } return this.cliPromptInput(prompts, overrides) .then(function(answers) { // Set prompt values _this.S.config.awsAdminKeyId = answers.awsAdminKeyId; _this.S.config.awsAdminSecretKey = answers.awsAdminSecretKey; _this.evt.options.name = answers.name; _this.evt.options.domain = answers.domain; _this.evt.options.notificationEmail = answers.notificationEmail; // Show region prompt if (!_this.evt.options.region) { // Prompt: region select let choices = awsMisc.validLambdaRegions.map(r => { return { key: '', value: r, label: r }; }); return _this.cliPromptSelect('Select a region for your project: ', choices, false) .then(results => { _this.evt.options.region = results[0].value; }); } }) .then(function() { // If profile exists, skip select prompt if (_this.profile) return; // If aws credentials were passed, skip select prompt if (_this.S.config.awsAdminKeyId && _this.S.config.awsAdminSecretKey) return; // Prompt: profile select let choices = []; for (let i = 0; i < _this.profiles.length; i++) { choices.push({ key: '', value: _this.profiles[i], label: _this.profiles[i] }); } return _this.cliPromptSelect('Select an AWS profile for your project: ', choices, false) .then(results => { _this.profile = results[0].value; }); }); } /** * Validate & Prepare * - Validate all data from event, interactive CLI or non interactive CLI and prepare project data */ _validateAndPrepare() { // Initialize AWS Misc Service this.AwsMisc = require('../utils/aws/Misc'); // If Profile, extract API Keys if (this.profile) { this.S.config.awsAdminKeyId = this.AwsMisc.profilesGet(this.profile)[this.profile].aws_access_key_id; this.S.config.awsAdminSecretKey = this.AwsMisc.profilesGet(this.profile)[this.profile].aws_secret_access_key; } // Validate API Keys if (!this.S.config.awsAdminKeyId || !this.S.config.awsAdminSecretKey) { return BbPromise.reject(new SError('Missing AWS API Key and/or AWS Secret Key')); } // Initialize Other AWS Services let awsConfig = { region: this.evt.options.region, accessKeyId: this.S.config.awsAdminKeyId, secretAccessKey: this.S.config.awsAdminSecretKey }; this.S3 = require('../utils/aws/S3')(awsConfig); this.CF = require('../utils/aws/CloudFormation')(awsConfig); // Validate Name - AWS only allows Alphanumeric and - in name let nameOk = /^([a-zA-Z0-9-]+)$/.exec(this.evt.options.name); if (!nameOk) { return BbPromise.reject(new SError('Project names can only be alphanumeric and -')); } // Validate Domain let domainRegex = /^[a-z0-9-.]+$/; if(!domainRegex.test(this.evt.options.domain)) { return BbPromise.reject(new SError('Domain must only contain lowercase letters, numbers, periods and dashes')); } // Validate NotificationEmail let emailRegex = /^([\w-]+(?:\.[\w-]+)*)@((?:[\w-]+\.)*\w[\w-]{0,66})\.([a-z]{2,6}(?:\.[a-z]{2})?)$/i; if(!emailRegex.test(this.evt.options.notificationEmail)) { return BbPromise.reject(new SError('Please enter a valid email')); } // Validate Region if (awsMisc.validLambdaRegions.indexOf(this.evt.options.region) == -1) { return BbPromise.reject(new SError('Invalid region. Lambda not supported in ' + this.evt.options.region, SError.errorCodes.UNKNOWN)); } return BbPromise.resolve(); } /** * Update Scaffolding */ _scaffold() { let _this = this; return BbPromise.try(function() { // If project does not exist, create scaffolding if (!_this.S.config.projectPath) { // Update Global Serverless Instance _this.S.updateConfig({ projectPath: path.resolve(path.join(path.dirname('.'), _this.evt.options.name)) }); } // Fill in meta attributes _this.meta = _this.S.state.getMeta(); _this.meta.variables.project = _this.evt.options.name; _this.meta.variables.projectBucket = SUtils.generateProjectBucketName(_this.evt.options.domain, _this.evt.options.region); _this.meta.variables.domain = _this.evt.options.domain; _this.meta.variables.notificationEmail = _this.evt.options.notificationEmail; // Fill in project attributes _this.project = _this.S.state.getProject(); _this.project.name = _this.evt.options.name; // Delete unnecessary package.json properties if (_this.project.readme) delete _this.project.readme; if (_this.project.readmeFilename) delete _this.project.readmeFilename; if (_this.project.gitHead) delete _this.project.gitHead; if (_this.project._id) delete _this.project._id; if (_this.project._shasum) delete _this.project._shasum; if (_this.project._from) delete _this.project._from; if (_this.project._npmVersion) delete _this.project._npmVersion; if (_this.project._nodeVersion) delete _this.project._nodeVersion; if (_this.project._npmUser) delete _this.project._npmUser; if (_this.project.dist) delete _this.project.dist; if (_this.project.maintainers) delete _this.project.maintainers; if (_this.project.directories) delete _this.project.directories; if (_this.project._resolved) delete _this.project._resolved; if (_this.project._args) delete _this.project._args; if (_this.project._inCache) delete _this.project._inCache; if (_this.project._installable) delete _this.project._installable; if (_this.project._location) delete _this.project._location; if (_this.project._phantomChildren) delete _this.project._phantomChildren; if (_this.project._requested) delete _this.project._requested; if (_this.project._requiredBy) delete _this.project._requiredBy; if (_this.project._shrinkwrap || _this.project._shrinkwrap === null) delete _this.project._shrinkwrap; if (_this.project._spec) delete _this.project._spec; if (_this.project._where) delete _this.project._where; // Save State return _this.S.state.save(); }); } /** * Create Stage And Region */ _createStageAndRegion() { this.evt.options.stage = 'development'; return this.S.actions.stageCreate({ options: { stage: this.evt.options.stage, region: this.evt.options.region, noExeCf: this.evt.options.noExeCf ? true : false } }); } /** * Create Stage And Region */ _installComponentDeps() { let _this = this, components = _this.S.state.getComponents(); components.forEach(function(component) { SCli.log(`Installing ${component.runtime} dependencies for component: ${component.name}`); if (component.runtime === 'nodejs') { SUtils.npmInstall(path.join(_this.S.config.projectPath, component.name)); } else if (component.runtime === 'python2.7') { SUtils.pipPrefixInstall( path.join(_this.S.config.projectPath, component.name, 'requirements.txt'), path.join(_this.S.config.projectPath, component.name, 'vendored') ); } return BbPromise.resolve(); }); } } return( ProjectInit ); };