ZBateson\MailMimeParser\Stream\MessagePartStream

Complexity

Total Complexity

18

Size/Duplication

Total Lines	132
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getTransferEncodingDecoratorForStream()	0	22	4
A	getCharsetDecoratorForStream()	0	12	2
A	writePartContentTo()	0	12	2
A	getBoundaryAndChildStreams()	0	18	6
A	getStreamsArray()	0	12	2
A	__construct()	0	4	1
A	createStream()	0	3	1

<?php
/**
 * This file is part of the ZBateson\MailMimeParser project.
 *
 * @license http://opensource.org/licenses/bsd-license.php BSD
 */
namespace ZBateson\MailMimeParser\Stream;

use ZBateson\MailMimeParser\MailMimeParser;
use ZBateson\MailMimeParser\Message\Part\MessagePart;
use ZBateson\MailMimeParser\Message\Part\MimePart;
use ZBateson\MailMimeParser\Message\Part\ParentHeaderPart;
use ZBateson\MailMimeParser\Stream\StreamFactory;
use Psr\Http\Message\StreamInterface;
use GuzzleHttp\Psr7\StreamDecoratorTrait;
use GuzzleHttp\Psr7\AppendStream;
use GuzzleHttp\Psr7;

/**
 * Writes a MimePart to a resource handle.
 * 
 * The class is responsible for writing out the headers and content of a
 * MimePart to an output stream buffer, taking care of encoding and filtering.
 * 
 * @author Zaahid Bateson
 */
class MessagePartStream implements StreamInterface
{
    use StreamDecoratorTrait;

    protected $streamFactory;
    protected $part;

    public function __construct(StreamFactory $sdf, MessagePart $part)
    {
        $this->streamFactory = $sdf;
        $this->part = $part;
    }

    /**
     * Sets up a mailmimeparser-encode stream filter on the content resource 
     * handle of the passed MimePart if applicable and returns a reference to
     * the filter.
     *
     * @param MimePart $part
     * @return StreamInterface a reference to the appended stream filter or null
     */
    private function getCharsetDecoratorForStream(MessagePart $part, StreamInterface $stream)
    {
        $charset = $part->getCharset();
        if (!empty($charset)) {
            $decorator = $this->streamFactory->newCharsetStream(
                $stream,
                $charset,
                MailMimeParser::DEFAULT_CHARSET
            );
            return $decorator;
        }
        return $stream;
    }
    
    /**
     * Appends a stream filter on the passed MimePart's content resource handle
     * based on the type of encoding for the passed part.
     *
     * @param MimePart $part
     * @param resource $handle
     * @param StreamLeftover $leftovers

The type ZBateson\MailMimeParser\Stream\StreamLeftover was not found. Maybe you did not declare it correctly or list all dependencies?

     * @return StreamInterface the stream filter
     */
    private function getTransferEncodingDecoratorForStream(
        MessagePart $part,
        StreamInterface $stream
    ) {
        $encoding = $part->getContentTransferEncoding();
        $decorator = null;
        switch ($encoding) {
            case 'quoted-printable':
                $decorator = $this->streamFactory->newQuotedPrintableStream($stream);
                break;
            case 'base64':
                $decorator = $this->streamFactory->newBase64Stream(
                    $this->streamFactory->newChunkSplitStream($stream));
                break;
            case 'x-uuencode':
                $decorator = $this->streamFactory->newUUStream($stream);
                $decorator->setFilename($part->getFilename());
                break;
            default:
                return $stream;
        }
        return $decorator;
    }

    /**
     * Writes out the content portion of the mime part based on the headers that
     * are set on the part, taking care of character/content-transfer encoding.
     *
     * @param MessagePart $part
     * @param StreamInterface $stream
     */
    public function writePartContentTo(MessagePart $part, StreamInterface $stream)
    {
        $contentStream = $part->getContentStream();
        if ($contentStream !== null) {
            $copyStream = $this->streamFactory->newNonClosingStream($stream);
            $es = $this->getTransferEncodingDecoratorForStream(
                $part,
                $copyStream
            );
            $cs = $this->getCharsetDecoratorForStream($part, $es);
            Psr7\copy_to_stream($contentStream, $cs);

The function copy_to_stream was not found. Maybe you did not declare it correctly or list all dependencies?

            $cs->close();
        }
    }

    protected function getBoundaryAndChildStreams(ParentHeaderPart $part)
    {
        $streams = [];
        $boundary = $part->getHeaderParameter('Content-Type', 'boundary');
        foreach ($part->getChildParts() as $i => $child) {
            if ($boundary !== null) {
                if ($i === 0 && !$part->hasContent()) {
                    $streams[] = Psr7\stream_for("--$boundary\r\n");

The function stream_for was not found. Maybe you did not declare it correctly or list all dependencies?

                } else {
                    $streams[] = Psr7\stream_for("\r\n--$boundary\r\n");
                }
            }
            $streams[] = $child->getStream();
        }
        if ($boundary !== null) {

The condition $boundary !== null is always true.

            $streams[] = Psr7\stream_for("\r\n--$boundary--\r\n");
        }
        return $streams;
    }

    protected function getStreamsArray()
    {
        $content = Psr7\stream_for();

The function stream_for was not found. Maybe you did not declare it correctly or list all dependencies?

        $this->writePartContentTo($this->part, $content);
        $content->rewind();
        $streams = [ new HeaderStream($this->part), $content ];

        if ($this->part instanceof ParentHeaderPart) {
            $streams = array_merge($streams, $this->getBoundaryAndChildStreams($this->part));
        }

        return $streams;
    }

    /**
     * Creates the underlying stream lazily when required.
     *
     * @return StreamInterface
     */
    protected function createStream()
    {
        return new AppendStream($this->getStreamsArray());
    }
}