OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	08/12/2024 10:33:48 AM	rwxr-xr-x
📄 AnonymousCredentials.php	2.5 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 ApiHelperTrait.php	7.42 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 ArrayTrait.php	3.58 KB	08/12/2024 10:33:12 AM	rw-r--r--
📁 Batch	-	08/12/2024 10:33:46 AM	rwxr-xr-x
📄 Blob.php	2.11 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 CallTrait.php	1.12 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 ClientTrait.php	8.19 KB	08/12/2024 10:33:12 AM	rw-r--r--
📁 Compute	-	08/12/2024 10:36:16 AM	rwxr-xr-x
📄 ConcurrencyControlTrait.php	1.4 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 DebugInfoTrait.php	1.33 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 DetectProjectIdTrait.php	3.09 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 Duration.php	2.2 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 EmulatorTrait.php	2.73 KB	08/12/2024 10:33:12 AM	rw-r--r--
📁 Exception	-	08/12/2024 10:33:47 AM	rwxr-xr-x
📄 ExponentialBackoff.php	4.86 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 GeoPoint.php	6.21 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 GrpcRequestWrapper.php	4.76 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 GrpcTrait.php	9 KB	08/12/2024 10:33:12 AM	rw-r--r--
📁 Iam	-	08/12/2024 10:33:47 AM	rwxr-xr-x
📄 InsecureCredentialsWrapper.php	1018 bytes	08/12/2024 10:33:12 AM	rw-r--r--
📄 Int64.php	1.77 KB	08/12/2024 10:33:12 AM	rw-r--r--
📁 Iterator	-	08/12/2024 10:33:47 AM	rwxr-xr-x
📄 JsonTrait.php	2.21 KB	08/12/2024 10:33:12 AM	rw-r--r--
📁 Lock	-	08/12/2024 10:33:47 AM	rwxr-xr-x
📁 Logger	-	08/12/2024 10:33:47 AM	rwxr-xr-x
📁 LongRunning	-	08/12/2024 10:33:48 AM	rwxr-xr-x
📄 PhpArray.php	7.45 KB	08/12/2024 10:33:12 AM	rw-r--r--
📁 Report	-	08/12/2024 10:33:48 AM	rwxr-xr-x
📄 RequestBuilder.php	4.89 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 RequestHandler.php	4.33 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 RequestProcessorTrait.php	4.62 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 RequestWrapper.php	21.09 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 RequestWrapperTrait.php	7.3 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 RestTrait.php	4.87 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 Retry.php	3.45 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 RetryDeciderTrait.php	2.9 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 ServiceBuilder.php	16.89 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 SysvTrait.php	1.88 KB	08/12/2024 10:33:12 AM	rw-r--r--
📁 Testing	-	08/12/2024 10:34:55 AM	rwxr-xr-x
📄 TimeTrait.php	4.48 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 Timestamp.php	4.11 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 TimestampTrait.php	1.61 KB	08/12/2024 10:33:12 AM	rw-r--r--
📁 Upload	-	08/12/2024 10:33:48 AM	rwxr-xr-x
📄 UriTrait.php	1.85 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 ValidateTrait.php	2.34 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 ValueMapperTrait.php	1.79 KB	08/12/2024 10:33:12 AM	rw-r--r--
📄 WhitelistTrait.php	1.16 KB	08/12/2024 10:33:12 AM	rw-r--r--

Editing: RequestProcessorTrait.php

<?php
/**
 * Copyright 2024 Google Inc. All Rights Reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

namespace Google\Cloud\Core;

use Google\ApiCore\ServerStream;
use Google\Rpc\Code;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\Core\Exception\ServiceException;
use Google\ApiCore\OperationResponse;
use \Google\Protobuf\Internal\Message;
use Google\Rpc\RetryInfo;
use Google\Rpc\BadRequest;

/**
 * @internal
 * Encapsulates shared functionality of classes that need to send
 * and process requests and responses.
 */
trait RequestProcessorTrait
{
    /**
     * @var array Map of error metadata types to RPC wrappers.
     */
    private $metadataTypes = [
        'google.rpc.retryinfo-bin' => RetryInfo::class,
        'google.rpc.badrequest-bin' => BadRequest::class
    ];

/**
     * Serializes a gRPC response.
     *
     * @param mixed $response
     * @return \Generator|OperationResponse|array|null
     */
    private function handleResponse($response)
    {
        if ($response instanceof PagedListResponse) {
            $response = $response->getPage()->getResponseObject();
        }

if ($response instanceof Message) {
            return $this->serializer->encodeMessage($response);
        }

if ($response instanceof OperationResponse) {
            return $response;
        }

if ($response instanceof ServerStream) {
            return $this->handleStream($response);
        }

return null;
    }

/**
     * Handles a streaming response.
     *
     * @param ServerStream $response
     * @return \Generator|array|null
     * @throws Exception\ServiceException
     */
    private function handleStream(ServerStream $response)
    {
        try {
            foreach ($response->readAll() as $count => $result) {
                $res = $this->serializer->encodeMessage($result);
                yield $res;
            }
        } catch (\Exception $ex) {
            throw $this->convertToGoogleException($ex);
        }
    }

/**
     * Convert a ApiCore exception to a Google Exception.
     *
     * @param \Exception $ex
     * @return ServiceException
     */
    private function convertToGoogleException(\Exception $ex): ServiceException
    {
        switch ($ex->getCode()) {
            case Code::INVALID_ARGUMENT:
                $exception = Exception\BadRequestException::class;
                break;

case Code::NOT_FOUND:
            case Code::UNIMPLEMENTED:
                $exception = Exception\NotFoundException::class;
                break;

case Code::ALREADY_EXISTS:
                $exception = Exception\ConflictException::class;
                break;

case Code::FAILED_PRECONDITION:
                $exception = Exception\FailedPreconditionException::class;
                break;

case Code::UNKNOWN:
                $exception = Exception\ServerException::class;
                break;

case Code::INTERNAL:
                $exception = Exception\ServerException::class;
                break;

case Code::ABORTED:
                $exception = Exception\AbortedException::class;
                break;

case Code::DEADLINE_EXCEEDED:
                $exception = Exception\DeadlineExceededException::class;
                break;

default:
                $exception = Exception\ServiceException::class;
                break;
        }

$metadata = [];
        if (method_exists($ex, 'getMetadata') && $ex->getMetadata()) {
            foreach ($ex->getMetadata() as $type => $binaryValue) {
                if (!isset($this->metadataTypes[$type])) {
                    continue;
                }
                $metadataElement = new $this->metadataTypes[$type];
                $metadataElement->mergeFromString($binaryValue[0]);
                $metadata[] = $this->serializer->encodeMessage($metadataElement);
            }
        }

return new $exception($ex->getMessage(), $ex->getCode(), $ex, $metadata);
    }
}