Permalink
Cannot retrieve contributors at this time
Fetching contributors…
Cannot retrieve contributors at this time
| # Description: | |
| # RSS feed alerter | |
| # | |
| # Dependencies: | |
| # "nodepie": "0.5.0" | |
| # | |
| # Configuration: | |
| # HUBOT_ALERTS_RSS_FEED - URL of the feed | |
| # HUBOT_ALERTS_RSS_ANNOUNCE_ROOM - where should Hubot announce new feed items | |
| # HUBOT_ALERTS_RSS_INTERVAL - how often (in seconds) to check the RSS feed - default: 300 (5 minutes) | |
| # HUBOT_ALERTS_RSS_PREPEND - text to prepend to alert messages - default: "RSS Alert" | |
| # HUBOT_ALERTS_RSS_BROKEN_TZ_ADJUSTMENT - if a feed's timezone is broken set this to adjust it - default: 0 | |
| # HUBOT_ALERTS_RSS_SKIP_FIRST - skip any items when first checking the feed - default: true (set to false for debugging) | |
| # | |
| # Commands: | |
| # none | |
| # | |
| # Author: | |
| # larcher | |
| NodePie = require("nodepie") | |
| # grab settings from environment variables, with defaults | |
| feed_url = process.env.HUBOT_ALERTS_RSS_FEED | |
| announce_room = process.env.HUBOT_ALERTS_RSS_ANNOUNCE_ROOM | |
| rss_interval = process.env.HUBOT_ALERTS_RSS_INTERVAL || 300 | |
| message_prepend = process.env.HUBOT_ALERTS_RSS_PREPEND || "RSS Alert" | |
| broken_tz_adjust = process.env.HUBOT_ALERTS_RSS_BROKEN_TZ_ADJUSTMENT || 0 | |
| skip_first_string = process.env.HUBOT_ALERTS_RSS_SKIP_FIRST || "true" | |
| skip_first = (skip_first_string == "true") | |
| if skip_first | |
| # effectively "mark all as read" when we start up | |
| last_check_time = (new Date()).getTime() | |
| else | |
| last_check_time = 0 | |
| module.exports = (robot) -> | |
| parse_feed = (err,res,body) -> | |
| if res.statusCode is not 200 | |
| consle.log("Error retrieving feed - status: " + res.statusCode) | |
| else | |
| feed = new NodePie(body) | |
| try | |
| feed.init() | |
| return feed | |
| catch e | |
| console.log("problem parsing feed", e) | |
| return false | |
| check_feed = (robot) -> | |
| console.log "checking alerts feed .. " + (new Date()) | |
| robot.http(feed_url).get() (err,res,body) -> | |
| now = (new Date()) | |
| feed = parse_feed(err,res,body) | |
| if feed | |
| latest = feed.getItems(0,1)[0] | |
| if latest | |
| latest_date = latest.getUpdateDate() | |
| latest_date.setTime( latest_date.getTime() + (60*60*1000*broken_tz_adjust)) | |
| if (latest_date - last_check_time ) >= 0 | |
| console.log " found update: " + latest.getTitle() | |
| result = robot.messageRoom announce_room, message_prepend + ": " + latest.getTitle() + " -- " + latest.getPermalink() | |
| if !result | |
| console.log "robot.messageRoom failed: ", result | |
| last_check_time = now | |
| setInterval( check_feed, rss_interval*1000, robot) | |