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|
if socket = env['rack.websocket']
socket.on_message do |m|
socket << "Server got \"#{m}\" message"
end
socket.on_error { Connections.delete socket }
Connections << socket
socket.read_every 1
end
[200, {}, []]
}
end
map '/wall' do
run lambda { |env|
msg = env['PATH_INFO'].gsub(/\/+/, '').strip
msg = Time.now if msg.empty?
Connections.each { |s| s << msg }
[200, {'Content-Type' => 'text/html'}, ["Sent \"#{msg}\" to #{Connections.size} clients"]]
}
end
end.to_app
Rack::Handler::Reel.run app, Port: 9292
__END__