Added a manager script to run all three scripts and keep them alive.

Author: scottgonzalez

scripts/manager.js

@@ -0,0 +1,36 @@
+var path = require( "path" ),
+	spawn = require( "child_process" ).spawn;
+
+function Process( script ) {
+	this.args = [].slice.call( arguments );
+	this.args[ 0 ] = path.join( __dirname, script );
+	this.start();
+	Process.list.push( this );
+}
+
+Process.list = [];
+
+Process.prototype.respawn = true;
+
+Process.prototype.start = function() {
+	this.child = spawn( "node", this.args );
+	this.child.on( "exit", this.onExit.bind( this ) );
+};
+
+Process.prototype.onExit = function( code ) {
+	if ( code !== 0 && this.respawn ) {
+		this.start();
+	}
+};
+
+new Process( "update-server.js", "--console" );
+new Process( "wordpress-update.js", "--console" );
+new Process( "retry.js", "--console" );
+
+// Let SIGINT pass through to spawned processes. When all children exit,
+// the manager will end on its own.
+process.on( "SIGINT", function() {
+	Process.list.forEach(function( process ) {
+		process.respawn = false;
+	});
+});

scripts/retry.js

@@ -36,7 +36,7 @@ actions.processMeta = function( repoId, fn ) {
 	hook.processMeta( repo, fn );
 };
 
-function processFailures( fn ) {
+var processFailures = function( fn ) {
 	Step(
 		function() {
 			retry.getFailure( this );
@@ -74,14 +74,21 @@ function processFailures( fn ) {
 
 		function( error ) {
 			if ( error ) {
-				console.log( error.stack );
+				return fn( error );
 			}
 
 			processFailures( fn );
 		}
 	);
-}
+};
 
 processFailures(function( error ) {
 	logger.error( "Error during retry: " + error.stack );
 });
+
+// Let the current retry finish, then stop processing and exit
+process.on( "SIGINT", function() {
+	processFailures = function( fn ) {
+		fn( null );
+	};
+});

scripts/wordpress-update.js

@@ -199,7 +199,7 @@ function processActions( fn ) {
 	);
 }
 
-function processActionsSince( actionId, fn ) {
+var processActionsSince = function( actionId, fn ) {
 	Step(
 		function() {
 			processNextAction( actionId, this );
@@ -230,7 +230,7 @@ function processActionsSince( actionId, fn ) {
 			processActionsSince( action.id, fn );
 		}
 	);
-}
+};
 
 function processNextAction( actionId, fn ) {
 	Step(
@@ -268,3 +268,10 @@ function processNextAction( actionId, fn ) {
 processActions(function( error ) {
 	logger.error( "Error updating WordPress: " + error.stack );
 });
+
+// Let the current action finish, then stop processing and exit
+process.on( "SIGINT", function() {
+	processActionsSince = function( actionId, fn ) {
+		fn( null );
+	};
+});