Twitter の UserStreams を Fastladder に送りこむ

twitter_to_fastladder.rb

require 'user-stream-receiver'                                                                                                                                                     
require 'json'                                                                                                                                                                     
require 'rest_client'                                                                                                                                                              

HOST = ''
API_KEY = ''

UserStreamReceiver.new.run{|chunk|                                                                                                                                                 
  begin                                                                                                                                                                            
    chunk = JSON.parse(chunk)                                                                                                                                                      
    next unless chunk['text']                                                                                                                                                      
    hash = {                                                                                                                                                                       
      feedlink: "https://twitter.com/#{chunk['user']['screen_name']}",                                                                                                             
      feedtitle: "Twitter #{chunk['user']['screen_name']}",                                                                                                                        
      link: "https://twitter.com/#{chunk['user']['screen_name']}/status/#{chunk['id']}",                                                                                           
      title: "Twitter #{chunk['user']['screen_name']}",                                                                                                                            
      body: chunk['text'],                                                                                                                                                         
      author: chunk['user']['screen_name'],                                                                                                                                        
      category: 'Twitter',                                                                                                                                                         
      published_date: chunk['created_at']                                                                                                                                          
    }                                                                                                                                                                         
    RestClient.post "http://#{HOST}/rpc/update_feed", json: hash.to_json, api_key: API_KEY                                                       
  rescue                                                                                                                                                                           
    p 'error'                                                                                                                                                                      
  end                                                                                                                                                                              
}