mirror of
https://github.com/dkam/paapi.git
synced 2025-12-28 15:14:52 +00:00
Migrate aws mixing into the client class
This commit is contained in:
@@ -1,6 +1,5 @@
|
|||||||
require 'paapi/version'
|
require 'paapi/version'
|
||||||
|
|
||||||
require 'paapi/aws_request'
|
|
||||||
require 'paapi/client'
|
require 'paapi/client'
|
||||||
require 'paapi/item'
|
require 'paapi/item'
|
||||||
require 'paapi/response'
|
require 'paapi/response'
|
||||||
|
|||||||
@@ -1,47 +1 @@
|
|||||||
require 'http'
|
|
||||||
require 'aws-sigv4'
|
|
||||||
|
|
||||||
# https://webservices.amazon.com/paapi5/documentation/common-request-parameters.html
|
|
||||||
module Paapi
|
|
||||||
module AwsRequest
|
|
||||||
def do_request(op:, payload:)
|
|
||||||
raise ArguemntError unless Paapi::OPERATIONS.keys.include?(op)
|
|
||||||
|
|
||||||
operation = OPERATIONS[op]
|
|
||||||
|
|
||||||
headers = {
|
|
||||||
'X-Amz-Target' => "com.amazon.paapi5.v1.ProductAdvertisingAPIv1.#{operation.target_name}",
|
|
||||||
'Content-Encoding' => 'amz-1.0',
|
|
||||||
}
|
|
||||||
|
|
||||||
default_payload = {
|
|
||||||
'PartnerTag' => partner_tag,
|
|
||||||
'PartnerType' => partner_type,
|
|
||||||
'Marketplace' => marketplace.site
|
|
||||||
}
|
|
||||||
|
|
||||||
payload = default_payload.merge(payload)
|
|
||||||
|
|
||||||
endpoint = "https://#{marketplace.host}/paapi5/#{operation.endpoint_suffix}"
|
|
||||||
|
|
||||||
signer = Aws::Sigv4::Signer.new(
|
|
||||||
service: operation.service,
|
|
||||||
region: marketplace.region,
|
|
||||||
access_key_id: access_key,
|
|
||||||
secret_access_key: secret_key,
|
|
||||||
http_method: operation.http_method,
|
|
||||||
endpoint: marketplace.host
|
|
||||||
)
|
|
||||||
|
|
||||||
signature = signer.sign_request(http_method: operation.http_method, url: endpoint, headers: headers, body: payload.to_json)
|
|
||||||
|
|
||||||
headers['Host'] = marketplace.host
|
|
||||||
headers['X-Amz-Date'] = signature.headers['x-amz-date']
|
|
||||||
headers['X-Amz-Content-Sha256']= signature.headers['x-amz-content-sha256']
|
|
||||||
headers['Authorization'] = signature.headers['authorization']
|
|
||||||
headers['Content-Type'] = 'application/json; charset=utf-8'
|
|
||||||
|
|
||||||
HTTP.headers(headers).post(endpoint, json: payload )
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
@@ -1,8 +1,9 @@
|
|||||||
require 'http'
|
require 'http'
|
||||||
|
require 'aws-sigv4'
|
||||||
|
|
||||||
module Paapi
|
module Paapi
|
||||||
class Client
|
class Client
|
||||||
include AwsRequest
|
|
||||||
attr_accessor :partner_tag, :marketplace, :resources
|
attr_accessor :partner_tag, :marketplace, :resources
|
||||||
attr_reader :partner_type, :access_key, :secret_key, :market
|
attr_reader :partner_type, :access_key, :secret_key, :market
|
||||||
|
|
||||||
@@ -34,20 +35,12 @@ module Paapi
|
|||||||
|
|
||||||
def get_items(item_ids:, **options)
|
def get_items(item_ids:, **options)
|
||||||
payload = { ItemIds: Array(item_ids), Resources: @resources }
|
payload = { ItemIds: Array(item_ids), Resources: @resources }
|
||||||
|
request(op: :get_items, payload: payload)
|
||||||
res = do_request(op: :get_items, payload: payload)
|
|
||||||
|
|
||||||
# Errors, ItemResults -> Items -> Item
|
|
||||||
return Response.new(res)
|
|
||||||
end
|
end
|
||||||
|
|
||||||
def get_variations(asin:, **options )
|
def get_variations(asin:, **options )
|
||||||
payload = { ASIN: asin, Resources: @resources }
|
payload = { ASIN: asin, Resources: @resources }
|
||||||
|
request(op: :get_variations, payload: payload)
|
||||||
res = do_request(op: :get_variations, payload: payload)
|
|
||||||
|
|
||||||
# Errors, VariationsResult->Items
|
|
||||||
Response.new(res)
|
|
||||||
end
|
end
|
||||||
|
|
||||||
# TODO: Currently we assume Keywords, but we need one of the follow: [Keywords Actor Artist Author Brand Title ]
|
# TODO: Currently we assume Keywords, but we need one of the follow: [Keywords Actor Artist Author Brand Title ]
|
||||||
@@ -58,18 +51,56 @@ module Paapi
|
|||||||
|
|
||||||
payload = { Keywords: keywords, Resources: @resources, ItemCount: 10, ItemPage: 1, SearchIndex: search_index }.merge(options)
|
payload = { Keywords: keywords, Resources: @resources, ItemCount: 10, ItemPage: 1, SearchIndex: search_index }.merge(options)
|
||||||
|
|
||||||
res = do_request(op: :search_items, payload: payload)
|
request(op: :search_items, payload: payload)
|
||||||
|
|
||||||
Response.new(res)
|
|
||||||
end
|
end
|
||||||
|
|
||||||
def get_browse_nodes(browse_node_ids:, **options)
|
def get_browse_nodes(browse_node_ids:, **options)
|
||||||
resources = ['BrowseNodes.Ancestor', 'BrowseNodes.Children']
|
|
||||||
payload = { BrowseNodeIds: Array(browse_node_ids), Resources: @resources }.merge(options)
|
payload = { BrowseNodeIds: Array(browse_node_ids), Resources: @resources }.merge(options)
|
||||||
|
request(op: :get_browse_nodes, payload: payload)
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def request(op:, payload:)
|
||||||
|
raise ArguemntError unless Paapi::OPERATIONS.keys.include?(op)
|
||||||
|
|
||||||
res = do_request(op: :get_browse_nodes, payload: payload)
|
operation = OPERATIONS[op]
|
||||||
|
|
||||||
Response.new(res)
|
headers = {
|
||||||
|
'X-Amz-Target' => "com.amazon.paapi5.v1.ProductAdvertisingAPIv1.#{operation.target_name}",
|
||||||
|
'Content-Encoding' => 'amz-1.0',
|
||||||
|
}
|
||||||
|
|
||||||
|
default_payload = {
|
||||||
|
'PartnerTag' => partner_tag,
|
||||||
|
'PartnerType' => partner_type,
|
||||||
|
'Marketplace' => marketplace.site
|
||||||
|
}
|
||||||
|
|
||||||
|
payload = default_payload.merge(payload)
|
||||||
|
|
||||||
|
endpoint = "https://#{marketplace.host}/paapi5/#{operation.endpoint_suffix}"
|
||||||
|
|
||||||
|
signer = Aws::Sigv4::Signer.new(
|
||||||
|
service: operation.service,
|
||||||
|
region: marketplace.region,
|
||||||
|
access_key_id: access_key,
|
||||||
|
secret_access_key: secret_key,
|
||||||
|
http_method: operation.http_method,
|
||||||
|
endpoint: marketplace.host
|
||||||
|
)
|
||||||
|
|
||||||
|
signature = signer.sign_request(http_method: operation.http_method, url: endpoint, headers: headers, body: payload.to_json)
|
||||||
|
|
||||||
|
headers['Host'] = marketplace.host
|
||||||
|
headers['X-Amz-Date'] = signature.headers['x-amz-date']
|
||||||
|
headers['X-Amz-Content-Sha256']= signature.headers['x-amz-content-sha256']
|
||||||
|
headers['Authorization'] = signature.headers['authorization']
|
||||||
|
headers['Content-Type'] = 'application/json; charset=utf-8'
|
||||||
|
|
||||||
|
Response.new( HTTP.headers(headers).post(endpoint, json: payload ) )
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user