index.js

'use strict';

var browserify = require('browserify');
var requireify = require('requireify');
var through = require('through');
var innersource = require('innersource');
var detective = require('detective');
var generator = require('inline-source-map');
var combine = require('combine-source-map');
var _ = require('lodash');
var findPackageJson = require('./lib/findPackageJson');
var outputDirWriter = require('./lib/outputDirWriter');
var scriptjsLocation = require.resolve('scriptjs');
var Q = require('q');
var events = require('events');

var postpend = innersource(addModule).replace(/\n/g, '');

var bundleEmitter = new events.EventEmitter();
var pack;

module.exports = function(filename) {
  if(!pack){
    pack = findPackageJson(filename);
    pack.then(function(data){
      if(!data.pack.promethify.outputDir){
        var server = require('./lib/server').start(bundleEmitter, pack);
      }
      else{
        outputDirWriter.start(bundleEmitter, data);
      }
    
    });
  }
  var buffer = '';

  return through(function(chunk) {
    buffer += chunk.toString();
  },
  function() {
    if(_.contains(filename, 'scriptjs')){
       this.queue(buffer);
       this.queue(null);
       return;
    }
    pack.then(function(data){
      var port = data.pack.promethify.port;
      var hostname = data.pack.promethify.hostname;
      var outputDeployPath = getPath(data.pack.promethify.outputDeployPath);
      var prepend = innersource(addRequire)
                    .replace('SCRIPTJS_LOC', scriptjsLocation)
                    .replace('HOSTNAME', hostname)
                    .replace('OUTPUT_DEPLOY_PATH', outputDeployPath)
                    .replace('PORT_NUM', port)
                    .replace(/\n/g, '');
      var asyncRequres = getAsyncRequires(buffer);
      var defs = asyncRequres.map(makeBrowserifyBundle);

      var totalPrelude = prepend;
      var offset = totalPrelude.split('\n').length - 1;
      
      var complete = totalPrelude + combine.removeComments(buffer) + postpend;
      
      var map = combine.create().addFile({ sourceFile: filename, source: buffer}, {line: offset});

      this.queue( complete + '\n'+map.comment());

      Q.all(defs).then(function(){
        this.queue(null);
      }.bind(this));
      
    }.bind(this)).done();
  });

};

function addModule(){
}


function addRequire(){
  /* jshint shadow: true */
  var tmpRequire = require;
  var scriptjs = require('SCRIPTJS_LOC');
  var require = function require(keys, callback){
    if(Array.isArray(keys)){

      var urls = keys.map(function(key){
        if( key[0] !== '/' ) { key = '/'+key;}
        return 'http://HOSTNAME:PORT_NUMOUTPUT_DEPLOY_PATH'+key;
      });

      var scriptParam = [urls, function(){
        var deps = keys.map(function(key){ return window.require(key); });
        callback.apply(null, deps);
      }];
      scriptjs.apply(null, scriptParam);
      return;
    }else{
      return tmpRequire.apply(null, arguments);
    }

  };
}

function getAsyncRequires(source){
  var amdRequires = detective.find(source, {nodes: true});
  var amdRequireArray = amdRequires.expressions.map(function(arrString){
    var exps = require('esprima').parse(arrString).body[0].expression;
    var array = require('static-eval')(exps);
    return array;
  });
  return _.flatten(amdRequireArray);
}

function makeBrowserifyBundle(asyncDep){
  var def = Q.defer();
  bundleEmitter.emit('bundle', asyncDep, def.promise);
  var b = browserify({debug: true});

  b.transform(requireify);

  pack.then(function(data){
    var basedir = data.pack.promethify.basedir;
    var dir = data.dir;

    if(asyncDep[0] === '/'){
      b
        .add(dir + '/' + basedir + asyncDep)
        .bundle({basedir: dir + '/' + basedir}, function(err, src){
          def.resolve(src);
        });
    }
    else {
      var resumer = require('resumer');
      var stream = resumer()
                .queue('module.exports = require("'+asyncDep+'");').end();
      b
        .require(stream)
        .bundle({basedir: dir + '/' + basedir}, function(err, src){
          def.resolve(src);
        });

    }
    
  }).done();
  return def.promise;
}

function getPath(deployPath){
  if(deployPath){
    return '/' + deployPath;
  }
  else {
    return '';
  }
}