Sid Gifari File Manager

Sid Gifari File Manager

🏠 Root / home2 / meumer25 / painelestilopetshop.meupet.app / vendor / kreait / firebase-php / src / Firebase / Messaging /

Editing: MulticastSendReport.php

<?php

declare(strict_types=1);

namespace Kreait\Firebase\Messaging;

use Countable;
use Kreait\Firebase\Exception\InvalidArgumentException;
use Kreait\Firebase\Exception\MessagingApiExceptionConverter;
use Kreait\Firebase\Http\Requests;
use Kreait\Firebase\Http\Responses;
use Kreait\Firebase\Messaging\Http\Request\MessageRequest;
use Kreait\Firebase\Util\JSON;
use Psr\Http\Message\RequestInterface;

final class MulticastSendReport implements Countable
{
    /** @var SendReport[] */
    private array $items = [];

private function __construct()
    {
    }

/**
     * @param SendReport[] $items
     */
    public static function withItems(array $items): self
    {
        $report = new self();
        $report->items = $items;

return $report;
    }

public static function fromRequestsAndResponses(Requests $requests, Responses $responses): self
    {
        $reports = [];
        $errorHandler = new MessagingApiExceptionConverter();

foreach ($responses as $response) {
            $contentIdHeader = $response->getHeaderLine('Content-ID');
            $contentIdHeaderParts = \explode('-', $contentIdHeader);

if (!($responseId = \array_pop($contentIdHeaderParts) ?: null)) {
                continue;
            }

$matchingRequest = $requests->findByContentId($responseId);

if (!($matchingRequest instanceof RequestInterface)) {
                continue;
            }

try {
                $requestData = JSON::decode((string) $matchingRequest->getBody(), true);
            } catch (InvalidArgumentException $e) {
                continue;
            }

if ($token = $requestData['message']['token'] ?? null) {
                $target = MessageTarget::with(MessageTarget::TOKEN, (string) $token);
            } elseif ($topic = $requestData['message']['topic'] ?? null) {
                $target = MessageTarget::with(MessageTarget::TOPIC, (string) $topic);
            } elseif ($condition = $requestData['message']['condition'] ?? null) {
                $target = MessageTarget::with(MessageTarget::CONDITION, (string) $condition);
            } else {
                $target = MessageTarget::with(MessageTarget::UNKNOWN, 'unknown');
            }

$message = $matchingRequest instanceof MessageRequest
                ? $matchingRequest->message()
                : null;

if ($response->getStatusCode() < 400) {
                try {
                    $responseData = JSON::decode((string) $response->getBody(), true);
                } catch (InvalidArgumentException $e) {
                    $responseData = [];
                }

$reports[] = SendReport::success($target, $responseData, $message);
            } else {
                $error = $errorHandler->convertResponse($response);
                $reports[] = SendReport::failure($target, $error, $message);
            }
        }

return self::withItems($reports);
    }

/**
     * @deprecated 5.14.0
     */
    public function withAdded(SendReport $report): self
    {
        $new = clone $this;
        $new->items[] = $report;

return $new;
    }

/**
     * @return SendReport[]
     */
    public function getItems(): array
    {
        return $this->items;
    }

public function successes(): self
    {
        return $this->filter(static fn (SendReport $item) => $item->isSuccess());
    }

public function failures(): self
    {
        return $this->filter(static fn (SendReport $item) => $item->isFailure());
    }

public function hasFailures(): bool
    {
        return $this->failures()->count() > 0;
    }

public function filter(callable $callback): self
    {
        $items = $this->items;

return self::withItems(\array_values(\array_filter($items, $callback)));
    }

/**
     * @return array<int, mixed>
     */
    public function map(callable $callback): array
    {
        return \array_map($callback, $this->items);
    }

/**
     * @return string[]
     */
    public function validTokens(): array
    {
        return $this->successes()
            ->filter(static fn (SendReport $report) => $report->target()->type() === MessageTarget::TOKEN)
            ->map(static fn (SendReport $report) => $report->target()->value())
        ;
    }

/**
     * Returns all provided registration tokens that were not reachable.
     *
     * @return string[]
     */
    public function unknownTokens(): array
    {
        return $this
            ->filter(static fn (SendReport $report) => $report->messageWasSentToUnknownToken())
            ->map(static fn (SendReport $report) => $report->target()->value())
        ;
    }

/**
     * Returns all provided registration tokens that were invalid.
     *
     * @return string[]
     */
    public function invalidTokens(): array
    {
        return $this
            ->filter(static fn (SendReport $report) => $report->messageTargetWasInvalid())
            ->map(static fn (SendReport $report) => $report->target()->value())
        ;
    }

public function count(): int
    {
        return \count($this->items);
    }
}