Plato - lib/worker.js

var fs = require('fs'),
  functions = require('./functions'),
  jazz = require('jazz');

/**
 * class Worker
 *
 * @param {Number} workerId: an ID unique to this worker
 */
function Worker(workerId) {
  this.workerId = workerId;
}

/**
 * Write a data file consisting of header, segment x numSegments, and footer templates.
 * File is being streamed so it can handle large content.
 * Thanks to Max Ogden's fs stream backpressure example https://gist.github.com/2516455
 *
 * @param {Object} templates: data file templates in the format of { header: '', segment: '', footer: '' }
 * @param {Number} genId: an ID unique to the current data generation, used by all worker processes
 * @param {Number} numSegments: how many segments in a data file
 * @param {String} outFile: the data file name, to be postfixed with worker ID
 * @param {Function} cb: standard cb(err, result) callback
 */
Worker.prototype.write = function (templates, genId, numSegments, outFile, cb) {

var stream = fs.createWriteStream(outFile + this.workerId, { flags: 'w', encoding: 'utf-8' }),
    segmentId = 0,
    segmentTemplate = jazz.compile(templates.segment),
    params = functions,
    status;

params.gen_id = genId;
  params.worker_id = this.workerId;

stream.on('error', function (err) {
    console.error('Error: %s', err.message);
  });
  stream.on('close', cb);
  stream.on('open', write);
  stream.on('drain', write);
};

module.exports = Worker;

lib/worker.js

Maintainability

Lines of code

Difficulty

Estimated Errors

Function weight

By Complexity

By SLOC