Add RocketChat as input handler

Author: AmShaegar13

.gitignore

@@ -1,4 +1,5 @@
 *.gem
+Gemfile.lock
 *.rbc
 /.config
 /coverage/

Gemfile

@@ -0,0 +1,3 @@
+source 'https://rubygems.org'
+
+gemspec

lib/xify.rb

@@ -2,6 +2,7 @@
 
 require 'xify/input/pipe'
 require 'xify/input/prompt'
+require 'xify/input/rocket_chat'
 require 'xify/input/shell'
 require 'xify/output/stdout'
 require 'xify/output/rocket_chat'

lib/xify/input/rocket_chat.rb

@@ -0,0 +1,39 @@
+require 'eventmachine'
+require 'json'
+require 'metybur'
+require 'net/https'
+require 'time'
+
+require 'xify/base/rocket_chat'
+
+module Input
+  class RocketChat < Base::RocketChat
+    def updates
+      login
+
+      EM.run do
+        config = @config
+        uri = URI.parse config['uri']
+        meteor = Metybur.connect "wss://#{uri.host}:#{uri.port}/websocket"
+        meteor.login resume: @auth_data['authToken'] do
+          meteor.subscribe 'stream-notify-user', "#{result[:id]}/rooms-changed", false
+          messages = meteor.collection 'stream-notify-user'
+          messages.on(:changed) do |id, attributes|
+             event = attributes[:args].last
+             room = event[:name]
+             message = event[:lastMessage]
+
+             next if message[:editedAt] || room != config['channel'][1..-1]
+
+             author = message[:u][:name]
+             text = message[:msg]
+             time = message[:ts][:'$date']
+             type = event[:t] == 'p' ? 'group' : 'channel'
+
+             yield Event.new author, text, parent: "##{room}", parent_link: "#{config['uri']}/#{type}/#{room}", time: Time.at(time / 1000)
+          end
+        end
+      end
+    end
+  end
+end

xify.gemspec

@@ -1,11 +1,13 @@
 Gem::Specification.new do |s|
   s.name        = 'xify'
-  s.version     = '0.1.0'
+  s.version     = '0.2.0'
   s.date        = '2018-05-11'
   s.summary     = 'Cross-post content from one service to another.'
   s.description = 'Cross-post content from one service to another.'
   s.author      = 'Finn Glöe'
   s.email       = '[email protected]'
   s.files       = Dir['lib/**/*.rb']
   s.executables << 'xify'
+
+  s.add_runtime_dependency 'metybur'
 end