vendor/symfony/mercure/src/Publisher.php line 21

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Mercure Component project.
  5.  *
  6.  * (c) Kévin Dunglas <dunglas@gmail.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. declare(strict_types=1);
  14. namespace Symfony\Component\Mercure;
  16. use Symfony\Component\HttpClient\HttpClient;
  17. use Symfony\Component\Mercure\Internal\QueryBuilder;
  18. use Symfony\Component\Mercure\Jwt\TokenProviderInterface;
  19. use Symfony\Contracts\HttpClient\HttpClientInterface;
  21. trigger_deprecation('symfony/mercure', '0.5', 'Class "%s" is deprecated, use "%s" instead.', Publisher::class, Hub::class);
  23. /**
  24.  * Publishes an update to the hub.
  25.  *
  26.  * @author Kévin Dunglas <dunglas@gmail.com>
  27.  *
  28.  * @experimental
  29.  *
  30.  * @deprecated
  31.  */
  32. final class Publisher implements PublisherInterface
  33. {
  34.     private $hubUrl;
  35.     private $jwtProvider;
  36.     private $httpClient;
  38.     /**
  39.      * @param TokenProviderInterface|callable(Update $update):string $jwtProvider
  40.      */
  41.     public function __construct(string $hubUrl, $jwtProvider, HttpClientInterface $httpClient = null)
  42.     {
  43.         $this->hubUrl = $hubUrl;
  44.         $this->jwtProvider = $jwtProvider;
  45.         $this->httpClient = $httpClient ?? HttpClient::create();
  46.     }
  48.     public function __invoke(Update $update): string
  49.     {
  50.         $postData = [
  51.             'topic' => $update->getTopics(),
  52.             'data' => $update->getData(),
  53.             'private' => $update->isPrivate() ? 'on' : null,
  54.             'id' => $update->getId(),
  55.             'type' => $update->getType(),
  56.             'retry' => $update->getRetry(),
  57.         ];
  59.         if ($this->jwtProvider instanceof TokenProviderInterface) {
  60.             $jwt = $this->jwtProvider->getJwt();
  61.         } else {
  62.             $jwt = ($this->jwtProvider)($update);
  63.         }
  64.         $this->validateJwt($jwt);
  66.         return $this->httpClient->request('POST', $this->hubUrl, [
  67.             'auth_bearer' => $jwt,
  68.             'body' => QueryBuilder::build($postData),
  69.         ])->getContent();
  70.     }
  72.     /**
  73.      * Regex ported from Windows Azure Active Directory IdentityModel Extensions for .Net.
  74.      *
  75.      * @throws Exception\InvalidArgumentException
  76.      *
  77.      * @license MIT
  78.      * @copyright Copyright (c) Microsoft Corporation
  79.      *
  80.      * @see https://github.com/AzureAD/azure-activedirectory-identitymodel-extensions-for-dotnet/blob/6e7a53e241e4566998d3bf365f03acd0da699a31/src/Microsoft.IdentityModel.JsonWebTokens/JwtConstants.cs#L58
  81.      */
  82.     private function validateJwt(string $jwt): void
  83.     {
  84.         if (!preg_match('/^[A-Za-z0-9-_]+\.[A-Za-z0-9-_]+\.[A-Za-z0-9-_]*$/', $jwt)) {
  85.             throw new Exception\InvalidArgumentException('The provided JWT is not valid.');
  86.         }
  87.     }
  88. }