Contents

require 'faye/websocket'

module Firehose
  class Server
    def initialize(opts={})
      @port   = opts[:port]   || Firehose::Default::URI.port
      @host   = opts[:host]   || Firehose::Default::URI.host
      @server = opts[:server] || :rainbows

      Firehose.logger.info "Starting #{Firehose::VERSION} '#{Firehose::CODENAME}', in #{ENV['RACK_ENV']}"
    end

    def start
      self.send("start_#{@server}")
    end

  private
    def start_rainbows
      require 'rainbows'
      Faye::WebSocket.load_adapter('rainbows')

      rackup = Unicorn::Configurator::RACKUP
      rackup[:port] = @port if @port
      rackup[:host] = @host if @host
      rackup[:set_listener] = true
      opts = rackup[:options]
      opts[:config_file] = File.expand_path('../../../config/rainbows.rb', __FILE__)

      server = Rainbows::HttpServer.new(Firehose::Rack::App.new, opts)
      server.start.join
    end

    def start_thin
      require 'thin'
      require 'thin_em_swf_policy' if ENV['RACK_ENV'] == 'development'

      Faye::WebSocket.load_adapter('thin')

      # TODO: See if we can just set Thin to use Firehose.logger instead of
      #       printing out messages by itself.
      Thin::Logging.silent = true if Firehose.logger.level == Logger::ERROR

      server = Thin::Server.new(@host, @port) do
        run Firehose::Rack::App.new
      end.start
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
firehose-1.1.1	lib/firehose/server.rb
firehose-1.1.0	lib/firehose/server.rb
firehose-1.0.0	lib/firehose/server.rb
firehose-0.2.alpha.10	lib/firehose/server.rb
firehose-0.2.alpha.9	lib/firehose/server.rb
firehose-0.2.alpha.8	lib/firehose/server.rb
firehose-0.2.alpha.7	lib/firehose/server.rb
firehose-0.2.alpha.6	lib/firehose/server.rb
firehose-0.2.alpha.5	lib/firehose/server.rb
firehose-0.2.alpha.3	lib/firehose/server.rb
firehose-0.2.alpha.2	lib/firehose/server.rb