Balloon\App\Preview\PreviewCreator

Complexity

Total Complexity

6

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	createPreview()	0	33	3
A	storePreview()	0	26	2

<?php

declare(strict_types=1);

/**
 * balloon
 *
 * @copyright   Copryright (c) 2012-2019 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Balloon\App\Preview;

use Balloon\Converter;
use Balloon\Filesystem\Node\File;
use MongoDB\BSON\ObjectId;
use MongoDB\Database;
use Psr\Log\LoggerInterface;

class PreviewCreator extends Preview
{
    /**
     * Converter.
     *
     * @var Converter
     */
    protected $converter;

    /**
     * Constructor.
     */
    public function __construct(Database $db, LoggerInterface $logger, Converter $converter)
    {
        parent::__construct($db, $logger);
        $this->converter = $converter;
    }

    /**
     * Create preview.
     */
    public function createPreview(File $file): ObjectId
    {
        $this->logger->debug('create preview for file ['.$file->getId().']', [
            'category' => get_class($this),
        ]);

        try {
            $stream = $this->converter->createPreview($file);
            $result = stream_get_contents($stream);
            $hash = md5($result);
            rewind($stream);

            $found = $this->db->{'thumbnail.files'}->findOne([
                'md5' => $hash,
            ], ['_id', 'thumbnail']);

            if ($found) {
                $this->logger->debug('found existing preview ['.$found['_id'].'] with same hash, use stored preview', [
                    'category' => get_class($this),
                ]);

                $file->setAppAttribute(__NAMESPACE__, 'preview', $found['_id']);

                return $found['_id'];
            }

            return $this->storePreview($file, $stream);
        } catch (\Exception $e) {
            $file->unsetAppAttribute(__NAMESPACE__, 'preview');

            throw $e;
        }
    }

    /**
     * Store new preview.
     */
    protected function storePreview(File $file, $content): ObjectId
    {
        try {
            $id = new ObjectId();
            $bucket = $this->db->selectGridFSBucket(['bucketName' => 'thumbnail']);
            $stream = $bucket->openUploadStream(null, ['_id' => $id]);
            /*fwrite($stream, $content);
            fclose($stream);*/
            stream_copy_to_stream($content, $stream);

            $file->setAppAttribute(__NAMESPACE__, 'preview', $id);

            $this->logger->info('stored new preview ['.$id.'] for file ['.$file->getId().']', [
                'category' => get_class($this),
            ]);

            return $id;
        } catch (\Exception $e) {
            $this->logger->error('failed store preview for file ['.$file->getId().']', [
                'category' => get_class($this),
                'exception' => $e,
            ]);

            throw $e;
        }
    }
}