Document

Operation	:	Linux server.tradinguniversity.rs 3.10.0-1160.119.1.vz7.224.4 #1 SMP Mon Sep 30 15:36:27 MSK 2024 x86_64
Software	:	Apache
Server IP	:	68.66.251.59 \| Your IP: 216.73.216.158
Domains	:	4 Domain
Permission	:	[ drwxr-xr-x ]

/ home / tradinguniversit / public_html / vendor / minishlink / web-push / src /

Web File Manager

主页上传上传 V2 命令行

WebPush.php

<?php

declare(strict_types=1);

/*
 * This file is part of the WebPush library.
 *
 * (c) Louis Lagrange <lagrange.louis@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Minishlink\WebPush;

use Base64Url\Base64Url;
use GuzzleHttp\Client;
use GuzzleHttp\Pool;
use GuzzleHttp\Exception\ConnectException;
use GuzzleHttp\Exception\RequestException;
use GuzzleHttp\Psr7\Request;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

class WebPush
{
    protected Client $client;
    protected array $auth;

/**
     * @var null|array Array of array of Notifications
     */
    protected ?array $notifications = null;

/**
     * @var array Default options: TTL, urgency, topic, batchSize, requestConcurrency
     */
    protected array $defaultOptions;

/**
     * @var int Automatic padding of payloads, if disabled, trade security for bandwidth
     */
    protected int $automaticPadding = Encryption::MAX_COMPATIBILITY_PAYLOAD_LENGTH;

/**
     * @var bool Reuse VAPID headers in the same flush session to improve performance
     */
    protected bool $reuseVAPIDHeaders = false;

/**
     * @var array Dictionary for VAPID headers cache
     */
    protected array $vapidHeaders = [];

/**
     * WebPush constructor.
     *
     * @param array    $auth           Some servers need authentication
     * @param array    $defaultOptions TTL, urgency, topic, batchSize, requestConcurrency
     * @param int|null $timeout        Timeout of POST request
     *
     * @throws \ErrorException
     */
    public function __construct(array $auth = [], array $defaultOptions = [], ?int $timeout = 30, array $clientOptions = [])
    {
        Utils::checkRequirement();

if (isset($auth['VAPID'])) {
            $auth['VAPID'] = VAPID::validate($auth['VAPID']);
        }

$this->auth = $auth;

$this->setDefaultOptions($defaultOptions);

if (!array_key_exists('timeout', $clientOptions) && isset($timeout)) {
            $clientOptions['timeout'] = $timeout;
        }
        $this->client = new Client($clientOptions);
    }

/**
     * Queue a notification. Will be sent when flush() is called.
     *
     * @param string|null $payload If you want to send an array or object, json_encode it
     * @param array $options Array with several options tied to this notification. If not set, will use the default options that you can set in the WebPush object
     * @param array $auth Use this auth details instead of what you provided when creating WebPush
     * @throws \ErrorException
     */
    public function queueNotification(SubscriptionInterface $subscription, ?string $payload = null, array $options = [], array $auth = []): void
    {
        if (isset($payload)) {
            if (Utils::safeStrlen($payload) > Encryption::MAX_PAYLOAD_LENGTH) {
                throw new \ErrorException('Size of payload must not be greater than '.Encryption::MAX_PAYLOAD_LENGTH.' octets.');
            }

$contentEncoding = $subscription->getContentEncoding();
            if (!$contentEncoding) {
                throw new \ErrorException('Subscription should have a content encoding');
            }

$payload = Encryption::padPayload($payload, $this->automaticPadding, $contentEncoding);
        }

if (array_key_exists('VAPID', $auth)) {
            $auth['VAPID'] = VAPID::validate($auth['VAPID']);
        }

$this->notifications[] = new Notification($subscription, $payload, $options, $auth);
    }

/**
     * @param string|null $payload If you want to send an array or object, json_encode it
     * @param array $options Array with several options tied to this notification. If not set, will use the default options that you can set in the WebPush object
     * @param array $auth Use this auth details instead of what you provided when creating WebPush
     * @throws \ErrorException
     */
    public function sendOneNotification(SubscriptionInterface $subscription, ?string $payload = null, array $options = [], array $auth = []): MessageSentReport
    {
        $this->queueNotification($subscription, $payload, $options, $auth);
        return $this->flush()->current();
    }

