blob: bd46582df2050895015af7025069b3ee5bdce37a (
plain)
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
|
<?php
namespace Aws;
use Aws\Api\Service;
/**
* Validates the required input parameters of commands are non empty
*
* @internal
*/
class InputValidationMiddleware
{
/** @var callable */
private $nextHandler;
/** @var array */
private $mandatoryAttributeList;
/** @var Service */
private $service;
/**
* Create a middleware wrapper function.
*
* @param Service $service
* @param array $mandatoryAttributeList
* @return callable */
public static function wrap(Service $service, $mandatoryAttributeList) {
if (!is_array($mandatoryAttributeList) ||
array_filter($mandatoryAttributeList, 'is_string') !== $mandatoryAttributeList
) {
throw new \InvalidArgumentException(
"The mandatory attribute list must be an array of strings"
);
}
return function (callable $handler) use ($service, $mandatoryAttributeList) {
return new self($handler, $service, $mandatoryAttributeList);
};
}
public function __construct(
callable $nextHandler,
Service $service,
$mandatoryAttributeList
) {
$this->service = $service;
$this->nextHandler = $nextHandler;
$this->mandatoryAttributeList = $mandatoryAttributeList;
}
public function __invoke(CommandInterface $cmd) {
$nextHandler = $this->nextHandler;
$op = $this->service->getOperation($cmd->getName())->toArray();
if (!empty($op['input']['shape'])) {
$service = $this->service->toArray();
if (!empty($input = $service['shapes'][$op['input']['shape']])) {
if (!empty($input['required'])) {
foreach ($input['required'] as $key => $member) {
if (in_array($member, $this->mandatoryAttributeList)) {
$argument = is_string($cmd[$member]) ? trim($cmd[$member]) : $cmd[$member];
if ($argument === '' || $argument === null) {
$commandName = $cmd->getName();
throw new \InvalidArgumentException(
"The {$commandName} operation requires non-empty parameter: {$member}"
);
}
}
}
}
}
}
return $nextHandler($cmd);
}
}
|
