Class: Io::Flow::V0::HttpClient::Request

Inherits:
Object
  • Object
show all
Defined in:
lib/flow_commerce/flow_api_v0_client.rb

Defined Under Namespace

Classes: PATCH

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(http_handler, base_uri, path) ⇒ Request

Returns a new instance of Request.



44036
44037
44038
44039
44040
44041
44042
44043
44044
44045
44046
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44036

def initialize(http_handler, base_uri, path)
  @http_handler = http_handler
  @base_uri = Preconditions.assert_class('base_uri', base_uri, URI)
  @path = Preconditions.assert_class('path', path, String)
  @full_uri = @base_uri.to_s + @path
  @params = nil
  @body = nil
  @auth = nil
  @headers = {}
  @header_keys_lower_case = []
end

Instance Attribute Details

#base_uri ⇒ Object (readonly)

Returns the value of attribute base_uri.



44034
44035
44036
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44034

def base_uri
  @base_uri
end

#full_uri ⇒ Object (readonly)

Returns the value of attribute full_uri.



44034
44035
44036
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44034

def full_uri
  @full_uri
end

#path ⇒ Object (readonly)

Returns the value of attribute path.



44034
44035
44036
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44034

def path
  @path
end

Instance Method Details

#delete(&block) ⇒ Object 



44094
44095
44096
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44094

def delete(&block)
  do_request(Net::HTTP::Delete, &block)
end

#do_request(klass) ⇒ Object 



44118
44119
44120
44121
44122
44123
44124
44125
44126
44127
44128
44129
44130
44131
44132
44133
44134
44135
44136
44137
44138
44139
44140
44141
44142
44143
44144
44145
44146
44147
44148
44149
44150
44151
44152
44153
44154
44155
44156
44157
44158
44159
44160
44161
44162
44163
44164
44165
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44118

def do_request(klass)
  Preconditions.assert_class('klass', klass, Class)

  uri = @full_uri.dup
  if q = to_query(@params)
    uri += "?%s" % q
  end

  request = klass.send(:new, uri)

  curl = ['curl']
  if klass != Net::HTTP::Get
    curl << "-X%s" % klass.name.split("::").last.upcase
  end

  if @body
    # DEBUG tmpfile = "/tmp/rest_client.tmp"
    # DEBUG File.open(tmpfile, "w") { |os| os << @body.to_s }
    # DEBUG curl << "-d@%s" % tmpfile
    request.body = @body
  end

  if @auth
    curl << "-u \"%s:%s\"" % [@auth.username, @auth.password]
    Preconditions.check_state(!@header_keys_lower_case.include?("authorization"),
                              "Cannot specify both an Authorization header and an auth instance")
    user_pass = "%s:%s" % [@auth.username, @auth.password]
    encoded = Base64.encode64(user_pass).to_s.split("\n").map(&:strip).join
    request.add_field("Authorization", "Basic %s" % encoded)
  end

  @headers.each { |key, value|
    curl <<  "-H \"%s: %s\"" % [key, value]
    request.add_field(key, value)
  }

  curl << "'%s%s'" % [@base_uri, path]
  # DEBUG puts curl.join(" ")

  raw_response = @http_handler.instance(@base_uri, request.path).execute(request)
  response = raw_response.to_s == "" ? nil : JSON.parse(raw_response)

  if block_given?
    yield response
  else
    response
  end
end

#get(&block) ⇒ Object 



44090
44091
44092
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44090

def get(&block)
  do_request(Net::HTTP::Get, &block)
end

#options(&block) ⇒ Object 



44098
44099
44100
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44098

def options(&block)
  do_request(Net::HTTP::Options, &block)
end

#patch(&block) ⇒ Object 



44114
44115
44116
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44114

def patch(&block)
  do_request(PATCH, &block)
end

#post(&block) ⇒ Object 



44102
44103
44104
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44102

def post(&block)
  do_request(Net::HTTP::Post, &block)
end

#put(&block) ⇒ Object 



44106
44107
44108
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44106

def put(&block)
  do_request(Net::HTTP::Put, &block)
end

#with_auth(auth) ⇒ Object 



44058
44059
44060
44061
44062
44063
44064
44065
44066
44067
44068
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44058

def with_auth(auth)
  Preconditions.assert_class('auth', auth, HttpClient::Authorization)
  Preconditions.check_state(@auth.nil?, "auth previously set")

  if auth.scheme.name == AuthScheme::BASIC.name
    @auth = auth
  else
    raise "Auth Scheme[#{auth.scheme.name}] not supported"
  end
  self
end

#with_body(body) ⇒ Object 



44084
44085
44086
44087
44088
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44084

def with_body(body)
  Preconditions.check_not_blank('body', body)
  @body = body
  self
end

#with_header(name, value) ⇒ Object 



44048
44049
44050
44051
44052
44053
44054
44055
44056
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44048

def with_header(name, value)
  Preconditions.check_not_blank('name', name, "Header name is required")
  Preconditions.check_not_blank('value', value, "Header value is required")
  Preconditions.check_state(!@headers.has_key?(name),
                            "Duplicate header named[%s]" % name)
  @headers[name] = value
  @header_keys_lower_case << name.downcase
  self
end

#with_json(json) ⇒ Object

Wrapper to set Content-Type header to application/json and set the provided json document as the body



44079
44080
44081
44082
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44079

def with_json(json)
  @headers['Content-Type'] ||= 'application/json; charset=UTF-8'
  with_body(json)
end

#with_query(params) ⇒ Object 



44070
44071
44072
44073
44074
44075
 
# File 'lib/flow_commerce/flow_api_v0_client.rb', line 44070

def with_query(params)
  Preconditions.assert_class('params', params, Hash)
  Preconditions.check_state(@params.nil?, "Already have query parameters")
  @params = params
  self
end