| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346 |
- <?php
- /*
- * Copyright 2016 Google LLC
- * All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are
- * met:
- *
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above
- * copyright notice, this list of conditions and the following disclaimer
- * in the documentation and/or other materials provided with the
- * distribution.
- * * Neither the name of Google Inc. nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- */
- namespace Google\ApiCore;
- use Exception;
- use Google\Protobuf\Internal\RepeatedField;
- use Google\Rpc\Status;
- use GuzzleHttp\Exception\RequestException;
- use Google\ApiCore\Testing\MockStatus;
- use stdClass;
- /**
- * Represents an exception thrown during an RPC.
- */
- class ApiException extends Exception
- {
- private $status;
- private $metadata;
- private $basicMessage;
- private $decodedMetadataErrorInfo;
- /**
- * ApiException constructor.
- * @param string $message
- * @param int $code
- * @param string|null $status
- * @param array $optionalArgs {
- * @type Exception|null $previous
- * @type array|null $metadata
- * @type string|null $basicMessage
- * }
- */
- public function __construct(
- string $message,
- int $code,
- string $status = null,
- array $optionalArgs = []
- ) {
- $optionalArgs += [
- 'previous' => null,
- 'metadata' => null,
- 'basicMessage' => $message,
- ];
- parent::__construct($message, $code, $optionalArgs['previous']);
- $this->status = $status;
- $this->metadata = $optionalArgs['metadata'];
- $this->basicMessage = $optionalArgs['basicMessage'];
- if ($this->metadata) {
- $this->decodedMetadataErrorInfo = self::decodeMetadataErrorInfo($this->metadata);
- }
- }
- public function getStatus()
- {
- return $this->status;
- }
- /**
- * Returns null if metadata does not contain error info, or returns containsErrorInfo() array
- * if the metadata does contain error info.
- * @param array $metadata
- * @return array $details {
- * @type string|null $reason
- * @type string|null $domain
- * @type array|null $errorInfoMetadata
- * }
- */
- private static function decodeMetadataErrorInfo(array $metadata)
- {
- $details = [];
- // ApiExceptions created from RPC status have metadata that is an array of objects.
- if (is_object(reset($metadata))) {
- $metadataRpcStatus = Serializer::decodeAnyMessages($metadata);
- $details = self::containsErrorInfo($metadataRpcStatus);
- } elseif (self::containsErrorInfo($metadata)) {
- $details = self::containsErrorInfo($metadata);
- } else {
- // For GRPC-based responses, the $metadata needs to be decoded.
- $metadataGrpc = Serializer::decodeMetadata($metadata);
- $details = self::containsErrorInfo($metadataGrpc);
- }
- return $details;
- }
- /**
- * Returns the `reason` in ErrorInfo for an exception, or null if there is no ErrorInfo.
- * @return string|null $reason
- */
- public function getReason()
- {
- return ($this->decodedMetadataErrorInfo) ? $this->decodedMetadataErrorInfo['reason'] : null;
- }
- /**
- * Returns the `domain` in ErrorInfo for an exception, or null if there is no ErrorInfo.
- * @return string|null $domain
- */
- public function getDomain()
- {
- return ($this->decodedMetadataErrorInfo) ? $this->decodedMetadataErrorInfo['domain'] : null;
- }
- /**
- * Returns the `metadata` in ErrorInfo for an exception, or null if there is no ErrorInfo.
- * @return array|null $errorInfoMetadata
- */
- public function getErrorInfoMetadata()
- {
- return ($this->decodedMetadataErrorInfo) ? $this->decodedMetadataErrorInfo['errorInfoMetadata'] : null;
- }
- /**
- * @param stdClass $status
- * @return ApiException
- */
- public static function createFromStdClass(stdClass $status)
- {
- $metadata = property_exists($status, 'metadata') ? $status->metadata : null;
- return self::create(
- $status->details,
- $status->code,
- $metadata,
- Serializer::decodeMetadata((array) $metadata)
- );
- }
- /**
- * @param string $basicMessage
- * @param int $rpcCode
- * @param array|null $metadata
- * @param Exception $previous
- * @return ApiException
- */
- public static function createFromApiResponse(
- $basicMessage,
- $rpcCode,
- array $metadata = null,
- Exception $previous = null
- ) {
- return self::create(
- $basicMessage,
- $rpcCode,
- $metadata,
- Serializer::decodeMetadata((array) $metadata),
- $previous
- );
- }
- /**
- * For REST-based responses, the metadata does not need to be decoded.
- *
- * @param string $basicMessage
- * @param int $rpcCode
- * @param array|null $metadata
- * @param Exception $previous
- * @return ApiException
- */
- public static function createFromRestApiResponse(
- $basicMessage,
- $rpcCode,
- array $metadata = null,
- Exception $previous = null
- ) {
- return self::create(
- $basicMessage,
- $rpcCode,
- $metadata,
- is_null($metadata) ? [] : $metadata,
- $previous
- );
- }
- /**
- * Checks if decoded metadata includes errorInfo message.
- * If errorInfo is set, it will always contain `reason`, `domain`, and `metadata` keys.
- * @param array $decodedMetadata
- * @return array {
- * @type string $reason
- * @type string $domain
- * @type array $errorInfoMetadata
- * }
- */
- private static function containsErrorInfo(array $decodedMetadata)
- {
- if (empty($decodedMetadata)) {
- return [];
- }
- foreach ($decodedMetadata as $value) {
- $isErrorInfoArray = isset($value['reason']) && isset($value['domain']) && isset($value['metadata']);
- if ($isErrorInfoArray) {
- return [
- 'reason' => $value['reason'],
- 'domain' => $value['domain'],
- 'errorInfoMetadata' => $value['metadata'],
- ];
- }
- }
- return [];
- }
- /**
- * Construct an ApiException with a useful message, including decoded metadata.
- * If the decoded metadata includes an errorInfo message, then the domain, reason,
- * and metadata fields from that message are hoisted directly into the error.
- *
- * @param string $basicMessage
- * @param int $rpcCode
- * @param iterable|null $metadata
- * @param array $decodedMetadata
- * @param Exception|null $previous
- * @return ApiException
- */
- private static function create(
- string $basicMessage,
- int $rpcCode,
- $metadata,
- array $decodedMetadata,
- Exception $previous = null
- ) {
- $containsErrorInfo = self::containsErrorInfo($decodedMetadata);
- $rpcStatus = ApiStatus::statusFromRpcCode($rpcCode);
- $messageData = [
- 'message' => $basicMessage,
- 'code' => $rpcCode,
- 'status' => $rpcStatus,
- 'details' => $decodedMetadata
- ];
- if ($containsErrorInfo) {
- $messageData = array_merge($containsErrorInfo, $messageData);
- }
- $message = json_encode($messageData, JSON_PRETTY_PRINT);
- if ($metadata instanceof RepeatedField) {
- $metadata = iterator_to_array($metadata);
- }
- return new ApiException($message, $rpcCode, $rpcStatus, [
- 'previous' => $previous,
- 'metadata' => $metadata,
- 'basicMessage' => $basicMessage,
- ]);
- }
- /**
- * @param Status $status
- * @return ApiException
- */
- public static function createFromRpcStatus(Status $status)
- {
- return self::create(
- $status->getMessage(),
- $status->getCode(),
- $status->getDetails(),
- Serializer::decodeAnyMessages($status->getDetails())
- );
- }
- /**
- * Creates an ApiException from a GuzzleHttp RequestException.
- *
- * @param RequestException $ex
- * @param boolean $isStream
- * @return ApiException
- * @throws ValidationException
- */
- public static function createFromRequestException(RequestException $ex, bool $isStream = false)
- {
- $res = $ex->getResponse();
- $body = (string) $res->getBody();
- $decoded = json_decode($body, true);
- // A streaming response body will return one error in an array. Parse
- // that first (and only) error message, if provided.
- if ($isStream && isset($decoded[0])) {
- $decoded = $decoded[0];
- }
- if (isset($decoded['error']) && $decoded['error']) {
- $error = $decoded['error'];
- $basicMessage = $error['message'] ?? '';
- $code = isset($error['status'])
- ? ApiStatus::rpcCodeFromStatus($error['status'])
- : $ex->getCode();
- $metadata = $error['details'] ?? null;
- return static::createFromRestApiResponse($basicMessage, $code, $metadata);
- }
- // Use the RPC code instead of the HTTP Status Code.
- $code = ApiStatus::rpcCodeFromHttpStatusCode($res->getStatusCode());
- return static::createFromApiResponse($body, $code);
- }
- /**
- * @return null|string
- */
- public function getBasicMessage()
- {
- return $this->basicMessage;
- }
- /**
- * @return mixed[]
- */
- public function getMetadata()
- {
- return $this->metadata;
- }
- /**
- * String representation of ApiException
- * @return string
- */
- public function __toString()
- {
- return __CLASS__ . ": $this->message\n";
- }
- }
|