Streaming API with Ruby

I must publicly confess my love with the Streaming API. (Don't tell my wife.) Last September I wrote a blog post entitled, Node.js Demo with Streaming API & that showed how to stream events from to the browser using Node.js. It was a pretty cool app if you are familiar with Node.js.

Then at Dreamforce '12 I did an Un-Conference session called, "Log Events in REALTIME with Papertrail" which was a knock-off but showed how to create an external logger for Salesforce using the Streaming API. Pretty slick stuff but again in Node.js.

Well I've found a much easier way to use the Streaming API than my previous attempts thanks to the Restforce ruby gem. According to the docs "... the Restforce gem makes implementing pub/sub with Salesforce a trivial task". A bold statement but entirely true.

So I put together a sample rails app that you can use as a starter with the Streaming API. Just fork this repo, watch the video below and then follow the simple, step-by-step instructions on the repo to get started. The demo app streaming events from a "Log__c" custom object to the rails app with in turn uses Papertrail as a logger.

Here's the file that does the heavy lifting for you. It connects to your org with the Restforce client, starts listening for events on the "LogEntries" channel and then once it receives it, outputs it to Papertrail through "puts".

require 'restforce'
require 'faye'

# Initialize a client with your username/password.
client = :username => ENV['SFDC_USERNAME'],
 :password  => ENV['SFDC_PASSWORD'],
 :security_token => ENV['SFDC_SECURITY_TOKEN'],
 :client_id => ENV['SFDC_CLIENT_ID'],
 :client_secret => ENV['SFDC_CLIENT_SECRET']

# simply for debugging
puts client.to_yaml


 puts 'Successfully authenticated to'

 EM.next_tick do
  client.subscribe 'LogEntries' do |message|
 puts "[#{message['sobject']['Level__c']}] #{message['sobject']['Class__c']} - #{message['sobject']['Short_Message__c']} (#{message['sobject']['Name']})"

 puts "Could not authenticate. Not listening for streaming events."