Sha256: a0bf8eadcf7601d6eb36ce65fe90374bf5a396d95202c39b4fb615b0a2a74aa0
Contents?: true
Size: 1.69 KB
Versions: 7
Compression:
Stored size: 1.69 KB
Contents
require "akamai_ccu/client"
require "akamai_ccu/endpoint"
require "akamai_ccu/signer"
require "akamai_ccu/response"
module AkamaiCCU
class Wrapper
class << self
attr_reader :secret, :client
attr_accessor :logger
def setup(secret, client_klass = Client, logger = Logger.new(nil))
@secret ||= secret
@client ||= client_klass.new(host: @secret.host)
@logger ||= logger
end
Endpoint::Network.constants.each do |network|
Endpoint::Action.constants.each do |action|
Endpoint::Mode.constants.each do |mode|
endpoint = Endpoint.by_constants(network, action, mode)
define_method(endpoint.to_s) do |objects, headers = [], &block|
wrapper = new(endpoint: endpoint, headers: headers)
block.call(wrapper) if block
wrapper.call(objects)
end
end
end
end
end
attr_accessor :signer_klass, :response_klass
def initialize(endpoint:, headers: [], signer_klass: Signer, response_klass: Response)
@endpoint = endpoint
@signer_klass = signer_klass
@response_klass = response_klass
@headers = headers
end
def call(objects)
response = self.class.client.call(path: @endpoint.path) do |request|
request.body = { objects: objects }.to_json
@signer_klass.new(request, self.class.secret.touch, @headers).call!
self.class.logger.debug { "request: uri=#{request.path}; body=#{request.body}; authorization=#{request["Authorization"]}" }
end
self.class.logger.debug { "response: inspect=#{response.inspect}; body=#{response.body}" }
response_klass.factory(response.body)
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems