var util = require('./util');
var Q = require('q');
var spawn = require('child_process').spawn;
var readline = require('readline');

module.exports = function(gulp, plugins, config) {
  return function() {
    return isInstalled().then(function(installed) {
      if (!installed) {
        return util.processToPromise(spawn(config.pub,
          ['global', 'activate', config.packageName, '--no-executables'], {
          stdio: 'inherit'
        }));
      }
    }).then(function() {
      return util.processToPromise(spawn(config.pub, ['global', 'run'].concat(config.args), {
        stdio: 'inherit'
      }));
    });
  };

  function isInstalled() {
    var subProcess = spawn(config.pub, ['global', 'list'], {
      // inherit stdin and stderr, but filter stdout
      stdio: [process.stdin, 'pipe', process.stderr]
    });
    var rl = readline.createInterface({
      input: subProcess.stdout,
      output: process.stdout,
      terminal: false
    });
    var found = false;
    rl.on('line', function(line) {
      if (line.indexOf(config.packageName) !== -1) {
        found = true;
      }
      console.log(line);
    });
    return util.processToPromise(subProcess).then( function() {
      return found;
    });
  }

};