@hitc/netsuite-tools/gulp-old-compile.js

var through = require('through2');
var gutil = require('gulp-util');
var PluginError = gutil.PluginError;
var cp = require('child_process');
var path = require('path');

var PLUGIN_NAME = 'gulp-old-compile';

// plugin level function (dealing with files)
function gulpOldCompile() {
  var s = through.obj(function(file, enc, cb) {
    if (file.isStream()) {
      this.emit('error', new PluginError(PLUGIN_NAME, 'Streams are not supported!'));
      return cb();
    }

    if (file.isBuffer()) {
      var oldCompilePath = path.resolve(__dirname, "compile.py");

      var args = [oldCompilePath, file.path];
      var cpObj = cp.spawn("python", args);

      var stdoutData = [];
      cpObj.stdout.on('data', function(chunk) { stdoutData.push(chunk); });

      var stderrData = [];
      cpObj.stderr.on('data', function(chunk) { stderrData.push(chunk); });

      cpObj.on('error', function(err) {
        s.emit('error', new PluginError(PLUGIN_NAME, "Error while compiling " + file.path + ":\n" + err));
        cb();
      });

      cpObj.on('close', function(code) {
        var stdout = Buffer.concat(stdoutData);
        var lines = stdout.toString().split('\n');
        for(var i=0; i<lines.length; i++) {
          if(lines[i].match(/^\[Errno/)) {
            s.emit('error', new PluginError(PLUGIN_NAME, "Error while compiling " + file.path + ":\n" + stdout.toString()));
          }
        }

        if(stderrData.length > 0) {
          var stderr = Buffer.concat(stderrData);
          s.emit('error', new PluginError(PLUGIN_NAME, "Error while compiling " + file.path + ":\n" + stderr.toString() + "\n\n" + stdout.toString()));
          cb();
        }

        if(!gutil.isBuffer(stdout)) stdout = new Buffer(String(stdout));
        file.contents = stdout;
        s.push(file);
        cb();
      });
    }
  });

  // returning the file stream
  return s;
};

// exporting the plugin main function
module.exports = gulpOldCompile;