Sha256: 56dbb35d99a9d81541bab306858f466706f4cf42cb0ff0c097895ef7eacabab3
Contents?: true
Size: 1.63 KB
Versions: 22
Compression:
Stored size: 1.63 KB
Contents
module Bixby
class HttpChannel < Bixby::APIChannel
def initialize(uri)
@uri = uri
end
# Execute the given request
#
# @param [JsonRequest] json_request
#
# @return [JsonResponse] response
def execute(json_request)
execute_internal(json_request)
end
# Execute a download request
# NOTE: This method is only available on the HTTP Channel.
#
# @param [JsonRequest] json_request
# @param [Block] block
#
# @return [JsonResponse] response
def execute_download(json_request, &block)
execute_internal(json_request, &block)
end
private
# Execute the request, optionally passing a block to handle the response
#
# @param [JsonRequest] json_request
# @param [Block] block
#
# @return [JsonResponse] response
def execute_internal(json_request, &block)
if json_request.respond_to?(:headers) then
# always required for posting to API
json_request.headers["Content-Type"] = "application/json"
end
req = HTTPI::Request.new(:url => @uri, :body => json_request.to_wire)
# add in extra headers if we have a SignedJsonRequest (or anything which has additional headers)
if json_request.respond_to? :headers then
req.headers.merge!(json_request.headers)
end
if block then
# execute request with block
req.on_body(&block)
HTTPI.post(req)
return JsonResponse.new("success")
else
# execute normal req, and return parsed response
res = HTTPI.post(req).body
return JsonResponse.from_json(res)
end
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems