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. }