REDROOM

Edit File Size: 3.14 KB

/home/godevadmin/www/admin/vendor/aws/Aws/Api/Parser/EventParsingIterator.php

Text Base64

<?php

namespace Aws\Api\Parser;

use \Iterator;
use Aws\Exception\EventStreamDataException;
use Aws\Api\Parser\Exception\ParserException;
use Aws\Api\StructureShape;
use Psr\Http\Message\StreamInterface;

/**
 * @internal Implements a decoder for a binary encoded event stream that will
 * decode, validate, and provide individual events from the stream.
 */
class EventParsingIterator implements Iterator
{
    /** @var StreamInterface */
    private $decodingIterator;

/** @var StructureShape */
    private $shape;

/** @var AbstractParser */
    private $parser;

public function __construct(
        StreamInterface $stream,
        StructureShape $shape,
        AbstractParser $parser
    ) {
        $this->decodingIterator = new DecodingEventStreamIterator($stream);
        $this->shape = $shape;
        $this->parser = $parser;
    }

#[\ReturnTypeWillChange]
    public function current()
    {
        return $this->parseEvent($this->decodingIterator->current());
    }

#[\ReturnTypeWillChange]
    public function key()
    {
        return $this->decodingIterator->key();
    }

#[\ReturnTypeWillChange]
    public function next()
    {
        $this->decodingIterator->next();
    }

#[\ReturnTypeWillChange]
    public function rewind()
    {
        $this->decodingIterator->rewind();
    }

#[\ReturnTypeWillChange]
    public function valid()
    {
        return $this->decodingIterator->valid();
    }

private function parseEvent(array $event)
    {
        if (!empty($event['headers'][':message-type'])) {
            if ($event['headers'][':message-type'] === 'error') {
                return $this->parseError($event);
            }
            if ($event['headers'][':message-type'] !== 'event') {
                throw new ParserException('Failed to parse unknown message type.');
            }
        }

if (empty($event['headers'][':event-type'])) {
            throw new ParserException('Failed to parse without event type.');
        }
        $eventShape = $this->shape->getMember($event['headers'][':event-type']);

$parsedEvent = [];
        foreach ($eventShape['members'] as $shape => $details) {
            if (!empty($details['eventpayload'])) {
                $payloadShape = $eventShape->getMember($shape);
                if ($payloadShape['type'] === 'blob') {
                    $parsedEvent[$shape] = $event['payload'];
                } else {
                    $parsedEvent[$shape] = $this->parser->parseMemberFromStream(
                        $event['payload'],
                        $payloadShape,
                        null
                    );
                }
            } else {
                $parsedEvent[$shape] = $event['headers'][$shape];
            }
        }

return [
            $event['headers'][':event-type'] => $parsedEvent
        ];
    }

private function parseError(array $event)
    {
        throw new EventStreamDataException(
            $event['headers'][':error-code'],
            $event['headers'][':error-message']
        );
    }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
Exception DIR	-	drwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
AbstractParser.php	1.03 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
AbstractRestParser.php	5.65 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
Crc32ValidatingParser.php	1.53 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
DecodingEventStreamIterator.php	9.08 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
EventParsingIterator.php	3.14 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
JsonParser.php	2.08 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
JsonRpcParser.php	1.34 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
MetadataParserTrait.php	2.66 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
PayloadParserTrait.php	1.50 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
QueryParser.php	1.79 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
RestJsonParser.php	1.26 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
RestXmlParser.php	1.10 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive
XmlParser.php	5.19 KB	lrwxrwxr-x	2024-06-18 20:09:54	Edit Download recursive recursive

Directory Contents