ready to support a cloudd cli

lib/cloudd.js

@@ -16,9 +16,6 @@ winston.default.transports.console.colorize = true;
 winston.default.transports.console.timestamp = true;
 
 // -------- todo -------------
-// for now no graph is built, later we'll check for DAG
-// preconditions to trigger next job etc.,
-// http://www.graphdracula.net/, node-graph
 
 // cloudd-format - create new package for formatting job names
 //   -- use date format, use host name, etc.,

lib/dag.js

@@ -30,6 +30,13 @@ DAG.prototype.nextTask = function() {
   return t;
 };
 
+/*
+ * progress % in numbers - this is approx value
+ */
+DAG.prototype.progress = function() {
+  return this.index<0?0:this.index>this.tasks.length?100:this.index / this.tasks.length;
+};
+
 /*
  * Set the index to next
  */

lib/job.js

@@ -96,6 +96,16 @@ Job.prototype.fetch = function() {
   return t;
 };
 
+/*
+ * toString - return key attributes for display purposes
+ */
+Job.prototype.toStringObj = function() {
+  return {
+    id:this.id, name:this.name, description:this.description, 
+    next:this.dag.nextTask(),
+    progress:this.dag.progress()
+  };
+};
 
 // ----------------
 var JobList = function() {
@@ -154,6 +164,12 @@ JobList.prototype.process = function() {
   }
 };
 
+/*
+ * return jobs - displayable parts
+ */
+JobList.prototype.toStringObj = function() {
+  return _.map(this.jobs, function(job) { return job.toStringObj(); });
+};
 
 // module exports
 exports.Job = Job;

lib/task.js

@@ -80,6 +80,11 @@ TaskQ.prototype.add = function(task) {
   this.q.enqueue(task);
 };
 
+// return q as array
+TaskQ.prototype.qAsArray = function () {
+  return this.q.list.toArray();
+};
+
 // process the next available Task
 //  - return the task in done callback
 //

package.json

@@ -9,7 +9,8 @@
     "winston"   : ">= 0.6.2",
     "sprintf"   : ">= 0.1.1",
     "to"        : ">= 0.2.9",
-    "cron"      : ">= 1.0.1"
+    "cron"      : ">= 1.0.1",
+    "zmq"       : ">= 2.2.0"
   },
   "devDependencies": {
     "mocha"     : ">= 1.7.4",