require 'rubygems'
require 'bundler/setup'
require 'reel'
Connections = []
Body = DATA.read
app = Rack::Builder.new do
map '/' do
run lambda { |env|
[200, {'Content-Type' => 'text/html'}, [Body]]
}
end
map '/subscribe' do
run lambda { |env|
body = Reel::EventStream.new do |socket|
Connections << socket
socket.on_error { Connections.delete socket }
end
[200, {'Content-Type' => 'text/event-stream'}, body]
}
end
map '/wall' do
run lambda { |env|
msg = env['PATH_INFO'].gsub(/\/+/, '').strip
msg = Time.now if msg.empty?
Connections.each { |s| s.data msg }
[200, {'Content-Type' => 'text/html'}, ["Sent \"#{msg}\" to #{Connections.size} clients"]]
}
end
end.to_app
Rack::Handler::Reel.run app, Port: 9292
__END__
Waiting for messages...