import path from 'path';
import { exec } from 'child_process';
import _ from 'lodash';
import { existsSync, mkdirp } from 'fs-extra';
import { registerAction } from '@usecannon/builder';
import { resolveCliSettings } from './settings';

import Debug from 'debug';

const debug = Debug('cannon:cli:plugins');

const DEPRECATED_PLUGINS = ['cannon-plugin-router'];

export async function installPlugin(name: string) {
  const packageJsonExists = existsSync(path.join(_getPluginDir(), 'package.json'));
  if (!packageJsonExists) {
    await mkdirp(_getPluginDir());
    debug('plugin init:', await _exec('npm init -y'));
  }
  debug('plugin install:', await _exec(`npm install ${name}`));
}

export async function removePlugin(name: string) {
  debug('plugin uninstall:', await _exec(`npm uninstall ${name}`));
}

export async function listInstalledPlugins() {
  if (!existsSync(_getPluginDir())) {
    return [];
  }

  const installedPlugins = Object.keys(
    _.pickBy(JSON.parse(await _exec('npm ls --json')).dependencies, (d: any) => !d.extraneous)
  ) as string[];

  for (const deprecated of DEPRECATED_PLUGINS) {
    const index = installedPlugins.indexOf(deprecated);
    if (index !== -1) {
      await removePlugin(deprecated);
      installedPlugins.splice(index, 1);
    }
  }

  return installedPlugins;
}

export async function loadPlugin(name: string) {
  const pluginFolder = path.join(_getPluginDir(), 'node_modules', name);

  // read pkg to get the actual plugin load dir
  // eslint-disable-next-line @typescript-eslint/no-var-requires
  const pkg = require(path.join(pluginFolder, 'package.json'));

  const pluginFile = pkg.cannon || pkg.main || '';

  return require(path.join(pluginFolder, pluginFile));
}

export async function loadPlugins() {
  const installedPlugins = await listInstalledPlugins();

  for (const plugin of installedPlugins) {
    const pluginAction = await loadPlugin(plugin);

    if (Array.isArray(pluginAction)) {
      for (const action of pluginAction) registerAction(action);
    } else {
      registerAction(pluginAction);
    }
  }
}

function _getPluginDir() {
  const cliSettings = resolveCliSettings();
  return path.join(cliSettings.cannonDirectory, 'plugins');
}

function _exec(cmd: string): Promise<string> {
  return new Promise((resolve, reject) => {
    exec(cmd, { cwd: _getPluginDir() }, (error, stdout) => {
      if (error) {
        reject(new Error(`command ${cmd} failed with error: ${error}`));
        return;
      }
      resolve(stdout);
    });
  });
}