lib/internal/Magento/Framework/Webapi/Backpressure/BackpressureContextFactory.php - 2.4-develop - githubmirror/magento2

lib/internal/Magento/Framework/Webapi/Backpressure/BackpressureContextFactory.php

75 строк2 KB

Alexandra Zota

ACP2E-4019: CE copyright updates for 2.4.9-beta1

22 окт 2025, 17:47

22 окт 2025, 17:471b769b7

<?php
/**
 * Copyright 2021 Adobe
 * All Rights Reserved.
 */

declare(strict_types=1);

namespace Magento\Framework\Webapi\Backpressure;

use Magento\Framework\App\Backpressure\ContextInterface;
use Magento\Framework\App\Backpressure\IdentityProviderInterface;
use Magento\Framework\App\RequestInterface;

/**
 * Creates backpressure context for a request
 */
class BackpressureContextFactory
{
    /**
     * @var RequestInterface
     */
    private RequestInterface $request;

    /**
     * @var IdentityProviderInterface
     */
    private IdentityProviderInterface $identityProvider;

    /**
     * @var BackpressureRequestTypeExtractorInterface
     */
    private BackpressureRequestTypeExtractorInterface $extractor;

    /**
     * @param RequestInterface $request
     * @param IdentityProviderInterface $identityProvider
     * @param BackpressureRequestTypeExtractorInterface $extractor
     */
    public function __construct(
        RequestInterface $request,
        IdentityProviderInterface $identityProvider,
        BackpressureRequestTypeExtractorInterface $extractor
    ) {
        $this->request = $request;
        $this->identityProvider = $identityProvider;
        $this->extractor = $extractor;
    }

    /**
     * Create context if possible for current request
     *
     * @param string $service Service class
     * @param string $method Service method
     * @param string $endpoint Endpoint
     * @return ContextInterface|null
     */
    public function create(string $service, string $method, string $endpoint): ?ContextInterface
    {
        $typeId = $this->extractor->extract($service, $method, $endpoint);
        if ($typeId === null) {
            return null;
        }

        return new RestContext(
            $this->request,
            $this->identityProvider->fetchIdentity(),
            $this->identityProvider->fetchIdentityType(),
            $typeId,
            $service,
            $method,
            $endpoint
        );
    }
}