Puzzle\AMQP\Messages\Bodies\StreamedBinary

Complexity

Total Complexity

4

Size/Duplication

Total Lines	43
Duplicated Lines	25.58 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	asTransported()	11	19	2
A	isChunked()	0	4	1

<?php

namespace Puzzle\AMQP\Messages\Bodies;

use Puzzle\ValueObjects\Uuid;
use Puzzle\AMQP\Messages\Chunks\Chunk;
use Puzzle\AMQP\Messages\Chunks\ChunkSize;
use Puzzle\AMQP\Messages\Chunks\ChunkedMessageMetadata;

class StreamedBinary extends Binary
{
    private
        $chunkSize,
        $metadata;

    public function __construct($content, ChunkSize $chunkSize)
    {
        parent::__construct($content);

        $this->chunkSize = $chunkSize;

        $size = strlen($content);
        $nbChunks = (int) ceil($size / $chunkSize->toBytes());

        $this->metadata = new ChunkedMessageMetadata(new Uuid(), $size, $nbChunks, sha1($content));
    }

    public function asTransported()
    {
        $wholeContent = parent::asTransported();
        $length = strlen($wholeContent);
        $offset = 0;
        $playhead = 0;

        while($offset < $length)

This code seems to be duplicated across your project.

        {
            $content = substr($wholeContent, $offset, $this->chunkSize->toBytes());
            $playhead++;

            $chunk = new Chunk($playhead, $offset, $content, $this->metadata);
            yield $chunk;

            $offset += $chunk->size();
            unset($chunk, $content);
        }
    }

    public function isChunked()
    {
        return true;
    }
}