parse-xml.js

var stream = require('stream');
var XMLStream = require('node-xml-stream-parser');

var XSE = XMLStream.EVENTS;
var OPEN_TAG = XSE.OPEN_TAG;
var CLOSE_TAG = XSE.CLOSE_TAG;
var TEXT = XSE.TEXT;
var CDATA = XSE.CDATA;
var INSTRUCTION = XSE.INSTRUCTION;
var ERROR = XSE.ERROR;
var UNPARSED_REMAIN = XSE.UNPARSED_REMAIN;

function ParseXML(options) {
	options || (options = {});
	options.readableObjectMode = true;
	options.objectMode = true;
	stream.Duplex.call(this, options);
	var self = this;
	var parser = this._parser = new XMLStream();
	parser.on(OPEN_TAG, function(name, attrs) {
		self.push({ type: OPEN_TAG, name: name, attrs: attrs });
	});
	parser.on(CLOSE_TAG, function(name) {
		self.push({ type: CLOSE_TAG, name: name });
	});
	parser.on(TEXT, function(text) {
		self.push({ type: TEXT, text: text });
	});
	parser.on(CDATA, function(cdata) {
		self.push({ type: CDATA, cdata: cdata });
	});
	parser.on(INSTRUCTION, function(name, attrs) {
		self.push({ type: INSTRUCTION, name: name, attrs: attrs });
	});
	parser.on(ERROR, function(error) {
		self.push({ type: ERROR, error: error });
	});
	parser.on(UNPARSED_REMAIN, function(remain) {
		self.push({ type: UNPARSED_REMAIN, buffer: remain.buffer, pos: remain.pos });
	});
	parser.on('finish', function() {
		self.push(null);
	});
}

ParseXML.OPEN_TAG = OPEN_TAG;
ParseXML.CLOSE_TAG = CLOSE_TAG;
ParseXML.TEXT = TEXT;
ParseXML.CDATA = CDATA;
ParseXML.INSTRUCTION = INSTRUCTION;
ParseXML.ERROR = ERROR;
ParseXML.UNPARSED_REMAIN = UNPARSED_REMAIN;

ParseXML.prototype = Object.create(stream.Duplex.prototype);
ParseXML.prototype.constructor = ParseXML;
ParseXML.prototype._read = function() {};
ParseXML.prototype._write = function(chunk, encoding, callback) {
	try {
		this._parser.write(chunk);
	} catch(e) {
		return callback(e);
	}
	return callback();
};
ParseXML.prototype._final = function(callback) {
	this._parser.end();
	callback && callback();
};

module.exports = ParseXML;