Contents

module Angelo
  class Responder
    class Eventsource < Responder

      def initialize _headers = nil, &block
        headers _headers if _headers
        super &block
      end

      def request= request
        @params = nil
        @request = request
      end

      def handle_request
        begin
          if @response_handler
            @base.filter :before
            @body = catch(:halt) { @base.eventsource &@response_handler.bind(@base) }
            if HALT_STRUCT === @body
              raise RequestError.new 'unknown sse error' unless @body.body == :sse
            end

            # TODO any real reason not to run afters with SSE?
            # @base.filter :after

            respond
          else
            raise NotImplementedError
          end
        rescue IOError => ioe
          warn "#{ioe.class} - #{ioe.message}"
        rescue RequestError => re
          headers SSE_HEADER
          handle_error re, re.type
        rescue => e
          handle_error e
        end
      end

      def respond
        Angelo.log @connection, @request, nil, :ok
        @request.respond 200, headers, nil
      end

    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

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