FM / Parser

/home/techb158/immovalet.com/vendor/aws/aws-sdk-php/src/Api/Parser/

/home/techb158/immovalet.com/vendor/aws/aws-sdk-php/src/Api/Parser

Name	Size	Mode	Actions
Exception/	-	0755	rm
AbstractParser.php	1006	0644	edit dl rm
AbstractRestParser.php	5603	0644	edit dl rm
Crc32ValidatingParser.php	1516	0644	edit dl rm
DecodingEventStreamIterator.php	8816	0644	edit dl rm
EventParsingIterator.php	2956	0644	edit dl rm
JsonParser.php	1603	0644	edit dl rm
JsonRpcParser.php	1321	0644	edit dl rm
MetadataParserTrait.php	2635	0644	edit dl rm
PayloadParserTrait.php	1475	0644	edit dl rm
QueryParser.php	1769	0644	edit dl rm
RestJsonParser.php	1246	0644	edit dl rm
RestXmlParser.php	1083	0644	edit dl rm
XmlParser.php	4850	0644	edit dl rm

Edit: /home/techb158/immovalet.com/vendor/aws/aws-sdk-php/src/Api/Parser/EventParsingIterator.php (2956B)

<?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;
    }

public function current()
    {
        return $this->parseEvent($this->decodingIterator->current());
    }

public function key()
    {
        return $this->decodingIterator->key();
    }

public function next()
    {
        $this->decodingIterator->next();
    }

public function rewind()
    {
        $this->decodingIterator->rewind();
    }

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']
        );
    }
}

decodingIterator = new DecodingEventStreamIterator($stream); $this->shape = $shape; $this->parser = $parser; } public function current() { return $this->parseEvent($this->decodingIterator->current()); } public function key() { return $this->decodingIterator->key(); } public function next() { $this->decodingIterator->next(); } public function rewind() { $this->decodingIterator->rewind(); } 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'] ); } }