/**
     * Flush notifications. Triggers the requests.
     *
     * @param null|int $batchSize Defaults the value defined in defaultOptions during instantiation (which defaults to 1000).
     *
     * @return \Generator
     * @throws \ErrorException
     */
    public function flush(?int $batchSize = null): \Generator
    {
        if (empty($this->notifications)) {
            yield from [];
            return;
        }

if (null === $batchSize) {
            $batchSize = $this->defaultOptions['batchSize'];
        }

$batches = array_chunk($this->notifications, $batchSize);

// reset queue
        $this->notifications = [];

foreach ($batches as $batch) {
            // for each endpoint server type
            $requests = $this->prepare($batch);

$promises = [];

foreach ($requests as $request) {
                $promises[] = $this->client->sendAsync($request)
                    ->then(function ($response) use ($request) {
                        /** @var ResponseInterface $response **/
                        return new MessageSentReport($request, $response);
                    })
                    ->otherwise(function ($reason) {
                        return $this->createRejectedReport($reason);
                    });
            }

foreach ($promises as $promise) {
                yield $promise->wait();
            }
        }

if ($this->reuseVAPIDHeaders) {
            $this->vapidHeaders = [];
        }
    }

/**
     * Flush notifications. Triggers concurrent requests.
     *
     * @param callable(MessageSentReport): void $callback Callback for each notification
     * @param null|int $batchSize Defaults the value defined in defaultOptions during instantiation (which defaults to 1000).
     * @param null|int $requestConcurrency Defaults the value defined in defaultOptions during instantiation (which defaults to 100).
     */
    public function flushPooled($callback, ?int $batchSize = null, ?int $requestConcurrency = null): void
    {
        if (empty($this->notifications)) {
            return;
        }

if (null === $batchSize) {
            $batchSize = $this->defaultOptions['batchSize'];
        }

if (null === $requestConcurrency) {
            $requestConcurrency = $this->defaultOptions['requestConcurrency'];
        }

$batches = array_chunk($this->notifications, $batchSize);
        $this->notifications = [];

foreach ($batches as $batch) {
            $batch = $this->prepare($batch);
            $pool = new Pool($this->client, $batch, [
                'requestConcurrency' => $requestConcurrency,
                'fulfilled' => function (ResponseInterface $response, int $index) use ($callback, $batch) {
                    /** @var RequestInterface $request **/
                    $request = $batch[$index];
                    $callback(new MessageSentReport($request, $response));
                },
                'rejected' => function ($reason) use ($callback) {
                    $callback($this->createRejectedReport($reason));
                },
            ]);

$promise = $pool->promise();
            $promise->wait();
        }

if ($this->reuseVAPIDHeaders) {
            $this->vapidHeaders = [];
        }
    }

/**
     * @param RequestException|ConnectException $reason
     * @return MessageSentReport
     */
    protected function createRejectedReport($reason): MessageSentReport
    {
        if ($reason instanceof RequestException) {
            $response = $reason->getResponse();
        } else {
            $response = null;
        }

return new MessageSentReport($reason->getRequest(), $response, false, $reason->getMessage());
    }

/**
     * @throws \ErrorException
     * add back @throws \Random\RandomException when we drop PHP 8.1 support
     */
    protected function prepare(array $notifications): array
    {
        $requests = [];
        foreach ($notifications as $notification) {
            \assert($notification instanceof Notification);
            $subscription = $notification->getSubscription();
            $endpoint = $subscription->getEndpoint();
            $userPublicKey = $subscription->getPublicKey();
            $userAuthToken = $subscription->getAuthToken();
            $contentEncoding = $subscription->getContentEncoding();
            $payload = $notification->getPayload();
            $options = $notification->getOptions($this->getDefaultOptions());
            $auth = $notification->getAuth($this->auth);

if (!empty($payload) && !empty($userPublicKey) && !empty($userAuthToken)) {
                if (!$contentEncoding) {
                    throw new \ErrorException('Subscription should have a content encoding');
                }

$encrypted = Encryption::encrypt($payload, $userPublicKey, $userAuthToken, $contentEncoding);
                $cipherText = $encrypted['cipherText'];
                $salt = $encrypted['salt'];
                $localPublicKey = $encrypted['localPublicKey'];

$headers = [
                    'Content-Type' => 'application/octet-stream',
                    'Content-Encoding' => $contentEncoding,
                ];

if ($contentEncoding === "aesgcm") {
                    $headers['Encryption'] = 'salt='.Base64Url::encode($salt);
                    $headers['Crypto-Key'] = 'dh='.Base64Url::encode($localPublicKey);
                }

$encryptionContentCodingHeader = Encryption::getContentCodingHeader($salt, $localPublicKey, $contentEncoding);
                $content = $encryptionContentCodingHeader.$cipherText;

$headers['Content-Length'] = (string) Utils::safeStrlen($content);
            } else {
                $headers = [
                    'Content-Length' => '0',
                ];

$content = '';
            }

$headers['TTL'] = $options['TTL'];

if (isset($options['urgency'])) {
                $headers['Urgency'] = $options['urgency'];
            }

if (isset($options['topic'])) {
                $headers['Topic'] = $options['topic'];
            }

if (array_key_exists('VAPID', $auth) && $contentEncoding) {
                $audience = parse_url($endpoint, PHP_URL_SCHEME).'://'.parse_url($endpoint, PHP_URL_HOST);
                if (!parse_url($audience)) {
                    throw new \ErrorException('Audience "'.$audience.'"" could not be generated.');
                }

$vapidHeaders = $this->getVAPIDHeaders($audience, $contentEncoding, $auth['VAPID']);

$headers['Authorization'] = $vapidHeaders['Authorization'];

if ($contentEncoding === 'aesgcm') {
                    if (array_key_exists('Crypto-Key', $headers)) {
                        $headers['Crypto-Key'] .= ';'.$vapidHeaders['Crypto-Key'];
                    } else {
                        $headers['Crypto-Key'] = $vapidHeaders['Crypto-Key'];
                    }
                }
            }

$requests[] = new Request('POST', $endpoint, $headers, $content);
        }

return $requests;
    }

