rdt-for-vdf

Author: sanjjaymahalingam

lib/muffin_man/sp_api_client.rb

@@ -9,7 +9,7 @@ class SpApiClient
     attr_reader :refresh_token, :client_id, :client_secret, :sandbox, :config,
                 :region, :request_type, :local_var_path, :query_params,
                 :request_body, :scope, :access_token_cache_key, :credentials,
-                :pii_data_elements
+                :pii_data_elements, :requires_rdt
 
     ACCESS_TOKEN_URL = "https://api.amazon.com/auth/o2/token".freeze
     SERVICE_NAME = "execute-api".freeze
@@ -31,6 +31,7 @@ def initialize(credentials, sandbox = false)
       @sandbox = sandbox
       @credentials = credentials
       @pii_data_elements = []
+      @requires_rdt = false
       Typhoeus::Config.user_agent = ""
       @config = MuffinMan.configuration
     end
@@ -132,7 +133,7 @@ def request_grantless_access_token
     end
 
     def headers
-      if requires_rdt_token_for_pii?
+      if requires_rdt_token_for_pii? || requires_rdt
         access_token = retrieve_rdt_access_token || retrieve_lwa_access_token
       else
         access_token = scope ? retrieve_grantless_access_token : retrieve_lwa_access_token

lib/muffin_man/vendor_direct_fulfillment_inventory/v1.rb

@@ -3,11 +3,13 @@
 module MuffinMan
   module VendorDirectFulfillmentInventory
     class V1 < SpApiClient
-      def submit_inventory_update(warehouse_id, selling_party, is_full_update, items)
+      def submit_inventory_update(warehouse_id, selling_party_id, is_full_update, items)
         @local_var_path = "/vendor/directFulfillment/inventory/v1/warehouses/#{warehouse_id}/items"
         @request_body = {
           "inventory" => {
-            "sellingParty" => selling_party,
+            "sellingParty" => {
+              "partyId" => selling_party_id
+            },
             "isFullUpdate" => is_full_update,
             "items" => items
           }

lib/muffin_man/vendor_direct_fulfillment_orders/v20211228.rb

@@ -20,12 +20,14 @@ def get_orders(created_after, created_before, params = {})
         }
         @query_params.merge!(params.slice(*GET_ORDERS_PARAMS))
         @request_type = "GET"
+        @requires_rdt = true
         call_api
       end
 
       def get_order(purchase_order_number)
         @local_var_path = "/vendor/directFulfillment/orders/2021-12-28/purchaseOrders/#{purchase_order_number}"
         @request_type = "GET"
+        @requires_rdt = true
         call_api
       end
 

lib/muffin_man/vendor_direct_fulfillment_shipping/v20211228.rb

@@ -31,16 +31,17 @@ def submit_shipping_label_request(shipping_label_requests)
       def get_shipping_label(purchase_order_number)
         @local_var_path = "/vendor/directFulfillment/shipping/2021-12-28/shippingLabels/#{purchase_order_number}"
         @request_type = "GET"
+        @requires_rdt = true
         call_api
       end
 
-      def create_shipping_labels(purchase_order_number, selling_party, ship_from_party, containers: nil)
+      def create_shipping_labels(purchase_order_number, selling_party, ship_from_party, containers)
         @local_var_path = "/vendor/directFulfillment/shipping/2021-12-28/shippingLabels/#{purchase_order_number}"
         @request_body = {
           "sellingParty" => selling_party,
-          "shipFromParty" => ship_from_party
+          "shipFromParty" => ship_from_party,
+          "containers" => containers
         }
-        @request_body["containers"] = containers if containers
         @request_type = "POST"
         call_api
       end
@@ -67,12 +68,14 @@ def get_customer_invoices(created_after, created_before, params = {})
         }
         @query_params.merge!(params.slice(*VENDOR_DIRECT_FULFILLMENT_SHIPPING_PARAMS))
         @request_type = "GET"
+        @requires_rdt = true
         call_api
       end
 
       def get_customer_invoice(purchase_order_number)
         @local_var_path = "/vendor/directFulfillment/shipping/2021-12-28/customerInvoices/#{purchase_order_number}"
         @request_type = "GET"
+        @requires_rdt = true
         call_api
       end
 
@@ -84,12 +87,14 @@ def get_packing_slips(created_after, created_before, params = {})
         }
         @query_params.merge!(params.slice(*VENDOR_DIRECT_FULFILLMENT_SHIPPING_PARAMS))
         @request_type = "GET"
+        @requires_rdt = true
         call_api
       end
 
       def get_packing_slip(purchase_order_number)
         @local_var_path = "/vendor/directFulfillment/shipping/2021-12-28/packingSlips/#{purchase_order_number}"
         @request_type = "GET"
+        @requires_rdt = true
         call_api
       end
     end