maccman / juggernaut.rb

Created June 26, 2012


    
    View juggernaut.rb 
  
  
      juggernaut.rb
    
    
        Raw
      
    
    File suppressed. Click to show.
  
  
            1
            2
            3
            4
            5
            6
            7
            8
            9
            10
            11
            12
            13
            14
            15
            16
            17
            18
            19
            20
            21
            22
            23
            24
            25
            26
            27
            28
            29
            30
            31
            32
            33
            34
            35
            36
            37
            38
            39
            40
            41
            42
            43
            44
            45
          
          
            # Usage: redis-cli publish message hello
 
require 'sinatra'
require 'redis'
 
conns = []
 
get '/' do
  erb :index
end
 
get '/subscribe' do
  content_type 'text/event-stream'
  stream(:keep_open) do |out|
    conns << out
    out.callback { conns.delete(out) }
  end
end
 
Thread.new do
  redis = Redis.connect
  redis.psubscribe('message', 'message.*') do |on|
    on.pmessage do |match, channel, message|
      channel = channel.sub('message.', '')
 
      conns.each do |out|
        out << "event: #{channel}\n\n"
        out << "data: #{message}\n\n"
      end
    end
  end
end
 
__END__
 
@@ index
  <article id="log"></article>
 
  <script>
    var source = new EventSource('/subscribe');
 
    source.addEventListener('message', function (event) {
      log.innerText += '\n' + event.data;
    }, false);
  </script>