command-manager/bin/thread.js

/**
 * Created by nuintun on 2015/12/3.
 */

'use strict';

var path = require('path');
var ipc = require('ipc-main');
var Emulator = require('./emulator');

// cache
var threads = {};

module.exports = {
  start: function (){
    ipc.on('emulator', function (event, project, action){
      var thread = threads[project.name];

      console.log('action', action);

      switch (action) {
        case 'start':
          console.log(!thread || !thread.connected);

          if (!thread || !thread.connected) {
            console.log('start');
            var env = {};

            Object.keys(process.env).forEach(function (key){
              env[key] = process.env[key];
            });

            project.env.forEach(function (item){
              env[item.name] = item.value;
            });

            thread = new Emulator({
              env: env,
              cwd: project.path,
              command: project.command.value
            });

            thread.on('data', function (data){
              event.sender.send('emulator', 'data', project, data.toString());
            });

            thread.on('error', function (error){
              event.sender.send('emulator', 'error', project, error.toString());
            });

            thread.on('close', function (signal){
              event.sender.send('emulator', 'close', project, signal.toString());

              console.log('close');
              delete threads[project.name];
            });

            thread.start();

            threads[project.name] = thread;
          } else {
            thread.stop();
          }
          break;
        case 'stop':
          if (thread) {
            thread.stop();
          } else {
            event.sender.send('emulator', 'close', project, 0);
          }
          break;
      }
    });
  }
};