Discourse Forum User Post Alert

gistfile1.js

/**
 * This monitors a Discourse forum for postings by a particular user.
 * I stopped just shy of figuring out how to publish an event to a
 * Particle device PubSub stream.
 **/

var https	   = require('https'),
    cp             = require('child_process'),
    xmlParseString = require('xml2js').parseString;


getLatest();


function getLatest() {
	https.get('https://community.particle.io/latest.rss', function(res) {
		var body = '';
		
		res.on('data', function(d) {
			body += d.toString();
		});
		
		res.on('end', function() {
			xmlParseString(body, function(err, result) {
				var items = result.rss.channel[0].item;
				for(var i in items) {
					getTopic(items[i].source[0].$.url);
				}
			});
		});
	}).on('error', function(e) {
		console.log('ERROR: ', e);
		
		setTimeout(getLatest, 60000);
	});
}


function getTopic(url) {
	url = url.replace('spark.io', 'particle.io');
	https.get(url, function(res) {
		var body = '';
		
		res.on('data', function(d) {
			body += d.toString();
		});
		
		res.on('end', function() {
			xmlParseString(body, function(err, result) {
				var items = result.rss.channel[0].item;
				for(var i in items) {
					var author = /\(\@(\w)+/.exec(items[i].author)[0].substr(1);
					
					if(author.toUpperCase()=='@JACK') {
						console.log(items[i].pubDate);
						cp.execFileSync('particle', ['publish', 'jackattack', '"'+items[i].pubDate+'"']);
					}
				}
			});
			
			setTimeout(getLatest, 60000);
		});
	}).on('error', function(e) {
		console.log('ERROR: ', e);
		
		setTimeout(getLatest, 60000);
	});
}