Add rss input handler

Author: AmShaegar13

example.config.yml

@@ -12,6 +12,12 @@ inputs:
     trigger:
       schedule: '*/5 9-16 * * *'
       now: true
+  - class: Rss
+    enabled: false
+    uri: https://www.archlinux.org/feeds/news/
+    trigger:
+      schedule: '*/10 * * * *'
+      now: false
   - class: RocketChat
     enabled: false
     channel: '#xify-in'

lib/xify/input/rss.rb

@@ -0,0 +1,51 @@
+require 'rss'
+require 'open-uri'
+
+module Input
+  class Rss
+    def initialize(config)
+      @config = config
+
+      @uri = URI.parse config['uri']
+
+      working_dir = "#{ENV['HOME']}/.xify/Rss"
+      Dir.mkdir working_dir rescue Errno::EEXIST
+      @latest_file = "#{working_dir}/#{@uri.to_s.gsub(/\W+/, '_')}"
+    end
+
+    def updates
+      opts = {}
+      opts[:first] = :now if @config['trigger']['now']
+      Rufus::Scheduler.singleton.repeat @config['trigger']['schedule'], opts do
+        open(@uri) do |rss|
+          latest = Time.parse File.read(@latest_file) rescue Time.now - 24*60*60
+          feed = RSS::Parser.parse(rss)
+          feed.items
+            .select do |item| 
+              item.pubDate > latest
+            end
+            .sort_by do |item|
+              item.pubDate
+            end
+            .each do |item|
+              yield Xify::Event.new(
+                item.dc_creator,
+                "*#{item.title}*\n\n#{item.description}",
+                link: item.link,
+                parent: feed.channel.title,
+                parent_link: feed.channel.link,
+                time: item.pubDate
+              )
+              update_latest item
+            end
+        end
+      end
+    end
+
+    private
+
+    def update_latest(latest)
+      File.write @latest_file, latest.pubDate.to_s
+    end
+  end
+end

xify.gemspec

@@ -2,7 +2,7 @@ require 'date'
 
 Gem::Specification.new do |s|
   s.name        = 'xify'
-  s.version     = '0.4.2'
+  s.version     = '0.5.0'
   s.date        = Date.today.to_s
   s.summary     = 'Cross-post content from one service to another.'
   s.description = 'Cross-post content from one service to another.'