Gecko [ touzafair.com ]

Name	Size	Permission
auth	[ DIR ]	drwxr-xr-x
multipart	[ DIR ]	drwxr-xr-x
body_proxy.rb	1.3 KB	-rw-r--r--
builder.rb	8.56 KB	-rw-r--r--
cascade.rb	2.25 KB	-rw-r--r--
chunked.rb	3.3 KB	-rw-r--r--
common_logger.rb	3.12 KB	-rw-r--r--
conditional_get.rb	2.99 KB	-rw-r--r--
config.rb	410 B	-rw-r--r--
constants.rb	2.47 KB	-rw-r--r--
content_length.rb	806 B	-rw-r--r--
content_type.rb	695 B	-rw-r--r--
deflater.rb	5.51 KB	-rw-r--r--
directory.rb	6.02 KB	-rw-r--r--
etag.rb	1.87 KB	-rw-r--r--
events.rb	4.8 KB	-rw-r--r--
file.rb	167 B	-rw-r--r--
files.rb	5.66 KB	-rw-r--r--
head.rb	524 B	-rw-r--r--
headers.rb	2.96 KB	-rw-r--r--
lint.rb	36.09 KB	-rwxr-xr-x
lock.rb	573 B	-rw-r--r--
logger.rb	414 B	-rw-r--r--
media_type.rb	1.4 KB	-rw-r--r--
method_override.rb	1.45 KB	-rw-r--r--
mime.rb	32.69 KB	-rw-r--r--
mock.rb	63 B	-rw-r--r--
mock_request.rb	5.37 KB	-rw-r--r--
mock_response.rb	3.28 KB	-rw-r--r--
multipart.rb	1.17 KB	-rw-r--r--
null_logger.rb	1.18 KB	-rw-r--r--
query_parser.rb	8.37 KB	-rw-r--r--
recursive.rb	1.78 KB	-rw-r--r--
reloader.rb	3.02 KB	-rw-r--r--
request.rb	24.57 KB	-rw-r--r--
response.rb	10.72 KB	-rw-r--r--
rewindable_input.rb	3.12 KB	-rw-r--r--
runtime.rb	870 B	-rw-r--r--
sendfile.rb	5.55 KB	-rw-r--r--
show_exceptions.rb	13.73 KB	-rw-r--r--
show_status.rb	3.58 KB	-rw-r--r--
static.rb	6 KB	-rw-r--r--
tempfile_reaper.rb	778 B	-rw-r--r--
urlmap.rb	2.81 KB	-rw-r--r--
utils.rb	21.1 KB	-rw-r--r--
version.rb	958 B	-rw-r--r--

Code Editor : rewindable_input.rb

# -*- encoding: binary -*-
# frozen_string_literal: true

require 'tempfile'

require_relative 'constants'

module Rack
  # Class which can make any IO object rewindable, including non-rewindable ones. It does
  # this by buffering the data into a tempfile, which is rewindable.
  #
  # Don't forget to call #close when you're done. This frees up temporary resources that
  # RewindableInput uses, though it does *not* close the original IO object.
  class RewindableInput
    # Makes rack.input rewindable, for compatibility with applications and middleware
    # designed for earlier versions of Rack (where rack.input was required to be
    # rewindable).
    class Middleware
      def initialize(app)
        @app = app
      end

def call(env)
        env[RACK_INPUT] = RewindableInput.new(env[RACK_INPUT])
        @app.call(env)
      end
    end

def initialize(io)
      @io = io
      @rewindable_io = nil
      @unlinked = false
    end

def gets
      make_rewindable unless @rewindable_io
      @rewindable_io.gets
    end

def read(*args)
      make_rewindable unless @rewindable_io
      @rewindable_io.read(*args)
    end

def each(&block)
      make_rewindable unless @rewindable_io
      @rewindable_io.each(&block)
    end

def rewind
      make_rewindable unless @rewindable_io
      @rewindable_io.rewind
    end

def size
      make_rewindable unless @rewindable_io
      @rewindable_io.size
    end

# Closes this RewindableInput object without closing the originally
    # wrapped IO object. Cleans up any temporary resources that this RewindableInput
    # has created.
    #
    # This method may be called multiple times. It does nothing on subsequent calls.
    def close
      if @rewindable_io
        if @unlinked
          @rewindable_io.close
        else
          @rewindable_io.close!
        end
        @rewindable_io = nil
      end
    end

private

def make_rewindable
      # Buffer all data into a tempfile. Since this tempfile is private to this
      # RewindableInput object, we chmod it so that nobody else can read or write
      # it. On POSIX filesystems we also unlink the file so that it doesn't
      # even have a file entry on the filesystem anymore, though we can still
      # access it because we have the file handle open.
      @rewindable_io = Tempfile.new('RackRewindableInput')
      @rewindable_io.chmod(0000)
      @rewindable_io.set_encoding(Encoding::BINARY)
      @rewindable_io.binmode
      # :nocov:
      if filesystem_has_posix_semantics?
        raise 'Unlink failed. IO closed.' if @rewindable_io.closed?
        @unlinked = true
      end
      # :nocov:

buffer = "".dup
      while @io.read(1024 * 4, buffer)
        entire_buffer_written_out = false
        while !entire_buffer_written_out
          written = @rewindable_io.write(buffer)
          entire_buffer_written_out = written == buffer.bytesize
          if !entire_buffer_written_out
            buffer.slice!(0 .. written - 1)
          end
        end
      end
      @rewindable_io.rewind
    end

def filesystem_has_posix_semantics?
      RUBY_PLATFORM !~ /(mswin|mingw|cygwin|java)/
    end
  end
end

${this.title}

Code Editor : rewindable_input.rb