feat(task): New background task process class and bin script

Author: pilsy

bin/task.js

@@ -1,45 +1 @@
-var utils     = require( 'utils' )
-  , env       = utils.bootstrapEnv()
-  , moduleLdr = env.moduleLoader
-  , tasks     = require( 'tasks' )
-  , chalk     = require( 'chalk' )
-  , debuggr   = require( 'debug' )( 'BackgroundTasks' )
-  , ready     = false
-  , task      = null;
-
-function debug() {
-    var args = [].slice.call( arguments );
-    args[ 0 ] = chalk.yellow( process.env.TASK_NAME + '-' + process.pid ) + ':  ' + args[ 0 ];
-    debuggr.apply( debuggr, args );
-}
-
-debug( 'Starting...' );
-
-process.on( 'message', function( message ) {
-    if ( !ready ) {
-        debug( 'Not ready...' );
-        process.send( { code: 'NOT_READY' } );
-    } else if ( task !== null ) {
-        debug( 'Still running...' );
-        process.send( { code: 'BUSY' } );
-    } else {
-        debug( 'Running task...' );
-
-        var payload = message.payload || {};
-        task = new ( tasks[ process.env.TASK_NAME ] )( payload, function( err, result ) {
-            process.nextTick(function() {
-                task = null;
-                process.send( { code: 'RESULT', error: err, result: result } );
-            });
-        });
-    }
-});
-
-moduleLdr.on( 'modulesLoaded', function() {
-    debug( 'Ready...' );
-    ready = true;
-    process.send( { code: 'READY' } );
-    
-});
-
-moduleLdr.loadModules();
+module.exports = new ( require( 'classes' ).BackgroundTask )( process.env.TASK_NAME );

classes/BackgroundTask.js

@@ -0,0 +1,70 @@
+var Class   = require( 'classes' ).Class
+  , chalk   = require( 'chalk' )
+  , tasks   = require( 'tasks' )
+  , debuggr = require( 'debug' )( 'BackgroundTasks' );
+
+module.exports = Class.extend(
+{
+    env: null,
+    taskClass: null
+},
+{
+    task: null,
+
+    name: null,
+
+    isReady: false,
+
+    setup: function( name ) {
+        this.name = name;
+        this.task = null;
+        this.isReady = false;
+        this.Class.env = require( 'utils' ).bootstrapEnv();
+        this.Class.taskClass = tasks[ this.name ];
+        process.on( 'message', this.proxy( 'runTask' ) );
+
+        return [ this.Class.env.moduleLoader ];
+    },
+
+    init: function( moduleLoader ) {
+        moduleLoader.on( 'modulesLoaded', this.proxy( 'ready' ) );
+        moduleLoader.loadModules();
+    },
+
+    debug: function() {
+        var args = [].slice.call( arguments );
+        args[ 0 ] = chalk.yellow( this.name + '-' + process.pid ) + ':  ' + args[ 0 ];
+        debuggr.apply( debuggr, args );
+    },
+
+    ready: function() {
+        this.debug( 'Ready...' );
+        this.processReady = true;
+        process.send( { code: 'READY' } );
+    },
+
+    runTask: function( message ) {
+        var payload = message.payload || {};
+
+        if ( !this.processReady ) {
+            this.debug( 'Process is not ready yet...' );
+            process.send( { code: 'NOT_READY' } );
+        } else if ( this.task !== null ) {
+            this.debug( 'Still running previous task...' );
+            process.send( { code: 'BUSY' } );
+        } else {
+            this.debug( 'Running task...' );
+            this.task = new this.Class.taskClass( payload, this.proxy( 'taskFinished' ) );
+        }
+    },
+
+    taskFinished: function( err, result ) {
+        this.debug( 'Finished processing' + ( err !== null && err !== undefined ? ' with error: ' + err : '' ) );
+        process.send( { code: 'RESULT', error: err, result: result } );
+        process.nextTick( this.proxy( 'clearTask' ) );
+    },
+
+    clearTask: function() {
+        this.task = null;
+    }
+});