Class: EmmyExtends::EmHttpRequest::Adapter

Inherits:
Object
  • Object
show all
Includes:
EmmyHttp::Adapter
Defined in:
lib/emmy_extends/em_http_request/adapter.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#body ⇒ Object (readonly)

Returns the value of attribute body.



9
10
11
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 9

def body
  @body
end

#connection ⇒ Object (readonly)

Returns the value of attribute connection.



10
11
12
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 10

def connection
  @connection
end

#headers ⇒ Object (readonly)

Returns the value of attribute headers.



14
15
16
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 14

def headers
  @headers
end

#http_client ⇒ Object (readonly)

Returns the value of attribute http_client.



8
9
10
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 8

def http_client
  @http_client
end

#http_request ⇒ Object (readonly)

Returns the value of attribute http_request.



7
8
9
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 7

def http_request
  @http_request
end

#operation ⇒ Object (readonly)

Returns the value of attribute operation.



11
12
13
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 11

def operation
  @operation
end

#response ⇒ Object (readonly)

Returns the value of attribute response.



12
13
14
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 12

def response
  @response
end

#url ⇒ Object (readonly)

Returns the value of attribute url.



13
14
15
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 13

def url
  @url
end

Instance Method Details

#connection_options ⇒ Object 



117
118
119
120
121
122
123
124
125
126
127
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 117

def connection_options
  {
    connect_timeout: operation.request.timeouts.connect,
    inactivity_timeout: operation.request.timeouts.inactivity,
    ssl: (operation.request.ssl) ? {
      cert_chain_file: operation.request.ssl.cert_chain_file,
      verify_peer:     (operation.request.ssl.verify_peer == :peer),
      ssl_version:     operation.request.ssl.ssl_version
    } : {}
  }
end

#delegate=(operation) ⇒ Object

required for adapter



19
20
21
22
23
24
25
26
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 19

def delegate=(operation)
  @operation = operation
  prepare_url
  @headers = operation.request.headers.clone
  prepare_body
  setup_http_request
  setup_http_client
end

#encode_body(body) ⇒ Object 



140
141
142
143
144
145
146
147
148
149
150
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 140

def encode_body(body)
  return body if operation.request.headers["Content-Encoding"] != "gzip"
  wio = StringIO.new("w")
  begin
    w_gz = Zlib::GzipWriter.new(wio)
    w_gz.write(body)
    wio.string
  ensure
    w_gz.close
  end
end

#initialize_connection(conn) ⇒ Object 



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
109
110
111
112
113
114
115
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 84

def initialize_connection(conn)
  @connection = conn
  conn.extend EmHttpRequest::Connection
  @http_request.conn = conn
  @http_request.post_init

  conn.on :connect do
    http_request.connection_completed
  end

  conn.on :data do |chunk|
    http_request.receive_data chunk
  end

  conn.on :close do |reason=nil|
    http_request.unbind(reason)
  end

  # before connection_completed
  @http_request.finalize_request(@http_client)

  conn.pending_connect_timeout = http_request.connopts.connect_timeout
  conn.comm_inactivity_timeout = http_request.connopts.inactivity_timeout

  @body = ''
  #operation.connection = conn  # update connection handler
  operation.init!(operation, conn)

rescue EventMachine::ConnectionError => e
  EventMachine.next_tick { @http_client.close(e.message) }
  operation.error!("connection error", self)
end

#prepare_body ⇒ Object 



49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 49

def prepare_body
  raise "attribute `file` unsupported" if operation.request.file
  body, form, json, file = operation.request.body, operation.request.form, operation.request.json

  @body = if body
    raise "body cannot be hash" if body.is_a?(Hash)
    body_text = body.is_a?(Array) ? body.join : body.to_s
    body_text

  elsif form
    form_encoded = form.is_a?(String) ? form : URI.encode_www_form(form)
    # rfc3986
    body_text = form_encoded.gsub(/([!'()*]+)/m) { '%'+$1.unpack('H2'*$1.bytesize).join('%').upcase }

    headers['Content-Type'] = 'application/x-www-form-urlencoded'
    headers['Content-Length'] = body_text.bytesize
    body_text

  elsif json
    json_string = json.is_a?(String) ? json : (json.respond_to?(:to_json) ? json.to_json : JSON.dump(json))
    headers['Content-Type']   = 'application/json'
    headers['Content-Length'] = json_string.size
    json_string

  else
    headers['Content-Length'] = 0 if %w('POST PUT').include? operation.request.type
    '' # empty body
  end
end

#prepare_url ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 28

def prepare_url
  @url = operation.request.real_url
  raise 'relative url' if url.relative?

  @url.normalize!

  if path = operation.request.real_path
    raise 'path is not relative' unless path.relative?
    @url += path
  end
  @url.user     = operation.request.user if operation.request.user
  @url.password = operation.request.password if operation.request.password
  if operation.request.query
    if operation.request.query.is_a?(Hash)
      @url.query_values = operation.request.query
    else
      @url.query = operation.request.query.to_s
    end
  end
end

#request_options ⇒ Object 



129
130
131
132
133
134
135
136
137
138
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 129

def request_options
  {
    redirects: 5,
    keepalive: operation.request.keep_alive,
    path: url.path,
    query: url.query,
    body: encode_body(body),
    head: headers
  }
end

#setup_http_client ⇒ Object 



152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 152

def setup_http_client
  @http_client = begin
    type = operation.request.type.to_s.upcase # http method
    http_client_options = HttpClientOptions.new(url, request_options, type)
    EventMachine::HttpClient.new(@http_request, http_client_options).tap do |client|
      client.stream do |chunk|
        @body << chunk
      end

      client.headers do |response_header|
        @response = EmmyHttp::Response.new
        response.headers = http_client.response_header
        response.status  = status
        operation.head!(response, operation, connection)
      end

      client.callback do
        if @http_client.response_header && @http_client.response_header.status.zero?
          operation.error!("connection timed out", operation, connection)
        else
          response.body   = body
          operation.success!(response, operation, connection)
        end
      end

      client.errback do |c|
        operation.error!(client.error, operation, connection)
      end
    end
  end
end

#setup_http_request ⇒ Object 



184
185
186
187
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 184

def setup_http_request
  # return EventMachine::HttpConnection
  @http_request = EventMachine::HttpRequest.new(url, connection_options)
end

#status ⇒ Object 



189
190
191
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 189

def status
  (@http_client.error || @http_client.response_header.empty?) ? 0 : @http_client.response_header.status
end

#to_a ⇒ Object 



80
81
82
 
# File 'lib/emmy_extends/em_http_request/adapter.rb', line 80

def to_a
  ["tcp://#{url.host}:#{url.port || url.default_port}", EmmyMachine::Connection, method(:initialize_connection), self]
end