@anycli/plugin-plugins/lib/plugins.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const config_1 = require("@anycli/config");
const cli_ux_1 = require("cli-ux");
const fs = require("fs-extra");
const http_call_1 = require("http-call");
const path = require("path");
const manifest_1 = require("./manifest");
const yarn_1 = require("./yarn");
class Plugins {
    constructor(config) {
        this.config = config;
        this.manifest = new manifest_1.default(path.join(this.config.dataDir, 'plugins', 'user.json'));
        this.yarn = new yarn_1.default({ config, cwd: this.userPluginsDir });
        this.debug = require('debug')('@anycli/plugins');
    }
    async list() {
        const plugins = await this.manifest.list();
        return Object.entries(plugins);
    }
    async install(name, tag = 'latest') {
        try {
            const unfriendly = this.unfriendlyName(name);
            if (unfriendly) {
                let version = await this.fetchVersionFromNPM({ name: unfriendly, tag });
                if (version)
                    name = unfriendly;
            }
            await this.createPJSON();
            await this.yarn.exec(['add', `${name}@${tag}`]);
            await this.loadPlugin(name, tag);
            // if (!plugin.commands.length) throw new Error('no commands found in plugin')
            await this.manifest.add(name, tag);
        }
        catch (err) {
            await this.uninstall(name).catch(err => this.debug(err));
            throw err;
        }
    }
    async uninstall(name) {
        await this.manifest.remove(name);
        try {
            await this.yarn.exec(['remove', name]);
        }
        catch (err) {
            cli_ux_1.cli.warn(err);
        }
    }
    async hasPlugin(name) {
        const list = await this.list();
        const plugin = list.find(([n]) => this.friendlyName(n) === this.friendlyName(name));
        if (plugin)
            return plugin[0];
    }
    unfriendlyName(name) {
        if (name.includes('@'))
            return;
        const defaultScope = this.config.pjson.anycli.pluginScope;
        if (!defaultScope)
            return;
        return `@${defaultScope}/plugin-${name}`;
    }
    friendlyName(name) {
        const defaultScope = this.config.pjson.anycli.pluginScope;
        if (!defaultScope)
            return name;
        const match = name.match(`@${defaultScope}/plugin-(.+)`);
        if (!match)
            return name;
        return match[1];
    }
    userPluginPath(name) {
        return path.join(this.userPluginsDir, 'node_modules', name);
    }
    async loadPlugin(name, _) {
        const config = await config_1.read({ root: this.userPluginPath(name) });
        return this.config.engine.load(config);
        // return this.config.engine!.load(config, {resetCache: true})
    }
    async createPJSON() {
        if (!await fs.pathExists(this.pjsonPath)) {
            await fs.outputJSON(this.pjsonPath, { private: true, anycli: { schema: 1 } }, { spaces: 2 });
        }
    }
    get userPluginsDir() {
        return path.join(this.config.dataDir, 'plugins');
    }
    get pjsonPath() {
        return path.join(this.userPluginsDir, 'package.json');
    }
    async fetchVersionFromNPM(plugin) {
        try {
            let url = `${this.config.npmRegistry}/-/package/${plugin.name.replace('/', '%2f')}/dist-tags`;
            const { body: pkg } = await http_call_1.default.get(url);
            return pkg[plugin.tag];
        }
        catch (err) {
            this.debug(err);
        }
    }
}
exports.default = Plugins;