ByProjectKeyVariantsBulkPost.php

<?php
 
declare(strict_types=1);
namespace Commercetools\Api\Client\Resource;
 
use Commercetools\Api\Models\Variant\VariantBulkUpdateResponse;
use Commercetools\Api\Models\Variant\VariantBulkUpdateResponseModel;
use Commercetools\Base\JsonObject;
use Commercetools\Base\JsonObjectModel;
use Commercetools\Client\ApiRequest;
use Commercetools\Exception\ApiClientException;
use Commercetools\Exception\ApiServerException;
use Commercetools\Exception\ExceptionFactory;
use Commercetools\Exception\InvalidArgumentException;
use GuzzleHttp\ClientInterface;
use GuzzleHttp\Exception\ClientException;
use GuzzleHttp\Exception\RequestException;
use GuzzleHttp\Exception\ServerException;
use GuzzleHttp\Promise\PromiseInterface;
 
use Psr\Http\Message\ResponseInterface;
 
class ByProjectKeyVariantsBulkPost extends ApiRequest
{
    public function __construct(string $projectKey, $body = null, array $headers = [], ?ClientInterface $client = null)
    {
        $uri = str_replace(['{projectKey}'], [self::encodePathParam($projectKey)], '{projectKey}/variants/bulk');
        parent::__construct($client, 'POST', $uri, $headers, is_object($body) || is_array($body) ? json_encode($body) : $body);
    }
 
    public function mapFromResponse(?ResponseInterface $response, ?string $resultType = null)
    {
        if (is_null($response)) {
            return null;
        }
        if (is_null($resultType)) {
            switch ($response->getStatusCode()) {
                case '207':
                    $resultType = VariantBulkUpdateResponseModel::class;
 
                    break;
                default:
                    $resultType = JsonObjectModel::class;
 
                    break;
            }
        }
 
        return $resultType::of($this->responseData($response));
    }
 
    public function execute(array $options = [], ?string $resultType = null)
    {
        try {
            $response = $this->send($options);
        } catch (ServerException $e) {
            $response = $e->getResponse();
            $e = ExceptionFactory::createServerException($e, $this, $response, $this->mapFromResponse($response, $resultType));
            throw $e;
        } catch (ClientException $e) {
            $response = $e->getResponse();
            $e = ExceptionFactory::createClientException($e, $this, $response, $this->mapFromResponse($response, $resultType));
            throw $e;
        }
 
        return $this->mapFromResponse($response, $resultType);
    }
 
    public function executeAsync(array $options = [], ?string $resultType = null)
    {
        return $this->sendAsync($options)->then(
            function (ResponseInterface $response) use ($resultType) {
                return $this->mapFromResponse($response, $resultType);
            },
            function (RequestException $e) use ($resultType) {
                $response = $e->getResponse();
                if ($e instanceof ServerException) {
                    $e = ExceptionFactory::createServerException($e, $this, $response, $this->mapFromResponse($response, $resultType));
                }
                if ($e instanceof ClientException) {
                    $e = ExceptionFactory::createClientException($e, $this, $response, $this->mapFromResponse($response, $resultType));
                }
                throw $e;
            }
        );
    }
 
    public function withVersionControl($versionControl): ByProjectKeyVariantsBulkPost
    {
        return $this->withQueryParam('versionControl', $versionControl);
    }
}