public function isAutomaticPadding(): bool
    {
        return $this->automaticPadding !== 0;
    }

public function getAutomaticPadding(): int
    {
        return $this->automaticPadding;
    }

/**
     * @param bool|int $automaticPadding Max padding length
     *
     * @throws \ValueError
     */
    public function setAutomaticPadding(bool|int $automaticPadding): WebPush
    {
        if ($automaticPadding === true) {
            $automaticPadding = Encryption::MAX_COMPATIBILITY_PAYLOAD_LENGTH;
        } elseif ($automaticPadding === false) {
            $automaticPadding = 0;
        }

if ($automaticPadding > Encryption::MAX_PAYLOAD_LENGTH) {
            throw new \ValueError('Automatic padding is too large. Max is '.Encryption::MAX_PAYLOAD_LENGTH.'. Recommended max is '.Encryption::MAX_COMPATIBILITY_PAYLOAD_LENGTH.' for compatibility reasons (see README).');
        }
        if ($automaticPadding < 0) {
            throw new \ValueError('Padding length should be positive or zero.');
        }

$this->automaticPadding = $automaticPadding;

return $this;
    }

public function getReuseVAPIDHeaders(): bool
    {
        return $this->reuseVAPIDHeaders;
    }

/**
     * Reuse VAPID headers in the same flush session to improve performance
     */
    public function setReuseVAPIDHeaders(bool $enabled): WebPush
    {
        $this->reuseVAPIDHeaders = $enabled;

return $this;
    }

public function getDefaultOptions(): array
    {
        return $this->defaultOptions;
    }

/**
     * @param array $defaultOptions Keys 'TTL' (Time To Live, defaults 4 weeks), 'urgency', 'topic', 'batchSize', 'requestConcurrency'
     */
    public function setDefaultOptions(array $defaultOptions): WebPush
    {
        $this->defaultOptions['TTL'] = $defaultOptions['TTL'] ?? 2419200;
        $this->defaultOptions['urgency'] = $defaultOptions['urgency'] ?? null;
        $this->defaultOptions['topic'] = $defaultOptions['topic'] ?? null;
        $this->defaultOptions['batchSize'] = $defaultOptions['batchSize'] ?? 1000;
        $this->defaultOptions['requestConcurrency'] = $defaultOptions['requestConcurrency'] ?? 100;

return $this;
    }

public function countPendingNotifications(): int
    {
        return null !== $this->notifications ? count($this->notifications) : 0;
    }

/**
     * @throws \ErrorException
     */
    protected function getVAPIDHeaders(string $audience, string $contentEncoding, array $vapid): ?array
    {
        $vapidHeaders = null;

$cache_key = null;
        if ($this->reuseVAPIDHeaders) {
            $cache_key = implode('#', [$audience, $contentEncoding, crc32(serialize($vapid))]);
            if (array_key_exists($cache_key, $this->vapidHeaders)) {
                $vapidHeaders = $this->vapidHeaders[$cache_key];
            }
        }

if (!$vapidHeaders) {
            $vapidHeaders = VAPID::getVapidHeaders($audience, $vapid['subject'], $vapid['publicKey'], $vapid['privateKey'], $contentEncoding);
        }

if ($this->reuseVAPIDHeaders) {
            $this->vapidHeaders[$cache_key] = $vapidHeaders;
        }

return $vapidHeaders;
    }
}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-01-29 05:44:07
..	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-01-29 05:44:07
Encryption.php	text/x-php	10.67 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-01-29 05:44:07
MessageSentReport.php	text/x-php	2.34 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-01-29 05:44:07
Notification.php	text/x-php	1.46 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-01-29 05:44:07
Subscription.php	text/x-php	2.71 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-01-29 05:44:07
SubscriptionInterface.php	text/x-php	580 B	tradinguniversit/tradinguniversit	-rw-r--r--	2025-01-29 05:44:07
Utils.php	text/x-php	4.78 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-01-29 05:44:07
VAPID.php	text/x-php	6.34 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-01-29 05:44:07
WebPush.php	text/x-php	14.48 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-01-29 05:44:07