gistfile1.txt

var sys = require('sys'),
    Path  = require('path'),
    Mu = require('../mu'),
    Script = process.binding('evals').Script;

exports.compile = compile;
exports.compilePartial = compilePartial;

function RenderEventEmitter(options) {
  this.chunkSize = options.chunkSize || 1024;
  this.buffer = '';
  this.paused = false;
  this.closed = false;
  this.emittedEOF = false;
}
sys.inherits(RenderEventEmitter, process.EventEmitter);

function compile(parsed) {
  var code =
    '(function COMPILED(context, options) {\n' +
    '  options = options || {};\n' +
    '  var Mu = M;\n' +
    '  var REE = new RenderEventEmitter(options);\n' +
    '  process.nextTick(function () {\n' +
         compilePartial(parsed) + '\n' +
    '    REE.close();\n' +
    '  });\n' +
    '  return REE;\n' +
    '})';
  
  var func = Script.runInNewContext(code, { 
	  RenderEventEmitter:RenderEventEmitter, M:Mu, process:process});
  
  func.LINES  = Mu.Preprocessor.rebuildLines(parsed);
  func.SOURCE = Mu.Preprocessor.rebuildSource(parsed);
  
  return func;
}

function compilePartial(parsed) {
  return parsed.map(function (line) {
    var lineNumber = line.number;
    var tokens = line.tokens;
    
    return tokens.map(function (token) {
      var value = token.value;
      
      switch (token.type) {
      
      case 'string':
        return 'REE.write("' + value + '");';
        
      case 'variable':
        return 'REE.write(Mu.escape(Mu.normalize(context, "' + value + '")));';
      
      case 'unescaped':
        return 'REE.write(Mu.normalize(context, "' + value + '"));';
      
      case 'start_enumerable':
        return 'Mu.enumerable(' +
          'context, context.' + value + ', function enum_' + value + '(context) {';
      
      case 'start_inverted_enumerable':
        return 'Mu.enumerable(' +
          'context, !context.' + value + ', function enum_' + value + '(context) {';
      
      case 'end_enumerable':
        return '});';
        
      case 'partial':
        return compilePartial(value);
      
      }
    }).join('');
  }).join('');
}

mixin(RenderEventEmitter.prototype, {
  write: function (chunk) {
    if (this.closed) {
      return;
    }
    
    this.buffer += chunk;
    this.emitChunks();
  },
  
  close: function () {
    this.closed = true;
    this.emitChunks();
  },
  
  pause: function () {
    this.paused = true;
  },
  
  resume: function () {
    this.paused = false;
    this.emitChunks();
  },
  
  emitChunks: function () {
    while (this.buffer.length >= this.chunkSize) {
      if (this.paused) {
        return;
      }
      
      var chunk = this.buffer.substring(0, this.chunkSize);
      this.buffer = this.buffer.substring(this.chunkSize);
      
      this.emit('data', chunk);
    }
    
    if (this.closed && !this.paused && this.buffer.length) {
      this.emit('data', this.buffer);
      this.buffer = '';
    }
    
    if (this.closed && !this.emittedEOF && !this.buffer.length) {
      this.emittedEOF = true;
      this.emit('end');
    }
  }
});

// Simple shallow object merge.
function mixin(obj1, obj2) {
  for (var key in obj2) {
    if (obj2.hasOwnProperty(key)) {
      obj1[key] = obj2[key];
    }
  }
}