Mirrors/overte
3
0
Fork 0
mirror of https://github.com/overte-org/overte.git synced 2025-04-21 18:44:00 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Move Process and ProcessGroup to process.js module

Browse source
This commit is contained in:
Ryan Huffman 2015-12-03 13:37:21 -08:00
parent 1b85327e4a
commit a41f41a514
2 changed files with 100 additions and 90 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

94
console/main.js
View file

@ -1,14 +1,14 @@
'use strict'
var extend = require('extend');
var util = require('util');
var events = require('events');
var electron = require('electron');
var app = electron.app; // Module to control application life.
var BrowserWindow = require('browser-window'); // Module to create native browser window.
var Menu = require('menu');
var Tray = require('tray');
var childProcess = require('child_process');
var process = require('./modules/process.js');
var Process = process.Process;
var ProcessGroup = process.ProcessGroup;
const ipcMain = electron.ipcMain;
@ -22,92 +22,6 @@ var appIcon = null;
var TRAY_ICON = 'resources/tray-icon.png';
var APP_ICON = 'resources/tray-icon.png';
const ProcessStates = {
STOPPED: 'stopped',
STARTED: 'started',
STOPPING: 'stopping'
};
function ProcessGroup(name, processes) {
this.name = name;
this.processes = processes;
};
util.inherits(ProcessGroup, events.EventEmitter);
ProcessGroup.prototype = extend(ProcessGroup.prototype, {
addProcess: function(process) {
this.processes.push(process);
},
start: function() {
for (let process of this.processes) {
process.start();
}
},
stop: function() {
for (let process of this.processes) {
process.stop();
}
}
});
var ID = 0;
function Process(name, command, commandArgs) {
events.EventEmitter.call(this);
this.id = ++ID;
this.name = name;
this.command = command;
this.commandArgs = commandArgs ? commandArgs : [];
this.child = null;
this.state = ProcessStates.STOPPED;
};
util.inherits(Process, events.EventEmitter);
Process.prototype = extend(Process.prototype, {
start: function() {
if (this.state != ProcessStates.STOPPED) {
console.warn("Can't start process that is not stopped.");
return;
}
console.log("Starting " + this.command);
try {
this.child = childProcess.spawn(this.command, this.commandArgs, {
detached: false
});
//console.log("started ", this.child);
this.child.on('error', this.onChildStartError.bind(this));
this.child.on('close', this.onChildClose.bind(this));
this.state = ProcessStates.STARTED;
console.log("Child process started");
} catch (e) {
console.log("Got error starting child process for " + this.name, e);
this.child = null;
this.state = ProcessStates.STOPPED;
}
this.emit('state-update');
},
stop: function() {
if (this.state != ProcessStates.STARTED) {
console.warn("Can't stop process that is not started.");
return;
}
this.child.kill();
this.state = ProcessStates.STOPPING;
},
// Events
onChildStartError: function(error) {
console.log("Child process error ", error);
this.state = ProcessStates.STOPPED;
this.emit('state-update');
},
onChildClose: function(code) {
console.log("Child process closed with code ", code);
this.state = ProcessStates.STOPPED;
this.emit('state-update');
}
});
// Quit when all windows are closed.
app.on('window-all-closed', function() {
// On OS X it is common for applications and their menu bar

96
console/modules/process.js Executable file
View file

@ -0,0 +1,96 @@
'use strict'
var extend = require('extend');
var util = require('util');
var events = require('events');
var childProcess = require('child_process');
const ProcessStates = {
STOPPED: 'stopped',
STARTED: 'started',
STOPPING: 'stopping'
};
function ProcessGroup(name, processes) {
this.name = name;
this.processes = processes;
};
util.inherits(ProcessGroup, events.EventEmitter);
ProcessGroup.prototype = extend(ProcessGroup.prototype, {
addProcess: function(process) {
this.processes.push(process);
},
start: function() {
for (let process of this.processes) {
process.start();
}
},
stop: function() {
for (let process of this.processes) {
process.stop();
}
}
});
var ID = 0;
function Process(name, command, commandArgs) {
events.EventEmitter.call(this);
this.id = ++ID;
this.name = name;
this.command = command;
this.commandArgs = commandArgs ? commandArgs : [];
this.child = null;
this.state = ProcessStates.STOPPED;
};
util.inherits(Process, events.EventEmitter);
Process.prototype = extend(Process.prototype, {
start: function() {
if (this.state != ProcessStates.STOPPED) {
console.warn("Can't start process that is not stopped.");
return;
}
console.log("Starting " + this.command);
try {
this.child = childProcess.spawn(this.command, this.commandArgs, {
detached: false
});
//console.log("started ", this.child);
this.child.on('error', this.onChildStartError.bind(this));
this.child.on('close', this.onChildClose.bind(this));
this.state = ProcessStates.STARTED;
console.log("Child process started");
} catch (e) {
console.log("Got error starting child process for " + this.name, e);
this.child = null;
this.state = ProcessStates.STOPPED;
}
this.emit('state-update');
},
stop: function() {
if (this.state != ProcessStates.STARTED) {
console.warn("Can't stop process that is not started.");
return;
}
this.child.kill();
this.state = ProcessStates.STOPPING;
},
// Events
onChildStartError: function(error) {
console.log("Child process error ", error);
this.state = ProcessStates.STOPPED;
this.emit('state-update');
},
onChildClose: function(code) {
console.log("Child process closed with code ", code);
this.state = ProcessStates.STOPPED;
this.emit('state-update');
}
});
module.exports.Process = Process;
module.exports.ProcessGroup = ProcessGroup;
module.exports.ProcessStates = ProcessStates;