@mindev/min-cli/lib/class/Xcx.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const fs = require("fs-extra");
const path = require("path");
const glob = require("glob");
const _ = require("lodash");
const chokidar = require("chokidar");
const class_1 = require("../class");
const util_1 = require("../util");
const MINI_PROGRAM_CONFIG_FILE_NAME = 'project.config.json';
/**
 * 小程序类，用于转换，编译和实时监听
 *
 * @export
 * @class Xcx
 */
class Xcx {
    /**
     * Creates an instance of Xcx.
     * @param {Xcx.Options} options
     * @memberof Xcx
     */
    constructor(options) {
        this.options = options;
    }
    /**
     * 解析节点树
     *
     * @param {(Xcx.Entry | Xcx.Entry[])} entry
     * @returns {XcxNode[]}
     * @memberof Xcx
     */
    parser(entry) {
        let xcxNodes = [];
        if (_.isArray(entry)) {
            entry.forEach(item => {
                xcxNodes = [...xcxNodes, ...this.parser(item)];
            });
        }
        else {
            if (entry.isGlob) {
                // 搜索文件结果
                let requests = glob.sync(entry.request, {
                    cwd: entry.parent || util_1.config.cwd
                });
                // 创建入口文件配置
                let list = requests.map(request => {
                    return Object.assign({}, _.omit(entry, 'isGlob'), { request });
                });
                // 遍历
                xcxNodes = [...xcxNodes, ...this.parser(list)];
            }
            else {
                // 创建节点树
                let xcxNode = class_1.XcxNode.create(entry);
                if (xcxNode) {
                    xcxNodes.push(xcxNode);
                }
            }
        }
        return xcxNodes;
    }
    /**
     * 通过 Entry 入口生成节点树并进行转换
     *
     * @param {(Xcx.Entry | Xcx.Entry[])} entry
     * @memberof Xcx
     */
    transfromFromEntry(entry) {
        let xcxNodes = this.parser(entry);
        this.transfrom(xcxNodes);
    }
    /**
     * 转换节点树
     *
     * @param {(XcxNode | XcxNode [])} xcxNode
     * @memberof Xcx
     */
    transfrom(xcxNode) {
        class_1.XcxTraverse.traverse(xcxNode, this.options.traverse);
    }
    /**
     * 编译
     *
     * @memberof Xcx
     */
    compile(isFromWatch) {
        util_1.log.newline();
        this.clear(isFromWatch);
        // this.copyProjectConfig()
        this.appCompile();
        this.pagesCompile();
        this.imagesCompile();
    }
    /**
     * 清空 packages 目录下 dest 下的文件
     *
     * @memberof Xcx
     */
    clearPackages() {
        let { isClear, packageNames = [] } = this.options;
        if (!isClear)
            return;
        packageNames.forEach(packageName => {
            fs.emptyDirSync(util_1.config.getPath('packages', packageName, util_1.config.package.dest));
        });
    }
    /**
     * 编译 packages 下的组件，仅用于 min publish
     *
     * @memberof Xcx
     */
    compilePackages() {
        this.clearPackages();
        let { packageNames = [] } = this.options;
        let glob = '';
        if (packageNames.length === 0) {
            glob = '**';
        }
        else if (packageNames.length === 1) {
            glob = packageNames[0];
        }
        else {
            glob = `{${packageNames.join(',')}}`;
        }
        // ./**/src/index.wxc
        glob = `./${glob}/${util_1.config.package.src}/*${util_1.config.ext.wxc}`;
        let xcxEntry = {
            request: glob,
            parent: util_1.config.getPath('packages'),
            isMain: true,
            isGlob: true,
            isPublish: true
        };
        this.transfromFromEntry(xcxEntry);
    }
    /**
     * 监听文件新增、修改、删除
     *
     * @memberof Xcx
     */
    watch() {
        let watcher = chokidar.watch([util_1.config.src, util_1.config.packages, util_1.config.filename, MINI_PROGRAM_CONFIG_FILE_NAME], {
            cwd: util_1.config.cwd,
            ignored: /node_modules|\.git|\.txt|\.log|\.DS_Store|\.npmignore|package\.json/i,
            persistent: true,
            ignoreInitial: true
        });
        watcher
            .on('add', this.watchAdd.bind(this))
            .on('change', this.watchChange.bind(this))
            .on('unlink', this.watchDelete.bind(this))
            .on('error', (err) => {
            util_1.log.fatal(err);
        })
            .on('ready', () => {
            if (!this.isWatched) {
                this.isWatched = true;
                util_1.log.msg(util_1.LogType.WATCH, '开始监听文件改动。');
            }
        });
        return watcher;
    }
    /**
     * 编译 从Next里获取监听变更文件，或者是之前存在缺失文件
     *
     * @memberof Xcx
     */
    next() {
        let requests = util_1.xcxNext.get();
        if (!requests.length) {
            return;
        }
        let xcxEntry = requests.map(request => {
            return {
                request,
                parent: util_1.config.cwd,
                isMain: true,
                isForce: true
            };
        });
        util_1.log.newline();
        this.transfromFromEntry(xcxEntry);
        util_1.xcxNext.reset();
    }
    /**
     * 拷贝小程序项目配置文件
     *
     * @private
     * @memberof Xcx
     */
    // private copyProjectConfig () {
    //   let src = path.join(config.cwd, MINI_PROGRAM_CONFIG_FILE_NAME)
    //   let dest = config.getPath('dest', MINI_PROGRAM_CONFIG_FILE_NAME)
    //   if (!fs.existsSync(src)) {
    //     return
    //   }
    //   log.newline()
    //   log.msg(LogType.COPY, MINI_PROGRAM_CONFIG_FILE_NAME)
    //   fs.copySync(src, dest)
    // }
    /**
     * 删除小程序项目配置文件
     *
     * @private
     * @memberof Xcx
     */
    // private deleteProjectConfig () {
    //   let dest = config.getPath('dest', MINI_PROGRAM_CONFIG_FILE_NAME)
    //   if (!fs.existsSync(dest)) {
    //     return
    //   }
    //   log.newline()
    //   log.msg(LogType.DELETE, MINI_PROGRAM_CONFIG_FILE_NAME)
    //   fs.unlinkSync(dest)
    // }
    /**
     * 编译 APP 应用层
     *
     * @memberof Xcx
     */
    appCompile() {
        let { app = {} } = this.options;
        let { isSFC } = app;
        let xcxEntry = {
            request: isSFC ? `./app${util_1.config.ext.wxa}` : './app.{js,wxss}',
            parent: util_1.config.getPath('src'),
            isMain: true,
            isGlob: isSFC ? false : true
        };
        this.transfromFromEntry(xcxEntry);
    }
    /**
     * 编译 Pages 页面列表
     *
     * @private
     * @param {string[]} [pages]
     * @memberof Xcx
     */
    pagesCompile() {
        const tabBarList = util_1.Global.appTabBarList;
        /**
         * [
         *    pages/hello/index,
         *    pages/world/index
         * ]
         */
        let pages = this.options.pages || [];
        if (pages.length === 0) {
            pages = util_1.Global.appPages || [];
        }
        let xcxEntry = [];
        if (pages.length > 0) { // 优先编译命令行带过来的名称 或 app.json 里的 pages 字段
            let pageFiles = [];
            /**
             * [
             *    pages/hello/index.wxp,
             *    pages/world/index.wxp
             * ]
             */
            pageFiles = [...pageFiles, ...pages.map(page => `${page}${util_1.config.ext.wxp}`)];
            // 合并 tabBar.List 的选项卡页面
            pageFiles = [...pageFiles, ...tabBarList.map(tabBarItem => `${tabBarItem.pagePath}${util_1.config.ext.wxp}`)];
            // 去重
            pageFiles = _.uniq(pageFiles);
            xcxEntry = [...xcxEntry, ...pageFiles.map(pageFile => {
                    return {
                        request: pageFile,
                        parent: util_1.config.getPath('src'),
                        isMain: true
                    };
                })];
        }
        else { // 最后按照 模糊匹配所有的 .wxp 文件编译
            xcxEntry = [...xcxEntry, {
                    request: `**/*${util_1.config.ext.wxp}`,
                    parent: util_1.config.getPath('pages'),
                    isMain: true,
                    isGlob: true
                }];
        }
        this.transfromFromEntry(xcxEntry);
    }
    /**
     * 编译 Image 图片，只支持app.json里的 tabar 选项卡的 icon 图片路径
     *
     * @memberof Xcx
     */
    imagesCompile() {
        const tabBarList = util_1.Global.appTabBarList;
        // Array.prototype.concat.apply([], [[], [], []])
        const images = Array.prototype.concat.apply([], tabBarList.map(tabBarItem => {
            let map = [];
            if (tabBarItem.iconPath) {
                map.push({
                    origin: util_1.config.getPath('src', tabBarItem.iconPath),
                    target: util_1.config.getPath('dest', tabBarItem.iconPath)
                });
            }
            if (tabBarItem.selectedIconPath) {
                map.push({
                    origin: util_1.config.getPath('src', tabBarItem.selectedIconPath),
                    target: util_1.config.getPath('dest', tabBarItem.selectedIconPath)
                });
            }
            return map;
        }));
        images.forEach(image => {
            if (!fs.existsSync(image.origin)) {
                util_1.log.fatal(`找不到文件：${image.origin}`);
                return;
            }
            fs.copySync(image.origin, image.target);
        });
    }
    /**
     * 监听新增
     *
     * @private
     * @param {string} file
     * @memberof Xcx
     */
    watchAdd(file) {
        let isProjectConfig = file === MINI_PROGRAM_CONFIG_FILE_NAME;
        // if (isProjectConfig) { // 拷贝小程序项目配置文件
        //   this.copyProjectConfig()
        // } else {
        // }
        util_1.xcxNext.watchNewFile(file);
        this.next();
    }
    /**
     * 监听变更
     *
     * @private
     * @param {string} file
     * @memberof Xcx
     */
    watchChange(file) {
        let isApp = file === path.join(util_1.config.src, `app${util_1.config.ext.wxa}`);
        let isMinConfig = file === util_1.config.filename;
        let isProjectConfig = file === MINI_PROGRAM_CONFIG_FILE_NAME;
        // if (isProjectConfig) { // 拷贝小程序项目配置文件
        //   this.copyProjectConfig()
        // } else
        if (isApp || isMinConfig) { // 重新编译
            this.compile(true);
        }
        else {
            util_1.xcxNext.watchChangeFile(file);
            this.next();
        }
    }
    /**
     * 监听删除
     *
     * @private
     * @param {string} file
     * @memberof Xcx
     */
    watchDelete(file) {
        let isMinConfig = file === util_1.config.filename;
        let isProjectConfig = file === MINI_PROGRAM_CONFIG_FILE_NAME;
        // if (isProjectConfig) { // 删除小程序项目配置文件
        //   this.deleteProjectConfig()
        // } else
        if (isMinConfig) { // 重新编译
            this.compile(true);
        }
        else {
            util_1.xcxNext.watchDeleteFile(file);
            this.next();
        }
    }
    /**
     * Clear cache and dest dir
     *
     * @private
     * @param {Boolean} [isFromWatch] Is from the watch of chokidar
     * @memberof Xcx
     */
    clear(isFromWatch) {
        this.clearCache();
        if (isFromWatch) {
            return;
        }
        this.clearDest();
    }
    /**
     * Clear cache
     *
     * @private
     * @memberof Xcx
     */
    clearCache() {
        let { isClear } = this.options;
        if (!isClear)
            return;
        util_1.Global.clear();
        util_1.xcxNext.clear();
        util_1.xcxNodeCache.clear();
    }
    /**
     * Clear dest dir
     *
     * @private
     * @memberof Xcx
     */
    clearDest() {
        let { isClear } = this.options;
        if (!isClear)
            return;
        fs.emptyDirSync(util_1.config.getPath('dest'));
    }
}
exports.Xcx = Xcx;