Contents

module Angelo
  class Responder
    class Websocket < Responder

      class << self

        attr_writer :on_pong

        def on_pong
          @on_pong ||= ->(e){}
        end

      end

      def request= request
        @params = nil
        @request = request
        @websocket = @request.websocket
      end

      def handle_request
        begin
          if @response_handler
            Angelo.log @connection, @request, @websocket, :switching_protocols
            @bound_response_handler ||= @response_handler.bind @base
            @websocket.on_pong &Responder::Websocket.on_pong
            @base.filter :before
            @bound_response_handler[@websocket]
            @base.filter :after
          else
            raise NotImplementedError
          end
        rescue IOError => ioe
          warn "#{ioe.class} - #{ioe.message}"
          close_websocket
        rescue => e
          error e.message
          ::STDERR.puts e.backtrace
          begin
            @connection.close
          rescue Reel::StateError => rcse
            close_websocket
          end
        end
      end

      def close_websocket
        @websocket.close
        @base.websockets.remove_socket @websocket
      end

    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
angelo-0.3.3	lib/angelo/responder/websocket.rb
angelo-0.3.2	lib/angelo/responder/websocket.rb
angelo-0.3.1	lib/angelo/responder/websocket.rb
angelo-0.3.0	lib/angelo/responder/websocket.rb
angelo-0.2.4	lib/angelo/responder/websocket.rb