true, 'CopyObject' => true, 'CompleteMultipartUpload' => true]; /** @var callable */ private $errorParser; /** @var string */ private $exceptionClass; public function __construct(callable $parser, callable $errorParser, $exceptionClass = \DeliciousBrains\WP_Offload_Media\Aws3\Aws\Exception\AwsException::class) { $this->parser = $parser; $this->errorParser = $errorParser; $this->exceptionClass = $exceptionClass; } public function __invoke(\DeliciousBrains\WP_Offload_Media\Aws3\Aws\CommandInterface $command, \DeliciousBrains\WP_Offload_Media\Aws3\Psr\Http\Message\ResponseInterface $response) { if (200 === $response->getStatusCode() && isset(self::$ambiguousSuccesses[$command->getName()])) { $errorParser = $this->errorParser; $parsed = $errorParser($response); if (isset($parsed['code']) && isset($parsed['message'])) { throw new $this->exceptionClass($parsed['message'], $command, ['connection_error' => true]); } } $fn = $this->parser; return $fn($command, $response); } public function parseMemberFromStream(\DeliciousBrains\WP_Offload_Media\Aws3\Psr\Http\Message\StreamInterface $stream, \DeliciousBrains\WP_Offload_Media\Aws3\Aws\Api\StructureShape $member, $response) { return $this->parser->parseMemberFromStream($stream, $member, $response); } }