lib/firehose/cli.rb in firehose-0.0.15 vs lib/firehose/cli.rb in firehose-0.0.16

@@ -4,12 +4,26 @@
 module Firehose
   class CLI < Thor
     desc "server", "starts the firehose server"
     method_option :port, :type => :numeric, :default => Firehose::Default::URI.port, :required => true, :aliases => '-p'
     method_option :host, :type => :string, :default => '0.0.0.0', :required => true, :aliases => '-h'
+
     def server
+      broker = Firehose::Broker.new
+
       server = Thin::Server.new(options[:host], options[:port]) do
-        run Firehose::Rack::App.new
+        # TODO move this into a socket... this is really janky, but I need to to troubleshoot
+        # connection reference issues. I'd like to have this ancillary stuff accessiable via
+        # a different port or even a socket.
+        map '/_firehose/stats' do
+          run Proc.new {
+            [200, {'Content-Type' => 'text/plain'}, [broker.stats.inspect]]
+          }
+        end
+
+        map '/' do
+          run Firehose::Rack::App.new(broker)
+        end
       end
 
       begin
         server.start!
       rescue AMQP::TCPConnectionFailed => e
\ No newline at end of file