Gecko [ fernandoquevedodop.com ]

Name	Size	Permission
hybi	[ DIR ]	drwxr-xr-x
client.rb	3.91 KB	-rw-r--r--
draft75.rb	2.39 KB	-rw-r--r--
draft76.rb	2.35 KB	-rw-r--r--
event_emitter.rb	1.14 KB	-rw-r--r--
headers.rb	860 B	-rw-r--r--
hybi.rb	11.94 KB	-rw-r--r--
proxy.rb	1.7 KB	-rw-r--r--
server.rb	1.81 KB	-rw-r--r--
stream_reader.rb	1.09 KB	-rw-r--r--
utf8_match.rb	345 B	-rw-r--r--

Code Editor : server.rb

module WebSocket
  class Driver

class Server < Driver
      EVENTS = %w[open message error close]

def initialize(socket, options = {})
        super
        @http = HTTP::Request.new
        @delegate = nil
      end

def env
        @http.complete? ? @http.env : nil
      end

def url
        return nil unless e = env

url  = "ws://#{e['HTTP_HOST']}"
        url << e['PATH_INFO']
        url << "?#{e['QUERY_STRING']}" unless e['QUERY_STRING'] == ''
        url
      end

%w[add_extension set_header start frame text binary ping close].each do |method|
        define_method(method) do |*args, &block|
          if @delegate
            @delegate.__send__(method, *args, &block)
          else
            @queue << [method, args, block]
            true
          end
        end
      end

%w[protocol version].each do |method|
        define_method(method) do
          @delegate && @delegate.__send__(method)
        end
      end

def parse(chunk)
        return @delegate.parse(chunk) if @delegate

@http.parse(chunk)
        return fail_request('Invalid HTTP request') if @http.error?
        return unless @http.complete?

@delegate = Driver.rack(self, @options)
        open

EVENTS.each do |event|
          @delegate.on(event) { |e| emit(event, e) }
        end

emit(:connect, ConnectEvent.new)
      end

def write(buffer)
        @socket.write(Driver.encode(buffer, :binary))
      end

private

def fail_request(message)
        emit(:error, ProtocolError.new(message))
        emit(:close, CloseEvent.new(Hybi::ERRORS[:protocol_error], message))
      end

def open
        @queue.each do |method, args, block|
          @delegate.__send__(method, *args, &block)
        end
        @queue = []
      end
    end

end
end

${this.title}

Code Editor : server.rb