@faasjs/deployer/lib/index.js

'use strict';

Object.defineProperty(exports, '__esModule', { value: true });

function _interopDefault (ex) { return (ex && (typeof ex === 'object') && 'default' in ex) ? ex['default'] : ex; }

var fs = require('fs');
var path = require('path');
var load = require('@faasjs/load');
var Logger = _interopDefault(require('@faasjs/logger'));
var deepMerge = _interopDefault(require('@faasjs/deep_merge'));
var cloud_function = require('@faasjs/cloud_function');

class Deployer {
    constructor(data) {
        data.name = data.filename.replace(data.root, '').replace('.func.ts', '');
        data.version = new Date().toLocaleString('zh-CN', {
            hour12: false,
            timeZone: 'Asia/Shanghai',
        }).replace(/[^0-9]+/g, '_');
        data.logger = new Logger('Deployer');
        const Config = load.loadConfig(data.root, data.filename);
        if (!data.env)
            data.env = process.env.FaasEnv || Config.defaults.deploy.env;
        data.config = Config[data.env];
        if (!data.config)
            throw Error(`Config load failed: ${data.env}`);
        data.tmp = path.join(data.root, 'tmp', data.env, data.name, data.version) + path.sep;
        data.tmp.split(path.sep).reduce(function (acc, cur) {
            acc += path.sep + cur;
            if (!fs.existsSync(acc))
                fs.mkdirSync(acc);
            return acc;
        });
        this.deployData = data;
    }
    async deploy() {
        const data = this.deployData;
        const loadResult = await load.loadTs(data.filename, { tmp: true });
        const func = loadResult.module;
        if (!func)
            throw Error(`Func load failed: ${data.filename}`);
        if (func.config)
            data.config = deepMerge(data.config, func.config);
        data.dependencies = deepMerge(loadResult.dependencies, func.dependencies);
        // 按类型分类插件
        const includedCloudFunction = [];
        for (let i = 0; i < func.plugins.length; i++) {
            const plugin = func.plugins[i];
            if (!plugin.type) {
                data.logger.error('Unknow plugin type: %o', plugin);
                throw Error('[Deployer] Unknow plugin type');
            }
            if (plugin.type === 'cloud_function')
                includedCloudFunction.push({
                    index: i,
                    plugin
                });
        }
        // 将云函数插件移到最后
        if (includedCloudFunction.length)
            for (const plugin of includedCloudFunction) {
                func.plugins.splice(plugin.index, 1);
                func.plugins.push(plugin.plugin);
            }
        else {
            const functionPlugin = new cloud_function.CloudFunction();
            func.plugins.push(functionPlugin);
        }
        await func.deploy(this.deployData);
        return this.deployData;
    }
}

exports.Deployer = Deployer;