-
Notifications
You must be signed in to change notification settings - Fork 52
/
OrdersSDK.php
232 lines (203 loc) · 9.69 KB
/
OrdersSDK.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
<?php
declare(strict_types=1);
namespace AmazonPHP\SellingPartner\Api\ShipmentApi;
use AmazonPHP\SellingPartner\AccessToken;
use AmazonPHP\SellingPartner\Configuration;
use AmazonPHP\SellingPartner\Exception\ApiException;
use AmazonPHP\SellingPartner\Exception\InvalidArgumentException;
use AmazonPHP\SellingPartner\HttpFactory;
use AmazonPHP\SellingPartner\HttpSignatureHeaders;
use AmazonPHP\SellingPartner\ObjectSerializer;
use Psr\Http\Client\ClientExceptionInterface;
use Psr\Http\Client\ClientInterface;
use Psr\Http\Message\RequestInterface;
use Psr\Log\LoggerInterface;
/**
* Selling Partner API for Orders.
*
* Use the Orders Selling Partner API to programmatically retrieve order information. With this API, you can develop fast, flexible, and custom applications to manage order synchronization, perform order research, and create demand-based decision support tools. _Note:_ For the JP, AU, and SG marketplaces, the Orders API supports orders from 2016 onward. For all other marketplaces, the Orders API supports orders for the last two years (orders older than this don't show up in the response).
*
* The version of the OpenAPI document: v0
*
* This class was auto-generated by https://openapi-generator.tech
* Do not change it, it will be overwritten with next execution of /bin/generate.sh
*/
final class OrdersSDK implements OrdersSDKInterface
{
public function __construct(private readonly ClientInterface $client, private readonly HttpFactory $httpFactory, private readonly Configuration $configuration, private readonly LoggerInterface $logger)
{
}
/**
* Operation updateShipmentStatus.
*
* @param string $order_id An Amazon-defined order identifier, in 3-7-7 format. (required)
* @param \AmazonPHP\SellingPartner\Model\Orders\UpdateShipmentStatusRequest $payload The request body for the `updateShipmentStatus` operation. (required)
*
* @throws ApiException on non-2xx response
* @throws InvalidArgumentException
*/
public function updateShipmentStatus(AccessToken $accessToken, string $region, string $order_id, \AmazonPHP\SellingPartner\Model\Orders\UpdateShipmentStatusRequest $payload)
{
$request = $this->updateShipmentStatusRequest($accessToken, $region, $order_id, $payload);
$this->configuration->extensions()->preRequest('Orders', 'updateShipmentStatus', $request);
try {
$correlationId = $this->configuration->idGenerator()->generate();
$sanitizedRequest = $request;
foreach ($this->configuration->loggingSkipHeaders() as $sensitiveHeader) {
$sanitizedRequest = $sanitizedRequest->withoutHeader($sensitiveHeader);
}
if ($this->configuration->loggingEnabled('Orders', 'updateShipmentStatus')) {
$this->logger->log(
$this->configuration->logLevel('Orders', 'updateShipmentStatus'),
'Amazon Selling Partner API pre request',
[
'api' => 'Orders',
'operation' => 'updateShipmentStatus',
'request_correlation_id' => $correlationId,
'request_body' => (string) $sanitizedRequest->getBody(),
'request_headers' => $sanitizedRequest->getHeaders(),
'request_uri' => (string) $sanitizedRequest->getUri(),
]
);
}
$response = $this->client->sendRequest($request);
$this->configuration->extensions()->postRequest('Orders', 'updateShipmentStatus', $request, $response);
if ($this->configuration->loggingEnabled('Orders', 'updateShipmentStatus')) {
$sanitizedResponse = $response;
foreach ($this->configuration->loggingSkipHeaders() as $sensitiveHeader) {
$sanitizedResponse = $sanitizedResponse->withoutHeader($sensitiveHeader);
}
$this->logger->log(
$this->configuration->logLevel('Orders', 'updateShipmentStatus'),
'Amazon Selling Partner API post request',
[
'api' => 'Orders',
'operation' => 'updateShipmentStatus',
'response_correlation_id' => $correlationId,
'response_body' => (string) $sanitizedResponse->getBody(),
'response_headers' => $sanitizedResponse->getHeaders(),
'response_status_code' => $sanitizedResponse->getStatusCode(),
'request_uri' => (string) $sanitizedRequest->getUri(),
'request_body' => (string) $sanitizedRequest->getBody(),
]
);
}
} catch (ClientExceptionInterface $e) {
throw new ApiException(
"[{$e->getCode()}] {$e->getMessage()}",
(int) $e->getCode(),
null,
null,
$e
);
}
$statusCode = $response->getStatusCode();
if ($statusCode < 200 || $statusCode > 299) {
throw new ApiException(
\sprintf(
'[%d] Error connecting to the API (%s)',
$statusCode,
(string) $request->getUri()
),
$statusCode,
$response->getHeaders(),
(string) $response->getBody()
);
}
return null;
}
/**
* Create request for operation 'updateShipmentStatus'.
*
* @param string $order_id An Amazon-defined order identifier, in 3-7-7 format. (required)
* @param \AmazonPHP\SellingPartner\Model\Orders\UpdateShipmentStatusRequest $payload The request body for the `updateShipmentStatus` operation. (required)
*
* @throws \AmazonPHP\SellingPartner\Exception\InvalidArgumentException
*/
public function updateShipmentStatusRequest(AccessToken $accessToken, string $region, string $order_id, \AmazonPHP\SellingPartner\Model\Orders\UpdateShipmentStatusRequest $payload) : RequestInterface
{
// verify the required parameter 'order_id' is set
if ($order_id === null || (\is_array($order_id) && \count($order_id) === 0)) {
throw new InvalidArgumentException(
'Missing the required parameter $order_id when calling updateShipmentStatus'
);
}
// verify the required parameter 'payload' is set
if ($payload === null || (\is_array($payload) && \count($payload) === 0)) {
throw new InvalidArgumentException(
'Missing the required parameter $payload when calling updateShipmentStatus'
);
}
$resourcePath = '/orders/v0/orders/{orderId}/shipment';
$formParams = [];
$queryParams = [];
$headerParams = [];
$multipart = false;
$query = '';
if (\count($queryParams)) {
$query = \http_build_query($queryParams);
}
// path params
if ($order_id !== null) {
$resourcePath = \str_replace(
'{' . 'orderId' . '}',
ObjectSerializer::toPathValue($order_id),
$resourcePath
);
}
if ($multipart) {
$headers = [
'accept' => ['application/json'],
'host' => [$this->configuration->apiHost($region)],
'user-agent' => [$this->configuration->userAgent()],
];
} else {
$headers = [
'content-type' => ['application/json'],
'accept' => ['application/json'],
'host' => [$this->configuration->apiHost($region)],
'user-agent' => [$this->configuration->userAgent()],
];
}
$request = $this->httpFactory->createRequest(
'POST',
$this->configuration->apiURL($region) . $resourcePath . '?' . $query
);
// for model (json/xml)
if (isset($payload)) {
if ($headers['content-type'] === ['application/json']) {
$httpBody = \json_encode(ObjectSerializer::sanitizeForSerialization($payload), JSON_THROW_ON_ERROR);
} else {
$httpBody = $payload;
}
$request = $request->withBody($this->httpFactory->createStreamFromString($httpBody));
} elseif (\count($formParams) > 0) {
if ($multipart) {
$multipartContents = [];
foreach ($formParams as $formParamName => $formParamValue) {
$formParamValueItems = \is_array($formParamValue) ? $formParamValue : [$formParamValue];
foreach ($formParamValueItems as $formParamValueItem) {
$multipartContents[] = [
'name' => $formParamName,
'contents' => $formParamValueItem,
];
}
}
$request = $request->withParsedBody($multipartContents);
} elseif ($headers['content-type'] === ['application/json']) {
$request = $request->withBody($this->httpFactory->createStreamFromString(\json_encode($formParams, JSON_THROW_ON_ERROR)));
} else {
$request = $request->withParsedBody($formParams);
}
}
foreach (\array_merge($headerParams, $headers) as $name => $header) {
$request = $request->withHeader($name, $header);
}
return HttpSignatureHeaders::forConfig(
$this->configuration,
$accessToken,
$region,
$request
);
}
}