Class: Crown::HTTPWrapper

Inherits:
Object
  • Object
show all
Defined in:
lib/crown/http-wrapper.rb

Overview

------------------------------------------------------------------- # HTTPWrapper ------------------------------------------------------------------- #

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(address, port = 80, proxy_addr = nil, proxy_port = nil) ⇒ HTTPWrapper

------------------------------------------------------------------- # initialize ------------------------------------------------------------------- #



52
53
54
55
56
 
# File 'lib/crown/http-wrapper.rb', line 52

def initialize(address, port = 80, proxy_addr = nil, proxy_port = nil)
    @http = Net::HTTP.new(address, port, proxy_addr, proxy_port)
    @retry_limit = 3
    @retry_interval = 2.0
end

Instance Attribute Details

#retry_interval ⇒ Object

------------------------------------------------------------------- # accessor ------------------------------------------------------------------- #



47
48
49
 
# File 'lib/crown/http-wrapper.rb', line 47

def retry_interval
  @retry_interval
end

#retry_limit ⇒ Object

------------------------------------------------------------------- # accessor ------------------------------------------------------------------- #



47
48
49
 
# File 'lib/crown/http-wrapper.rb', line 47

def retry_limit
  @retry_limit
end

Class Method Details

.start(address, port = 80, proxy_addr = nil, proxy_port = nil, &block) ⇒ Object

------------------------------------------------------------------- # HTTPWrapper.start ------------------------------------------------------------------- #



61
62
63
 
# File 'lib/crown/http-wrapper.rb', line 61

def HTTPWrapper.start(address, port = 80, proxy_addr = nil, proxy_port = nil, &block)
    return HTTPWrapper.new(address, port, proxy_addr, proxy_port).start(&block)
end

Instance Method Details

#active? ⇒ Boolean

------------------------------------------------------------------- # active? ------------------------------------------------------------------- #

Returns:

  • (Boolean) 


125
126
127
 
# File 'lib/crown/http-wrapper.rb', line 125

def active?
    return @http.active?
end

#address ⇒ Object

------------------------------------------------------------------- # address ------------------------------------------------------------------- #



132
133
134
 
# File 'lib/crown/http-wrapper.rb', line 132

def address
    return @http.address
end

#finish ⇒ Object

------------------------------------------------------------------- # finish ------------------------------------------------------------------- #



174
175
176
177
 
# File 'lib/crown/http-wrapper.rb', line 174

def finish
    @http.finish
    return self
end

#get(path, header = nil) ⇒ Object

------------------------------------------------------------------- #

get

サーバの状況によって失敗する事があるので，最大で retry_limit 回 通信が成功するまで get() を試す．また，3xx 系のうち以下の 3 つの ステータスコードが返ってきた場合は，ロケーション・フィールド によって与えられた URI へ再度 GET を試みる．

  • 301: Moved Permanently
  • 302: Moved Temporarily
  • 303: See Other

------------------------------------------------------------------- #



79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
 
# File 'lib/crown/http-wrapper.rb', line 79

def get(path, header = nil)
    n = 0
    begin
        @http.start if (!@http.active?)
        response = @http.get(path, header)
        code = response.code.to_i
        while (code == 301 || code == 302 || code == 303)
            @http.finish if (@http.active?)
            
            # リダイレクト先へ接続

            uri = URI.parse(response['Location'])
            @http = Net::HTTP.new(uri.host, uri.port, @http.proxy_address, @http.proxy_port)
            path = String.new(uri.path)
            path.concat("?").concat(uri.query) if (uri.query != nil)
            
            @http.start
            response = @http.get(path, header)
            code = response.to_i
        end
        return response
    rescue Exception => e
        @http.finish if (@http.active?)
        if (n < @retry_limit)
            sleep(@retry_interval)
            n += 1
            retry
        end
        raise e
    end
end

#open_timeout ⇒ Object

------------------------------------------------------------------- # open_timeout ------------------------------------------------------------------- #



146
147
148
 
# File 'lib/crown/http-wrapper.rb', line 146

def open_timeout
    return @http.open_timeout
end

#open_timeout=(n) ⇒ Object

------------------------------------------------------------------- # open_timeout= ------------------------------------------------------------------- #



153
154
155
 
# File 'lib/crown/http-wrapper.rb', line 153

def open_timeout=(n)
    return @http.open_timeout = n
end

#port ⇒ Object

------------------------------------------------------------------- # port ------------------------------------------------------------------- #



139
140
141
 
# File 'lib/crown/http-wrapper.rb', line 139

def port
    return @http.port
end

#proxy? ⇒ Boolean

------------------------------------------------------------------- # proxy? ------------------------------------------------------------------- #

Returns:

  • (Boolean) 


182
183
184
 
# File 'lib/crown/http-wrapper.rb', line 182

def proxy?
    return @http.proxy?
end

#proxy_address ⇒ Object

------------------------------------------------------------------- # proxy_address ------------------------------------------------------------------- #



189
190
191
 
# File 'lib/crown/http-wrapper.rb', line 189

def proxy_address
    return @http.proxy_address
end

#proxy_port ⇒ Object

------------------------------------------------------------------- # proxy_port ------------------------------------------------------------------- #



196
197
198
 
# File 'lib/crown/http-wrapper.rb', line 196

def proxy_port
    return @http.proxy_port
end

#read_timeout ⇒ Object

------------------------------------------------------------------- # read_timeout ------------------------------------------------------------------- #



160
161
162
 
# File 'lib/crown/http-wrapper.rb', line 160

def read_timeout
    return @http.read_timeout
end

#read_timeout=(n) ⇒ Object

------------------------------------------------------------------- # read_timeout= ------------------------------------------------------------------- #



167
168
169
 
# File 'lib/crown/http-wrapper.rb', line 167

def read_timeout=(n)
    return @http.read_timeout = n
end

#start ⇒ Object

------------------------------------------------------------------- # start ------------------------------------------------------------------- #



113
114
115
116
117
118
119
120
 
# File 'lib/crown/http-wrapper.rb', line 113

def start
    @http.start
    if (block_given?)
        yield self
        @http.finish if (@http.active?)
    end
    return self
end