Initial commit again

Author: cookednoodles

Diff for: config.js

@@ -0,0 +1,18 @@
+var config = {};
+
+
+config.process = {};
+config.server = {};
+
+config.process.listen_port = 8001;
+config.process.console_port = 8002;
+config.process.events_port = 8003;
+
+// config.server.command_line = "java -Xmx {{Xmx}} -jar minecraft.jar";
+config.server.command_line = "./count.sh";
+config.server.path = "./";
+config.server.variables = {"Xmx":"512Mb"};
+config.server.port = 25565;
+config.server.plugin = "minecraft";
+
+module.exports = config;

Diff for: count.sh

@@ -0,0 +1,5 @@
+#!/bin/bash
+for COUNT in $(seq 1 100); do
+  echo $COUNT
+  sleep 0.25
+done

Diff for: gameprocess.js

@@ -0,0 +1,77 @@
+var spawn = require('child_process').spawn;
+var config = require('./config');
+var util = require("util");
+var events = require("events");
+var plugins = require("./plugins.js").plugins;
+
+var OFF = 0; ON = 1, STARTING = 2, STOPPING = 3;
+
+function GameServer() {
+  self = this;
+  this.status = OFF;
+  this.commandline = config.server.command_line;
+  this.plugin = plugins[config.server.plugin + '.js']; 
+};
+
+util.inherits(GameServer, events.EventEmitter);
+
+GameServer.prototype.turnon = function(){
+    // Shouldn't happen, but does on a crash after restart
+    if (!self.status == OFF){
+      console.log("Tried to turn on but status is already : " + self.status); 
+      return      
+    }
+      
+    this.ps = spawn(config.server.command_line);
+    this.output = this.ps.stdout;
+    self.status = STARTING;
+
+    this.output.on('data', function(data){
+      output = data.toString();
+      console.log(output);
+      self.emit('console', output);
+    });
+    
+    
+    this.ps.on('exit', function(){
+      if (self.status == STOPPING){
+	console.log("Process stopped");
+	self.status = OFF;1
+	self.emit('off');
+        return;	
+      }
+     
+      if (self.status == ON || self.status == STARTING){
+	console.log("Process died a horrible death");
+	self.status = OFF;	
+        self.emit('crash');
+	return;
+      }
+
+    });
+    
+    this.on('crash', function(){
+      console.log("Restarting after crash");      
+      this.turnon();
+    });
+}
+
+GameServer.prototype.turnoff = function(){
+  self.status = STOPPING; 
+  this.kill()
+}
+
+GameServer.prototype.restart = function(){
+  self.once('off', function (stream) {self.turnon()});
+  this.turnoff();
+}
+
+GameServer.prototype.kill = function(){
+  this.ps.kill();
+}
+
+GameServer.prototype.send = function(data){
+  this.ps.write(data);
+}
+
+module.exports = GameServer;

Diff for: gsd.js

@@ -0,0 +1,23 @@
+var WsServer    = require('ws').Server;
+var config = require('./config');
+var gameserver = require('./gameprocess');
+
+gameconsole = new WsServer({port: 8080});
+
+gameconsole.broadcast = function(data) {
+    for(var i in this.clients)
+        this.clients[i].send(data);
+};
+
+var potato = new gameserver();
+potato.turnon();
+
+// Stream everything out to the console
+potato.on('data', function(data){
+    gameconsole.broadcast(data.toString());
+});
+
+
+setTimeout(function(){
+    potato.restart()
+}, 5 * 1000);

Diff for: plugins.js

@@ -0,0 +1,12 @@
+var fs = require('fs');
+
+var plugins = {};
+fs.readdirSync("./plugins").forEach(function(file){
+    path = "./plugins/" + file;
+    if (fs.lstatSync(path).isFile()){
+      console.log('Loading plugin ' + file);
+      plugins[file] = require(path);
+    }
+});
+
+exports.plugins = plugins;