Puzzle\AMQP\Workers\Chunks\ChunkAssembler

Complexity

Total Complexity

8

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
B	process()	0	24	3
A	retrieveChunkedMessageMetadata()	0	9	2
A	retrieveChunkMetadata()	0	9	2

<?php

namespace Puzzle\AMQP\Workers\Chunks;

use Puzzle\AMQP\Workers\Worker;
use Puzzle\AMQP\ReadableMessage;
use Psr\Log\NullLogger;
use Psr\Log\LoggerAwareTrait;
use Puzzle\AMQP\Messages\Chunks\ChunkedMessageMetadata;
use Puzzle\AMQP\Messages\Chunks\ChunkMetadata;

class ChunkAssembler implements Worker
{
    use LoggerAwareTrait;

    private
        $tracker,
        $storage;

    public function __construct(ChunkAssemblyTracker $tracker, ChunkAssemblyStorage $storage)
    {
        $this->tracker = $tracker;
        $this->storage = $storage;
        $this->logger = new NullLogger();
    }

    public function process(ReadableMessage $message)
    {
        $headers = $message->getHeaders();

        $chunkMetadata = $this->retrieveChunkMetadata($headers);
        $chunkedMessageMetadata = $this->retrieveChunkedMessageMetadata($headers);
        $uuid = $chunkedMessageMetadata->uuid();

        if($this->tracker->hasBeenStarted($uuid) === false)
        {
            $this->tracker->start($chunkedMessageMetadata);
            $this->storage->start($chunkedMessageMetadata);
        }

        $this->tracker->markAsReceived($uuid, $chunkMetadata->playhead());
        $this->storage->store($uuid, $chunkMetadata, $message->getBodyAsTransported());

        if($this->tracker->isAllHasBeenReceived($uuid))
        {
            var_dump("OK for $uuid");

var_dump("OK for {$uuid}"); looks like debug code. Are you sure you do not want to remove it? This might expose sensitive data.

            // check hash
            $this->storage->finish($chunkedMessageMetadata, $headers);
        }
    }

    private function retrieveChunkedMessageMetadata(array $headers)
    {
        if(! isset($headers['chunkedMessage']))
        {
            throw new \InvalidArgumentException("Missing chunkedMessage header");
        }

        return ChunkedMessageMetadata::buildFromHeaders($headers['chunkedMessage']);
    }

    private function retrieveChunkMetadata(array $headers)
    {
        if(! isset($headers['chunk']))
        {
            throw new \InvalidArgumentException("Missing chunk header");
        }

        return ChunkMetadata::buildFromHeaders($headers['chunk']);
    }
}