handydandystringparser.js

exports.parseString = parseFeedString;

var myProductName = "daveReadFeed"; myVersion = "0.4.0";

const request = require ("request");
const feedParser = require ("feedparser");
const utils = require ("daveutils");
const stream = require ("stream");
const Iconv = require ("iconv").Iconv;

const metaNames = {
	title: true,
	link: true,
	description: true,
	pubDate: true,
	language: true,
	copyright: true,
	generator: true,
	cloud: true,
	image: true,
	categories: true
	};

function parseFeedString (theString, charset, callback) {
	var feedparser = new feedParser ();
	var theFeed = {
		head: new Object (),
		items: new Array ()
		};
	
	var theStream = new stream.Readable;
	theStream.push (theString);
	theStream.push (null);
	
	feedparser.on ("readable", function () {
		try {
			var item = this.read ();
			if (item !== null) {
				theFeed.items.push (item);
				for (var x in item.meta) {
					if (metaNames [x] !== undefined) {
						theFeed.head [x] = item.meta [x];
						}
					}
				}
			}
		catch (err) {
			console.log ("parseFeedString: err.message == " + err.message);
			}
		});
	feedparser.on ("error", function (err) {
		console.log ("parseFeedString: err.message == " + err.message);
		callback (err);
		});
	feedparser.on ("end", function () {
		callback (undefined, theFeed);
		});
	
	if (charset !== undefined) {
		var iconv = new Iconv (charset, "UTF-8");
		theStream = theStream.pipe (iconv);
		}
	theStream.pipe (feedparser);
	}