var promises = require("../promises"); var sax = require("sax"); var _ = require("underscore"); var nodes = require("./nodes"); var Element = nodes.Element; exports.readString = readString; function readString(xmlString, namespaceMap) { namespaceMap = namespaceMap || {}; var finished = false; var parser = sax.parser(true, {xmlns: true, position: false}); var rootElement = {children: []}; var currentElement = rootElement; var stack = []; var deferred = promises.defer(); parser.onopentag = function(node) { var attributes = mapObject(node.attributes, function(attribute) { return attribute.value; }, mapName); var element = new Element(mapName(node), attributes); currentElement.children.push(element); stack.push(currentElement); currentElement = element; }; function mapName(node) { if (node.uri) { var mappedPrefix = namespaceMap[node.uri]; var prefix; if (mappedPrefix) { prefix = mappedPrefix + ":"; } else { prefix = "{" + node.uri + "}"; } return prefix + node.local; } else { return node.local; } } parser.onclosetag = function(node) { currentElement = stack.pop(); }; parser.ontext = function(text) { if (currentElement !== rootElement) { currentElement.children.push(nodes.text(text)); } }; parser.onend = function() { if (!finished) { finished = true; deferred.resolve(rootElement.children[0]); } }; parser.onerror = function(error) { if (!finished) { finished = true; deferred.reject(error); } }; parser.write(xmlString).close(); return deferred.promise; } function mapObject(input, valueFunc, keyFunc) { return _.reduce(input, function(result, value, key) { var mappedKey = keyFunc(value, key, input); result[mappedKey] = valueFunc(value, key, input); return result; }, {}); }