1999-12-17 10:00:13 -05:00
|
|
|
=begin
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
= net/http.rb version 1.2.0
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
maintained by Minero Aoki <aamine@dp.u-netsurf.ne.jp>
|
|
|
|
This file is derived from "http-access.rb".
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
This program is free software.
|
|
|
|
You can distribute/modify this program under
|
|
|
|
the terms of the Ruby Distribute License.
|
1999-12-29 06:14:04 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
Japanese version of this document is in "net" full package.
|
|
|
|
You can get it from RAA
|
|
|
|
(Ruby Application Archive: http://www.ruby-lang.org/en/raa.html).
|
2000-09-21 02:58:01 -04:00
|
|
|
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
= class Net::HTTP
|
1999-12-17 10:00:13 -05:00
|
|
|
|
1999-12-29 06:14:04 -05:00
|
|
|
== Class Methods
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2000-06-27 09:36:17 -04:00
|
|
|
: new( address = 'localhost', port = 80, proxy_addr = nil, proxy_port = nil )
|
2000-05-18 04:57:37 -04:00
|
|
|
creates a new Net::HTTP object.
|
2000-11-16 09:03:20 -05:00
|
|
|
If proxy_addr is given, this method is equals to
|
2000-06-27 09:36:17 -04:00
|
|
|
Net::HTTP::Proxy(proxy_addr,proxy_port).
|
2000-05-18 04:57:37 -04:00
|
|
|
|
2000-06-27 09:36:17 -04:00
|
|
|
: start( address = 'localhost', port = 80, proxy_addr = nil, proxy_port = nil )
|
|
|
|
: start( address = 'localhost', port = 80, proxy_addr = nil, proxy_port = nil ) {|http| .... }
|
2000-11-16 09:03:20 -05:00
|
|
|
is equals to
|
|
|
|
Net::HTTP.new( address, port, proxy_addr, proxy_port ).start(&block)
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2000-11-10 18:31:32 -05:00
|
|
|
: Proxy( address, port )
|
|
|
|
creates a HTTP proxy class.
|
|
|
|
Arguments are address/port of proxy host.
|
|
|
|
You can replace HTTP class by this proxy class.
|
|
|
|
|
|
|
|
# example
|
|
|
|
proxy_http = HTTP::Proxy( 'proxy.foo.org', 8080 )
|
|
|
|
:
|
|
|
|
proxy_http.start( 'www.ruby-lang.org' ) do |http|
|
|
|
|
# connecting proxy.foo.org:8080
|
|
|
|
:
|
|
|
|
end
|
|
|
|
|
|
|
|
: proxy_class?
|
|
|
|
If self is HTTP, false.
|
|
|
|
If self is a class which was created by HTTP::Proxy(), true.
|
|
|
|
|
1999-12-29 06:14:04 -05:00
|
|
|
: port
|
2000-11-10 18:31:32 -05:00
|
|
|
HTTP default port (80).
|
1999-12-17 10:00:13 -05:00
|
|
|
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
== Instance Methods
|
1999-12-29 06:14:04 -05:00
|
|
|
|
2000-05-18 04:57:37 -04:00
|
|
|
: start
|
|
|
|
: start {|http| .... }
|
|
|
|
creates a new Net::HTTP object and starts HTTP session.
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
When this method is called with block, gives HTTP object to block
|
|
|
|
and close HTTP session after block call finished.
|
2000-05-18 04:57:37 -04:00
|
|
|
|
2000-11-10 18:31:32 -05:00
|
|
|
: proxy?
|
|
|
|
true if self is a HTTP proxy class
|
|
|
|
|
|
|
|
: proxy_address
|
|
|
|
address of proxy host. If self is not a proxy, nil.
|
|
|
|
|
|
|
|
: proxy_port
|
|
|
|
port number of proxy host. If self is not a proxy, nil.
|
|
|
|
|
2000-03-26 03:48:15 -05:00
|
|
|
: get( path, header = nil, dest = '' )
|
|
|
|
: get( path, header = nil ) {|str| .... }
|
2001-01-13 14:07:15 -05:00
|
|
|
gets data from "path" on connecting host.
|
2000-03-26 03:48:15 -05:00
|
|
|
"header" must be a Hash like { 'Accept' => '*/*', ... }.
|
2001-01-13 14:07:15 -05:00
|
|
|
Response body is written into "dest" by using "<<" method.
|
|
|
|
This method returns Net::HTTPResponse object.
|
2000-06-12 12:42:46 -04:00
|
|
|
|
|
|
|
# example
|
2001-01-13 14:07:15 -05:00
|
|
|
response = http.get( '/index.html' )
|
2000-03-26 03:48:15 -05:00
|
|
|
|
2000-09-21 02:58:01 -04:00
|
|
|
If called with block, give a part String of entity body.
|
1999-12-22 08:49:13 -05:00
|
|
|
|
1999-12-29 06:14:04 -05:00
|
|
|
: head( path, header = nil )
|
2000-11-16 09:03:20 -05:00
|
|
|
gets only header from "path" on connecting host.
|
1999-12-29 06:14:04 -05:00
|
|
|
"header" is a Hash like { 'Accept' => '*/*', ... }.
|
2000-11-16 09:03:20 -05:00
|
|
|
This method returns a Net::HTTPResponse object.
|
2000-03-31 08:02:40 -05:00
|
|
|
You can http header from this object like:
|
1999-12-22 08:49:13 -05:00
|
|
|
|
2000-03-31 08:02:40 -05:00
|
|
|
response['content-length'] #-> '2554'
|
|
|
|
response['content-type'] #-> 'text/html'
|
|
|
|
response['Content-Type'] #-> 'text/html'
|
|
|
|
response['CoNtEnT-tYpe'] #-> 'text/html'
|
1999-12-22 08:49:13 -05:00
|
|
|
|
2000-03-26 03:48:15 -05:00
|
|
|
: post( path, data, header = nil, dest = '' )
|
|
|
|
: post( path, data, header = nil ) {|str| .... }
|
2001-01-13 14:07:15 -05:00
|
|
|
posts "data" (must be String) to "path".
|
2000-11-16 09:03:20 -05:00
|
|
|
If the body exists, also gets entity body.
|
2001-01-13 14:07:15 -05:00
|
|
|
Response body is written into "dest" by using "<<" method.
|
2000-03-26 03:48:15 -05:00
|
|
|
"header" must be a Hash like { 'Accept' => '*/*', ... }.
|
2001-01-13 14:07:15 -05:00
|
|
|
This method returns Net::HTTPResponse object.
|
2000-03-26 03:48:15 -05:00
|
|
|
|
2000-11-16 09:03:20 -05:00
|
|
|
If called with block, gives a part of entity body string.
|
2000-03-26 03:48:15 -05:00
|
|
|
|
2000-04-22 03:29:53 -04:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
: request( request, [src] )
|
|
|
|
: request( request, [src] ) {|response| .... }
|
|
|
|
sends REQUEST to (remote) http server. This method also writes
|
|
|
|
string from SRC before it if REQUEST is a post/put request.
|
|
|
|
(giving SRC for get/head request causes ArgumentError.)
|
2000-09-21 02:58:01 -04:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
If called with block, gives a HTTP response object to the block.
|
2000-09-21 02:58:01 -04:00
|
|
|
|
2000-06-12 12:42:46 -04:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
= class Net::HTTP::Get, Head, Post
|
2000-03-27 10:52:27 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
HTTP request classes. These classes wraps request header and
|
|
|
|
entity path. All "key" is case-insensitive.
|
2000-12-24 15:01:44 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
== Methods
|
2000-12-24 15:01:44 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
: self[ key ]
|
|
|
|
returns header field for "key".
|
2000-06-12 12:42:46 -04:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
: self[ key ] = val
|
|
|
|
set header to "val".
|
2000-09-21 02:58:01 -04:00
|
|
|
|
2000-03-27 10:52:27 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
= class Net::HTTPResponse
|
2000-03-27 10:52:27 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
HTTP response class. This class wraps response header and entity.
|
2000-03-31 08:02:40 -05:00
|
|
|
All "key" is case-insensitive.
|
|
|
|
|
2000-06-12 12:42:46 -04:00
|
|
|
== Methods
|
|
|
|
|
2000-06-27 09:36:17 -04:00
|
|
|
: body
|
|
|
|
the entity body. ("dest" argument for HTTP#get, post, put)
|
2000-03-31 08:02:40 -05:00
|
|
|
|
|
|
|
: self[ key ]
|
|
|
|
returns header field for "key".
|
|
|
|
for HTTP, value is a string like 'text/plain'(for Content-Type),
|
|
|
|
'2045'(for Content-Length), 'bytes 0-1024/10024'(for Content-Range).
|
|
|
|
Multiple header had be joined by HTTP1.1 scheme.
|
|
|
|
|
|
|
|
: self[ key ] = val
|
|
|
|
set field value for "key".
|
2000-03-27 10:52:27 -05:00
|
|
|
|
2000-03-31 08:02:40 -05:00
|
|
|
: key?( key )
|
2000-11-16 09:03:20 -05:00
|
|
|
true if key exists
|
2000-03-31 08:02:40 -05:00
|
|
|
|
2000-04-18 05:39:02 -04:00
|
|
|
: each {|name,value| .... }
|
2000-11-16 09:03:20 -05:00
|
|
|
iterates for each field name and value pair
|
2000-04-18 05:39:02 -04:00
|
|
|
|
2000-06-27 09:36:17 -04:00
|
|
|
: code
|
2000-09-22 02:44:59 -04:00
|
|
|
HTTP result code string. For example, '302'
|
2000-06-12 12:42:46 -04:00
|
|
|
|
2000-06-27 09:36:17 -04:00
|
|
|
: message
|
|
|
|
HTTP result message. For example, 'Not Found'
|
2000-03-31 08:02:40 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
: read_body( dest = '' )
|
2000-03-27 10:52:27 -05:00
|
|
|
: body( dest = '' )
|
2001-01-13 14:07:15 -05:00
|
|
|
gets response body.
|
|
|
|
It is written into "dest" using "<<" method.
|
|
|
|
If this method is called twice or more, nothing will be done and
|
2000-12-24 15:01:44 -05:00
|
|
|
returns first "dest".
|
2000-06-27 09:36:17 -04:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
: read_body {|str| .... }
|
|
|
|
: body {|str| .... }
|
|
|
|
gets response body with block.
|
2000-06-27 09:36:17 -04:00
|
|
|
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
= Swithing Net::HTTP versions
|
2000-06-27 09:36:17 -04:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
You can use Net::HTTP 1.1 features by calling HTTP.old_implementation.
|
|
|
|
And calling Net::HTTP.new_implementation allows you to use 1.2 features
|
|
|
|
again.
|
2000-12-24 15:01:44 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
# example
|
|
|
|
HTTP.start {|http1| ...(http1 has 1.2 features)... }
|
2000-06-27 09:36:17 -04:00
|
|
|
|
2000-12-22 13:40:55 -05:00
|
|
|
HTTP.version_1_1
|
2001-01-13 14:07:15 -05:00
|
|
|
HTTP.start {|http2| ...(http2 has 1.1 features)... }
|
2000-12-24 15:01:44 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
HTTP.version_1_2
|
|
|
|
HTTP.start {|http3| ...(http3 has 1.2 features)... }
|
2000-06-27 09:36:17 -04:00
|
|
|
|
1999-12-29 06:14:04 -05:00
|
|
|
=end
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2000-06-12 12:42:46 -04:00
|
|
|
require 'net/protocol'
|
|
|
|
|
|
|
|
|
|
|
|
module Net
|
|
|
|
|
|
|
|
class HTTPBadResponse < StandardError; end
|
|
|
|
|
|
|
|
|
1999-12-29 06:14:04 -05:00
|
|
|
class HTTP < Protocol
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
HTTPVersion = '1.1'
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
###
|
|
|
|
### connection
|
|
|
|
###
|
2001-01-13 14:07:15 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
protocol_param :port, '80'
|
|
|
|
|
|
|
|
|
|
|
|
def initialize( addr = nil, port = nil )
|
|
|
|
super
|
|
|
|
|
|
|
|
@proxy_address = nil
|
|
|
|
@proxy_port = nil
|
|
|
|
|
|
|
|
@curr_http_version = HTTPVersion
|
|
|
|
@seems_1_0_server = false
|
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
|
|
|
def conn_command( sock )
|
|
|
|
end
|
|
|
|
|
|
|
|
def do_finish
|
2001-01-13 14:07:15 -05:00
|
|
|
end
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2000-11-10 18:31:32 -05:00
|
|
|
|
|
|
|
###
|
|
|
|
### proxy
|
|
|
|
###
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
public
|
|
|
|
|
|
|
|
|
2000-06-27 09:36:17 -04:00
|
|
|
class << self
|
|
|
|
|
2000-11-10 18:31:32 -05:00
|
|
|
def Proxy( p_addr, p_port = nil )
|
2001-02-06 06:14:51 -05:00
|
|
|
ProxyMod.create_proxy_class( p_addr, p_port || self.port )
|
2000-11-10 18:31:32 -05:00
|
|
|
end
|
|
|
|
|
2000-06-27 09:36:17 -04:00
|
|
|
alias orig_new new
|
|
|
|
|
|
|
|
def new( address = nil, port = nil, p_addr = nil, p_port = nil )
|
2000-11-16 09:03:20 -05:00
|
|
|
c = p_addr ? self::Proxy(p_addr, p_port) : self
|
|
|
|
i = c.orig_new( address, port )
|
2001-01-13 14:07:15 -05:00
|
|
|
setvar i
|
2000-11-16 09:03:20 -05:00
|
|
|
i
|
2000-06-27 09:36:17 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def start( address = nil, port = nil, p_addr = nil, p_port = nil, &block )
|
|
|
|
new( address, port, p_addr, p_port ).start( &block )
|
|
|
|
end
|
|
|
|
|
2000-11-10 18:31:32 -05:00
|
|
|
def proxy_class?
|
|
|
|
false
|
|
|
|
end
|
|
|
|
|
|
|
|
def proxy_address
|
|
|
|
nil
|
|
|
|
end
|
|
|
|
|
|
|
|
def proxy_port
|
|
|
|
nil
|
|
|
|
end
|
|
|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
def proxy?
|
|
|
|
false
|
|
|
|
end
|
|
|
|
|
|
|
|
def proxy_address
|
|
|
|
nil
|
|
|
|
end
|
|
|
|
|
|
|
|
def proxy_port
|
|
|
|
nil
|
|
|
|
end
|
|
|
|
|
|
|
|
def edit_path( path )
|
|
|
|
path
|
2000-06-27 09:36:17 -04:00
|
|
|
end
|
|
|
|
|
2000-11-10 18:31:32 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
module ProxyMod
|
|
|
|
|
|
|
|
class << self
|
|
|
|
|
|
|
|
def create_proxy_class( p_addr, p_port )
|
2001-02-06 08:04:08 -05:00
|
|
|
mod = self
|
2001-02-06 06:14:51 -05:00
|
|
|
klass = Class.new( HTTP )
|
|
|
|
klass.module_eval {
|
2001-02-06 08:04:08 -05:00
|
|
|
include mod
|
2001-02-06 06:14:51 -05:00
|
|
|
@proxy_address = p_addr
|
|
|
|
@proxy_port = p_port
|
|
|
|
}
|
|
|
|
def klass.proxy_class?
|
|
|
|
true
|
|
|
|
end
|
|
|
|
|
|
|
|
def klass.proxy_address
|
|
|
|
@proxy_address
|
|
|
|
end
|
|
|
|
|
|
|
|
def klass.proxy_port
|
|
|
|
@proxy_port
|
|
|
|
end
|
|
|
|
|
|
|
|
klass
|
|
|
|
end
|
|
|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
def initialize( addr, port )
|
|
|
|
super
|
|
|
|
@proxy_address = type.proxy_address
|
|
|
|
@proxy_port = type.proxy_port
|
|
|
|
end
|
|
|
|
|
|
|
|
attr_reader :proxy_address, :proxy_port
|
|
|
|
|
|
|
|
alias proxyaddr proxy_address
|
|
|
|
alias proxyport proxy_port
|
|
|
|
|
|
|
|
def proxy?
|
|
|
|
true
|
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
|
|
|
def conn_socket( addr, port )
|
|
|
|
super @proxy_address, @proxy_port
|
|
|
|
end
|
|
|
|
|
|
|
|
def edit_path( path )
|
|
|
|
'http://' + addr_port + path
|
|
|
|
end
|
|
|
|
|
|
|
|
end # module ProxyMod
|
|
|
|
|
|
|
|
|
|
|
|
#
|
|
|
|
# for backward compatibility
|
|
|
|
#
|
2000-11-10 18:31:32 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
@@newimpl = true
|
2000-06-27 09:36:17 -04:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
class << self
|
2000-06-27 09:36:17 -04:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def version_1_2
|
2000-11-16 09:03:20 -05:00
|
|
|
@@newimpl = true
|
|
|
|
end
|
2000-06-27 09:36:17 -04:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def version_1_1
|
2000-11-16 09:03:20 -05:00
|
|
|
@@newimpl = false
|
|
|
|
end
|
2000-06-27 09:36:17 -04:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
private
|
2000-03-27 10:52:27 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def setvar( obj )
|
2000-11-16 09:03:20 -05:00
|
|
|
f = @@newimpl
|
|
|
|
obj.instance_eval { @newimpl = f }
|
2000-11-10 18:31:32 -05:00
|
|
|
end
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
end
|
2000-11-10 18:31:32 -05:00
|
|
|
|
2000-03-27 10:52:27 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
#
|
|
|
|
# http operations
|
|
|
|
#
|
2000-11-10 18:31:32 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
public
|
|
|
|
|
|
|
|
def self.def_http_method( nm, hasdest, hasdata )
|
2001-01-13 14:07:15 -05:00
|
|
|
name = nm.id2name.downcase
|
|
|
|
cname = nm.id2name
|
|
|
|
lineno = __LINE__ + 2
|
2001-02-06 06:14:51 -05:00
|
|
|
src = <<" ----"
|
2001-01-13 14:07:15 -05:00
|
|
|
|
|
|
|
def #{name}( path, #{hasdata ? 'data,' : ''}
|
|
|
|
u_header = nil #{hasdest ? ',dest = nil, &block' : ''} )
|
2001-02-06 06:14:51 -05:00
|
|
|
resp = nil
|
|
|
|
request(
|
|
|
|
#{cname}.new( path, u_header ) #{hasdata ? ',data' : ''}
|
|
|
|
) do |resp|
|
2001-01-13 14:07:15 -05:00
|
|
|
resp.read_body( #{hasdest ? 'dest, &block' : ''} )
|
2001-02-06 06:14:51 -05:00
|
|
|
end
|
2001-01-13 14:07:15 -05:00
|
|
|
if @newimpl then
|
|
|
|
resp
|
|
|
|
else
|
|
|
|
resp.value
|
|
|
|
#{hasdest ? 'return resp, resp.body' : 'resp'}
|
|
|
|
end
|
|
|
|
end
|
2000-03-26 03:48:15 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def #{name}2( path, #{hasdata ? 'data,' : ''}
|
2001-02-06 06:14:51 -05:00
|
|
|
u_header = nil, &block )
|
|
|
|
request( #{cname}.new(path, u_header),
|
|
|
|
#{hasdata ? 'data,' : ''} &block )
|
2001-01-13 14:07:15 -05:00
|
|
|
end
|
2001-02-06 06:14:51 -05:00
|
|
|
----
|
|
|
|
#puts src
|
2001-01-13 14:07:15 -05:00
|
|
|
module_eval src, __FILE__, lineno
|
2000-12-24 15:01:44 -05:00
|
|
|
end
|
2000-03-26 03:48:15 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
def_http_method :Get, true, false
|
|
|
|
def_http_method :Head, false, false
|
|
|
|
def_http_method :Post, true, true
|
|
|
|
def_http_method :Put, false, true
|
2000-04-18 05:39:02 -04:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
def request( req, *args )
|
|
|
|
common_oper( req ) {
|
|
|
|
req.__send__( :exec,
|
|
|
|
@socket, @curr_http_version,
|
|
|
|
edit_path(req.path),
|
|
|
|
header_defaults, *args )
|
|
|
|
yield req.response if block_given?
|
|
|
|
}
|
|
|
|
req.response
|
2000-04-18 05:39:02 -04:00
|
|
|
end
|
|
|
|
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
private
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2000-11-16 09:03:20 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
def common_oper( req )
|
2000-03-05 05:25:53 -05:00
|
|
|
if not @socket then
|
|
|
|
start
|
2001-02-06 06:14:51 -05:00
|
|
|
req['connection'] = 'close'
|
2000-03-05 05:25:53 -05:00
|
|
|
elsif @socket.closed? then
|
1999-12-29 06:14:04 -05:00
|
|
|
@socket.reopen
|
2001-02-06 07:26:25 -05:00
|
|
|
on_connect
|
1999-12-29 06:14:04 -05:00
|
|
|
end
|
2001-02-06 06:14:51 -05:00
|
|
|
if @seems_1_0_server then
|
|
|
|
req['connection'] = 'close'
|
|
|
|
end
|
2000-03-27 10:52:27 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
yield req
|
|
|
|
req.response.__send__ :terminate
|
2001-01-13 14:07:15 -05:00
|
|
|
@curr_http_version = req.http_version
|
2000-09-21 02:58:01 -04:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
if keep_alive? req, req.response then
|
|
|
|
if @socket.closed? then
|
|
|
|
@seems_1_0_server = true
|
|
|
|
@socket.close
|
|
|
|
end
|
|
|
|
else
|
2000-03-05 05:25:53 -05:00
|
|
|
@socket.close
|
|
|
|
end
|
2001-01-13 14:07:15 -05:00
|
|
|
|
|
|
|
req.response
|
1999-12-29 06:14:04 -05:00
|
|
|
end
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
def header_defaults
|
2001-01-13 14:07:15 -05:00
|
|
|
h = {}
|
|
|
|
h['Host'] = addr_port
|
|
|
|
h['Connection'] = 'Keep-Alive'
|
|
|
|
h['Accept'] = '*/*'
|
|
|
|
h
|
|
|
|
end
|
|
|
|
|
|
|
|
def keep_alive?( request, response )
|
|
|
|
if response.key? 'connection' then
|
|
|
|
if /keep-alive/i === response['connection'] then
|
2000-04-22 03:29:53 -04:00
|
|
|
return true
|
|
|
|
end
|
2001-01-13 14:07:15 -05:00
|
|
|
elsif response.key? 'proxy-connection' then
|
|
|
|
if /keep-alive/i === response['proxy-connection'] then
|
2000-06-01 09:43:43 -04:00
|
|
|
return true
|
|
|
|
end
|
2001-01-13 14:07:15 -05:00
|
|
|
elsif request.key? 'Connection' then
|
|
|
|
if /keep-alive/i === request['Connection'] then
|
1999-12-29 06:14:04 -05:00
|
|
|
return true
|
|
|
|
end
|
|
|
|
else
|
2001-01-13 14:07:15 -05:00
|
|
|
if @curr_http_version == '1.1' then
|
1999-12-29 06:14:04 -05:00
|
|
|
return true
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
false
|
|
|
|
end
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
def addr_port
|
|
|
|
address + (port == HTTP.port ? '' : ":#{port}")
|
2001-01-13 14:07:15 -05:00
|
|
|
end
|
2000-12-24 15:01:44 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
end
|
2000-12-24 15:01:44 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
HTTPSession = HTTP
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2000-11-10 18:31:32 -05:00
|
|
|
|
1999-12-29 06:14:04 -05:00
|
|
|
|
2000-10-11 01:27:56 -04:00
|
|
|
class Code
|
aamine
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb: 1.1.26.
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb:
add module Net::NetPrivate and its inner classes
{Read,Write}Adapter, Command, Socket,
SMTPCommand, POP3Command, APOPCommand, HTTPCommand
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@826 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
2000-07-12 02:04:40 -04:00
|
|
|
|
2000-10-11 01:27:56 -04:00
|
|
|
def http_mkchild( bodyexist = nil )
|
|
|
|
c = mkchild(nil)
|
|
|
|
be = if bodyexist.nil? then @body_exist else bodyexist end
|
|
|
|
c.instance_eval { @body_exist = be }
|
|
|
|
c
|
aamine
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb: 1.1.26.
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb:
add module Net::NetPrivate and its inner classes
{Read,Write}Adapter, Command, Socket,
SMTPCommand, POP3Command, APOPCommand, HTTPCommand
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@826 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
2000-07-12 02:04:40 -04:00
|
|
|
end
|
|
|
|
|
2000-10-11 01:27:56 -04:00
|
|
|
def body_exist?
|
|
|
|
@body_exist
|
aamine
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb: 1.1.26.
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb:
add module Net::NetPrivate and its inner classes
{Read,Write}Adapter, Command, Socket,
SMTPCommand, POP3Command, APOPCommand, HTTPCommand
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@826 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
2000-07-12 02:04:40 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
end
|
|
|
|
|
2000-10-11 01:27:56 -04:00
|
|
|
HTTPInformationCode = InformationCode.http_mkchild( false )
|
|
|
|
HTTPSuccessCode = SuccessCode .http_mkchild( true )
|
|
|
|
HTTPRedirectionCode = RetriableCode .http_mkchild( true )
|
|
|
|
HTTPRetriableCode = HTTPRedirectionCode
|
|
|
|
HTTPClientErrorCode = FatalErrorCode .http_mkchild( true )
|
|
|
|
HTTPFatalErrorCode = HTTPClientErrorCode
|
|
|
|
HTTPServerErrorCode = ServerErrorCode.http_mkchild( true )
|
|
|
|
|
|
|
|
|
|
|
|
HTTPSwitchProtocol = HTTPInformationCode.http_mkchild
|
|
|
|
|
|
|
|
HTTPOK = HTTPSuccessCode.http_mkchild
|
|
|
|
HTTPCreated = HTTPSuccessCode.http_mkchild
|
|
|
|
HTTPAccepted = HTTPSuccessCode.http_mkchild
|
|
|
|
HTTPNonAuthoritativeInformation = HTTPSuccessCode.http_mkchild
|
|
|
|
HTTPNoContent = HTTPSuccessCode.http_mkchild( false )
|
|
|
|
HTTPResetContent = HTTPSuccessCode.http_mkchild( false )
|
|
|
|
HTTPPartialContent = HTTPSuccessCode.http_mkchild
|
|
|
|
|
|
|
|
HTTPMultipleChoice = HTTPRedirectionCode.http_mkchild
|
|
|
|
HTTPMovedPermanently = HTTPRedirectionCode.http_mkchild
|
|
|
|
HTTPMovedTemporarily = HTTPRedirectionCode.http_mkchild
|
|
|
|
HTTPNotModified = HTTPRedirectionCode.http_mkchild( false )
|
|
|
|
HTTPUseProxy = HTTPRedirectionCode.http_mkchild( false )
|
|
|
|
|
|
|
|
HTTPBadRequest = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPUnauthorized = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPPaymentRequired = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPForbidden = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPNotFound = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPMethodNotAllowed = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPNotAcceptable = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPProxyAuthenticationRequired = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPRequestTimeOut = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPConflict = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPGone = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPLengthRequired = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPPreconditionFailed = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPRequestEntityTooLarge = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPRequestURITooLarge = HTTPClientErrorCode.http_mkchild
|
|
|
|
HTTPUnsupportedMediaType = HTTPClientErrorCode.http_mkchild
|
|
|
|
|
|
|
|
HTTPNotImplemented = HTTPServerErrorCode.http_mkchild
|
|
|
|
HTTPBadGateway = HTTPServerErrorCode.http_mkchild
|
|
|
|
HTTPServiceUnavailable = HTTPServerErrorCode.http_mkchild
|
|
|
|
HTTPGatewayTimeOut = HTTPServerErrorCode.http_mkchild
|
|
|
|
HTTPVersionNotSupported = HTTPServerErrorCode.http_mkchild
|
aamine
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb: 1.1.26.
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb:
add module Net::NetPrivate and its inner classes
{Read,Write}Adapter, Command, Socket,
SMTPCommand, POP3Command, APOPCommand, HTTPCommand
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@826 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
2000-07-12 02:04:40 -04:00
|
|
|
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
class HTTP
|
aamine
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb: 1.1.26.
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb:
add module Net::NetPrivate and its inner classes
{Read,Write}Adapter, Command, Socket,
SMTPCommand, POP3Command, APOPCommand, HTTPCommand
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@826 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
2000-07-12 02:04:40 -04:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
###
|
|
|
|
### request
|
|
|
|
###
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
class HTTPRequest
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
def initialize( path, uhead = nil )
|
2001-01-13 14:07:15 -05:00
|
|
|
@path = path
|
2001-02-06 06:14:51 -05:00
|
|
|
@u_header = tmp = {}
|
2001-01-13 14:07:15 -05:00
|
|
|
return unless uhead
|
|
|
|
uhead.each do |k,v|
|
|
|
|
key = canonical(k)
|
|
|
|
if tmp.key? key then
|
|
|
|
$stderr.puts "WARNING: duplicated HTTP header: #{k}" if $VERBOSE
|
|
|
|
end
|
2001-01-16 02:57:43 -05:00
|
|
|
tmp[ key ] = v.strip
|
2001-01-13 14:07:15 -05:00
|
|
|
end
|
2001-02-06 06:14:51 -05:00
|
|
|
|
|
|
|
@socket = nil
|
|
|
|
@response = nil
|
|
|
|
@http_version = nil
|
1999-12-29 06:14:04 -05:00
|
|
|
end
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
public
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
attr_reader :path
|
|
|
|
attr_reader :response
|
2001-02-06 06:14:51 -05:00
|
|
|
attr_reader :http_version
|
2001-01-13 14:07:15 -05:00
|
|
|
|
2000-06-12 12:42:46 -04:00
|
|
|
def inspect
|
2001-01-13 14:07:15 -05:00
|
|
|
"\#<#{type}>"
|
2000-06-12 12:42:46 -04:00
|
|
|
end
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def []( key )
|
|
|
|
@u_header[ canonical key ]
|
|
|
|
end
|
2000-10-11 01:27:56 -04:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def []=( key, val )
|
|
|
|
@u_header[ canonical key ] = val
|
|
|
|
end
|
2000-11-07 06:27:16 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def key?( key )
|
|
|
|
@u_header.key? canonical(key)
|
|
|
|
end
|
2000-11-07 06:27:16 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def delete( key )
|
|
|
|
@u_header.delete canonical(key)
|
1999-12-17 10:00:13 -05:00
|
|
|
end
|
2001-01-13 14:07:15 -05:00
|
|
|
|
|
|
|
def each( &block )
|
|
|
|
@u_header.each( &block )
|
1999-12-29 06:14:04 -05:00
|
|
|
end
|
1999-12-17 10:00:13 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def each_key( &block )
|
|
|
|
@u_header.each_key( &block )
|
2000-02-21 10:25:37 -05:00
|
|
|
end
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def each_value( &block )
|
|
|
|
@u_header.each_value( &block )
|
2000-02-21 10:25:37 -05:00
|
|
|
end
|
1999-12-29 06:14:04 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
private
|
1999-12-29 06:14:04 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def canonical( k )
|
|
|
|
k.split('-').collect {|i| i.capitalize }.join('-')
|
2000-03-27 10:52:27 -05:00
|
|
|
end
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
#
|
|
|
|
# write
|
|
|
|
#
|
1999-12-29 06:14:04 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
def exec( sock, ver, path, ihead )
|
|
|
|
ready( sock, ihead ) {|header|
|
|
|
|
request ver, path, header
|
|
|
|
}
|
|
|
|
end
|
2001-01-13 14:07:15 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
def ready( sock, ihead )
|
|
|
|
@response = nil
|
|
|
|
@socket = sock
|
|
|
|
ihead.update @u_header
|
|
|
|
yield ihead
|
2001-01-13 14:07:15 -05:00
|
|
|
@response = read_response
|
2001-02-06 06:14:51 -05:00
|
|
|
@sock = nil
|
2001-01-13 14:07:15 -05:00
|
|
|
end
|
2000-11-07 06:27:16 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
def request( ver, path, header )
|
|
|
|
@socket.writeline sprintf('%s %s HTTP/%s', type::METHOD, path, ver)
|
|
|
|
header.each do |n,v|
|
2000-11-07 06:27:16 -05:00
|
|
|
@socket.writeline n + ': ' + v
|
|
|
|
end
|
|
|
|
@socket.writeline ''
|
|
|
|
end
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
#
|
|
|
|
# read
|
|
|
|
#
|
2000-11-07 06:27:16 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def read_response
|
|
|
|
resp = rdresp0
|
|
|
|
resp = rdresp0 while ContinueCode === resp
|
2000-11-07 06:27:16 -05:00
|
|
|
resp
|
|
|
|
end
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def rdresp0
|
|
|
|
resp = get_resline
|
2000-03-31 08:02:40 -05:00
|
|
|
|
2000-03-26 03:48:15 -05:00
|
|
|
while true do
|
2001-02-06 06:14:51 -05:00
|
|
|
line = @socket.readuntil( "\n", true ) # ignore EOF
|
|
|
|
line.sub!( /\s+\z/, '' ) # don't use chop!
|
2000-03-26 03:48:15 -05:00
|
|
|
break if line.empty?
|
2000-03-31 08:02:40 -05:00
|
|
|
|
2000-05-22 09:39:24 -04:00
|
|
|
m = /\A([^:]+):\s*/.match( line )
|
2001-02-06 06:14:51 -05:00
|
|
|
m or raise HTTPBadResponse, 'wrong header line format'
|
2000-03-31 08:02:40 -05:00
|
|
|
nm = m[1]
|
2000-05-22 09:39:24 -04:00
|
|
|
line = m.post_match
|
2000-03-31 08:02:40 -05:00
|
|
|
if resp.key? nm then
|
|
|
|
resp[nm] << ', ' << line
|
|
|
|
else
|
|
|
|
resp[nm] = line
|
|
|
|
end
|
2000-03-26 03:48:15 -05:00
|
|
|
end
|
1999-12-29 06:14:04 -05:00
|
|
|
|
2000-03-31 08:02:40 -05:00
|
|
|
resp
|
2000-03-26 03:48:15 -05:00
|
|
|
end
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def get_resline
|
2000-11-07 06:27:16 -05:00
|
|
|
str = @socket.readline
|
2001-02-06 06:14:51 -05:00
|
|
|
m = /\AHTTP(?:\/(\d+\.\d+))?\s+(\d\d\d)\s*(.*)\z/i.match( str )
|
2000-11-07 06:27:16 -05:00
|
|
|
unless m then
|
|
|
|
raise HTTPBadResponse, "wrong status line: #{str}"
|
2000-03-26 03:48:15 -05:00
|
|
|
end
|
2000-11-07 06:27:16 -05:00
|
|
|
@http_version = m[1]
|
|
|
|
status = m[2]
|
|
|
|
discrip = m[3]
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
::Net::NetPrivate::HTTPResponse.new(
|
|
|
|
status, discrip, @socket, type::HAS_BODY )
|
2000-12-24 14:39:15 -05:00
|
|
|
end
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
|
|
|
|
class HTTPRequestWithData < HTTPRequest
|
2001-02-06 06:14:51 -05:00
|
|
|
|
|
|
|
private
|
2001-01-13 14:07:15 -05:00
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
def exec( sock, ver, path, ihead, str = nil )
|
2001-01-13 14:07:15 -05:00
|
|
|
check_arg str, block_given?
|
|
|
|
|
|
|
|
if block_given? then
|
|
|
|
ac = Accumulator.new
|
2001-02-06 06:14:51 -05:00
|
|
|
yield ac # must be yield, DO NOT USE block.call
|
2001-01-13 14:07:15 -05:00
|
|
|
data = ac.terminate
|
|
|
|
else
|
|
|
|
data = str
|
|
|
|
end
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
ready( sock, ihead ) {|header|
|
|
|
|
header['Content-Length'] = data.size.to_s
|
|
|
|
header.delete 'Transfer-Encoding'
|
|
|
|
request ver, path, header
|
2001-01-13 14:07:15 -05:00
|
|
|
@socket.write data
|
|
|
|
}
|
|
|
|
end
|
|
|
|
|
|
|
|
def check_arg( data, blkp )
|
|
|
|
if data and blkp then
|
|
|
|
raise ArgumentError, 'both of data and block given'
|
|
|
|
end
|
|
|
|
unless data or blkp then
|
|
|
|
raise ArgumentError, 'str or block required'
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
|
|
class Accumulator
|
|
|
|
|
|
|
|
def initialize
|
|
|
|
@buf = ''
|
|
|
|
end
|
|
|
|
|
|
|
|
def write( s )
|
|
|
|
@buf.concat s
|
|
|
|
end
|
|
|
|
|
|
|
|
alias << write
|
|
|
|
|
|
|
|
def terminate
|
|
|
|
ret = @buf
|
|
|
|
@buf = nil
|
|
|
|
ret
|
|
|
|
end
|
|
|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
class Get < HTTPRequest
|
|
|
|
HAS_BODY = true
|
|
|
|
METHOD = 'GET'
|
|
|
|
end
|
|
|
|
|
|
|
|
class Head < HTTPRequest
|
|
|
|
HAS_BODY = false
|
|
|
|
METHOD = 'HEAD'
|
|
|
|
end
|
|
|
|
|
|
|
|
class Post < HTTPRequestWithData
|
|
|
|
HAS_BODY = true
|
|
|
|
METHOD = 'POST'
|
|
|
|
end
|
|
|
|
|
|
|
|
class Put < HTTPRequestWithData
|
|
|
|
HAS_BODY = true
|
|
|
|
METHOD = 'PUT'
|
|
|
|
end
|
|
|
|
|
|
|
|
end # HTTP::
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
module NetPrivate
|
2001-01-13 14:07:15 -05:00
|
|
|
|
|
|
|
###
|
|
|
|
### response
|
|
|
|
###
|
|
|
|
|
|
|
|
class HTTPResponse < Response
|
|
|
|
|
2000-10-11 01:27:56 -04:00
|
|
|
HTTPCODE_CLASS_TO_OBJ = {
|
|
|
|
'1' => HTTPInformationCode,
|
|
|
|
'2' => HTTPSuccessCode,
|
|
|
|
'3' => HTTPRedirectionCode,
|
|
|
|
'4' => HTTPClientErrorCode,
|
|
|
|
'5' => HTTPServerErrorCode
|
|
|
|
}
|
|
|
|
|
2000-03-31 08:02:40 -05:00
|
|
|
HTTPCODE_TO_OBJ = {
|
2000-10-11 01:27:56 -04:00
|
|
|
'100' => ContinueCode,
|
2000-10-12 05:54:32 -04:00
|
|
|
'101' => HTTPSwitchProtocol,
|
2000-10-11 01:27:56 -04:00
|
|
|
|
|
|
|
'200' => HTTPOK,
|
|
|
|
'201' => HTTPCreated,
|
|
|
|
'202' => HTTPAccepted,
|
|
|
|
'203' => HTTPNonAuthoritativeInformation,
|
|
|
|
'204' => HTTPNoContent,
|
|
|
|
'205' => HTTPResetContent,
|
|
|
|
'206' => HTTPPartialContent,
|
|
|
|
|
|
|
|
'300' => HTTPMultipleChoice,
|
|
|
|
'301' => HTTPMovedPermanently,
|
|
|
|
'302' => HTTPMovedTemporarily,
|
|
|
|
'303' => HTTPMovedPermanently,
|
|
|
|
'304' => HTTPNotModified,
|
|
|
|
'305' => HTTPUseProxy,
|
|
|
|
|
|
|
|
'400' => HTTPBadRequest,
|
|
|
|
'401' => HTTPUnauthorized,
|
|
|
|
'402' => HTTPPaymentRequired,
|
|
|
|
'403' => HTTPForbidden,
|
|
|
|
'404' => HTTPNotFound,
|
|
|
|
'405' => HTTPMethodNotAllowed,
|
|
|
|
'406' => HTTPNotAcceptable,
|
|
|
|
'407' => HTTPProxyAuthenticationRequired,
|
|
|
|
'408' => HTTPRequestTimeOut,
|
|
|
|
'409' => HTTPConflict,
|
|
|
|
'410' => HTTPGone,
|
|
|
|
'411' => HTTPFatalErrorCode,
|
|
|
|
'412' => HTTPPreconditionFailed,
|
|
|
|
'413' => HTTPRequestEntityTooLarge,
|
|
|
|
'414' => HTTPRequestURITooLarge,
|
|
|
|
'415' => HTTPUnsupportedMediaType,
|
|
|
|
|
|
|
|
'500' => HTTPFatalErrorCode,
|
|
|
|
'501' => HTTPNotImplemented,
|
|
|
|
'502' => HTTPBadGateway,
|
|
|
|
'503' => HTTPServiceUnavailable,
|
|
|
|
'504' => HTTPGatewayTimeOut,
|
|
|
|
'505' => HTTPVersionNotSupported
|
2000-03-27 10:52:27 -05:00
|
|
|
}
|
|
|
|
|
2000-11-07 06:27:16 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def initialize( status, msg, sock, be )
|
|
|
|
code = HTTPCODE_TO_OBJ[status] ||
|
|
|
|
HTTPCODE_CLASS_TO_OBJ[status[0,1]] ||
|
|
|
|
UnknownCode
|
|
|
|
super code, status, msg
|
|
|
|
@socket = sock
|
|
|
|
@body_exist = be
|
|
|
|
|
|
|
|
@header = {}
|
|
|
|
@body = nil
|
|
|
|
@read = false
|
|
|
|
end
|
|
|
|
|
|
|
|
def inspect
|
|
|
|
"#<#{type} #{code}>"
|
|
|
|
end
|
|
|
|
|
|
|
|
def []( key )
|
|
|
|
@header[ key.downcase ]
|
|
|
|
end
|
|
|
|
|
|
|
|
def []=( key, val )
|
|
|
|
@header[ key.downcase ] = val
|
|
|
|
end
|
|
|
|
|
|
|
|
def each( &block )
|
|
|
|
@header.each( &block )
|
|
|
|
end
|
|
|
|
|
|
|
|
def each_key( &block )
|
|
|
|
@header.each_key( &block )
|
|
|
|
end
|
|
|
|
|
|
|
|
def each_value( &block )
|
|
|
|
@header.each_value( &block )
|
|
|
|
end
|
|
|
|
|
|
|
|
def delete( key )
|
|
|
|
@header.delete key.downcase
|
|
|
|
end
|
|
|
|
|
|
|
|
def key?( key )
|
|
|
|
@header.key? key.downcase
|
|
|
|
end
|
|
|
|
|
|
|
|
def to_hash
|
|
|
|
@header.dup
|
|
|
|
end
|
|
|
|
|
|
|
|
def value
|
|
|
|
unless SuccessCode === self then
|
|
|
|
error! self
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
#
|
2001-01-13 14:07:15 -05:00
|
|
|
# header (for backward compatibility)
|
2001-02-06 06:14:51 -05:00
|
|
|
#
|
2000-12-24 14:39:15 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def read_header
|
|
|
|
self
|
|
|
|
end
|
2000-12-24 14:39:15 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
alias header read_header
|
|
|
|
alias response read_header
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
#
|
2001-01-13 14:07:15 -05:00
|
|
|
# body
|
2001-02-06 06:14:51 -05:00
|
|
|
#
|
2001-01-13 14:07:15 -05:00
|
|
|
|
|
|
|
def read_body( dest = nil, &block )
|
|
|
|
if @read and (dest or block) then
|
|
|
|
raise IOError, "#{type}\#read_body called twice with argument"
|
|
|
|
end
|
|
|
|
|
|
|
|
unless @read then
|
|
|
|
to = procdest( dest, block )
|
|
|
|
stream_check
|
|
|
|
|
|
|
|
if @body_exist and code_type.body_exist? then
|
|
|
|
read_body_0 to
|
|
|
|
@body = to
|
|
|
|
else
|
|
|
|
@body = nil
|
|
|
|
end
|
|
|
|
@read = true
|
|
|
|
end
|
|
|
|
|
|
|
|
@body
|
|
|
|
end
|
|
|
|
|
|
|
|
alias body read_body
|
|
|
|
alias entity read_body
|
|
|
|
|
|
|
|
|
2001-02-06 06:14:51 -05:00
|
|
|
private
|
|
|
|
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def terminate
|
|
|
|
read_body
|
|
|
|
end
|
|
|
|
|
|
|
|
def read_body_0( dest )
|
|
|
|
if chunked? then
|
2000-11-16 09:03:20 -05:00
|
|
|
read_chunked dest
|
2000-11-07 06:27:16 -05:00
|
|
|
else
|
2001-01-13 14:07:15 -05:00
|
|
|
clen = content_length
|
2000-11-07 06:27:16 -05:00
|
|
|
if clen then
|
2001-02-06 06:14:51 -05:00
|
|
|
@socket.read clen, dest, true # ignore EOF
|
2000-11-07 06:27:16 -05:00
|
|
|
else
|
2001-01-13 14:07:15 -05:00
|
|
|
clen = range_length
|
2000-11-07 06:27:16 -05:00
|
|
|
if clen then
|
|
|
|
@socket.read clen, dest
|
|
|
|
else
|
2000-11-16 09:03:20 -05:00
|
|
|
@socket.read_all dest
|
2000-11-07 06:27:16 -05:00
|
|
|
end
|
|
|
|
end
|
1999-12-29 06:14:04 -05:00
|
|
|
end
|
2000-11-07 06:27:16 -05:00
|
|
|
end
|
|
|
|
|
2000-11-16 09:03:20 -05:00
|
|
|
def read_chunked( dest )
|
1999-12-29 06:14:04 -05:00
|
|
|
len = nil
|
|
|
|
total = 0
|
1999-12-20 15:48:49 -05:00
|
|
|
|
1999-12-29 06:14:04 -05:00
|
|
|
while true do
|
|
|
|
line = @socket.readline
|
2000-10-15 17:37:30 -04:00
|
|
|
m = /[0-9a-fA-F]+/.match( line )
|
2000-03-31 08:02:40 -05:00
|
|
|
unless m then
|
2000-04-14 06:41:35 -04:00
|
|
|
raise HTTPBadResponse, "wrong chunk size line: #{line}"
|
1999-12-29 06:14:04 -05:00
|
|
|
end
|
2000-03-31 08:02:40 -05:00
|
|
|
len = m[0].hex
|
1999-12-29 06:14:04 -05:00
|
|
|
break if len == 0
|
2000-11-16 09:03:20 -05:00
|
|
|
@socket.read( len, dest ); total += len
|
1999-12-29 06:14:04 -05:00
|
|
|
@socket.read 2 # \r\n
|
1999-12-20 15:48:49 -05:00
|
|
|
end
|
2000-04-14 06:41:35 -04:00
|
|
|
until @socket.readline.empty? do
|
|
|
|
;
|
1999-12-29 06:14:04 -05:00
|
|
|
end
|
2000-03-26 03:48:15 -05:00
|
|
|
end
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def content_length
|
|
|
|
if @header.key? 'content-length' then
|
|
|
|
m = /\d+/.match( @header['content-length'] )
|
2000-03-31 08:02:40 -05:00
|
|
|
unless m then
|
|
|
|
raise HTTPBadResponse, 'wrong Content-Length format'
|
|
|
|
end
|
|
|
|
m[0].to_i
|
|
|
|
else
|
|
|
|
nil
|
2000-03-26 03:48:15 -05:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def chunked?
|
|
|
|
tmp = @header['transfer-encoding']
|
|
|
|
tmp and /\bchunked\b/i === tmp
|
2000-11-16 09:03:20 -05:00
|
|
|
end
|
2000-03-26 03:48:15 -05:00
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def range_length
|
|
|
|
if @header.key? 'content-range' then
|
|
|
|
m = %r<bytes\s+(\d+)-(\d+)/\d+>.match( @header['content-range'] )
|
2000-03-31 08:02:40 -05:00
|
|
|
unless m then
|
|
|
|
raise HTTPBadResponse, 'wrong Content-Range format'
|
|
|
|
end
|
|
|
|
l = m[2].to_i
|
|
|
|
u = m[1].to_i
|
|
|
|
if l > u then
|
|
|
|
nil
|
|
|
|
else
|
|
|
|
u - l
|
|
|
|
end
|
|
|
|
else
|
|
|
|
nil
|
|
|
|
end
|
1999-12-20 15:48:49 -05:00
|
|
|
end
|
|
|
|
|
2001-01-13 14:07:15 -05:00
|
|
|
def stream_check
|
|
|
|
if @socket.closed? then
|
|
|
|
raise IOError, 'try to read body out of block'
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
def procdest( dest, block )
|
|
|
|
if dest and block then
|
|
|
|
raise ArgumentError,
|
|
|
|
'both of arg and block are given for HTTP method'
|
|
|
|
end
|
|
|
|
if block then
|
|
|
|
ReadAdapter.new block
|
|
|
|
else
|
|
|
|
dest or ''
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
1999-12-20 15:48:49 -05:00
|
|
|
end
|
|
|
|
|
1999-12-17 10:00:13 -05:00
|
|
|
|
aamine
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb: 1.1.26.
* lib/net/protocol.rb, smtp.rb, pop.rb, http.rb:
add module Net::NetPrivate and its inner classes
{Read,Write}Adapter, Command, Socket,
SMTPCommand, POP3Command, APOPCommand, HTTPCommand
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@826 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
2000-07-12 02:04:40 -04:00
|
|
|
end # module Net::NetPrivate
|
|
|
|
|
1999-12-17 10:00:13 -05:00
|
|
|
end # module Net
|