Core\Service\FileManager

Complexity

Total Complexity

14

Size/Duplication

Total Lines	117
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

9 Methods

Rating	Name	Duplication	Size	Complexity
A	factory()	0	5	1
A	__construct()	0	7	1
A	findByID()	0	4	1
A	getContents()	0	5	1
A	getStream()	0	4	1
A	getRepository()	0	3	1
A	remove()	0	11	3
A	uploadFromStream()	0	7	1
A	uploadFromFile()	0	22	4

<?php

declare(strict_types=1);

namespace Core\Service;


use Auth\AuthenticationService;
use Auth\Entity\AnonymousUser;
use Auth\Entity\UserImage;
use Core\Entity\FileInterface;
use Core\Entity\FileMetadataInterface;
use Core\Entity\ImageInterface;
use Core\Entity\PermissionsInterface;
use Doctrine\ODM\MongoDB\DocumentManager;
use Doctrine\ODM\MongoDB\Event\LifecycleEventArgs;
use Imagine\Image\ImageInterface as ImagineImage;
use Doctrine\ODM\MongoDB\Repository\GridFSRepository;
use Doctrine\ODM\MongoDB\Repository\UploadOptions;
use Doctrine\Persistence\ObjectRepository;
use Imagine\Image\ImagineInterface;
use Psr\Container\ContainerInterface;

class FileManager
{
    /**
     * @var DocumentManager
     */
    private DocumentManager $dm;

    /**
     * @var AuthenticationService
     */
    private AuthenticationService $auth;

    public function __construct(
        DocumentManager $dm,
        AuthenticationService $auth
    )
    {
        $this->dm = $dm;
        $this->auth = $auth;
    }

    public static function factory(ContainerInterface $container): self
    {
        $dm = $container->get(DocumentManager::class);
        $auth = $container->get('AuthenticationService');
        return new FileManager($dm, $auth);
    }

    /**
     * @param string $entityClass
     * @param string $id
     * @return object|null|FileInterface
     */
    public function findByID(string $entityClass, string $id)
    {
        $repo = $this->getRepository($entityClass);
        return $repo->find($id);
    }

    /**
     * @param FileInterface $file
     * @return resource
     */
    public function getStream(FileInterface $file)
    {
        $repo = $this->getRepository(get_class($file));
        return $repo->openDownloadStream($file->getId());

The method openDownloadStream() does not exist on Doctrine\Persistence\ObjectRepository. It seems like you code against a sub-type of Doctrine\Persistence\ObjectRepository such as Doctrine\ODM\MongoDB\Repository\GridFSRepository or Doctrine\ODM\MongoDB\Repository\DefaultGridFSRepository.

    }

    public function getContents(FileInterface $file): string
    {
        $repo = $this->getRepository(get_class($file));
        $stream = $repo->openDownloadStream($file->getId());
        return stream_get_contents($stream);
    }

    public function uploadFromFile(string $entityClass, FileMetadataInterface $metadata, string $source, ?string $fileName = null): object
    {
        $repo = $this->getRepository($entityClass);

        if(UserImage::class !== $entityClass && is_null($metadata->getUser())){
            $user = $this->auth->getUser();

            if($user instanceof AnonymousUser){

$user is always a sub-type of Auth\Entity\AnonymousUser.

                $metadata->getPermissions()->grant($user, PermissionsInterface::PERMISSION_ALL);
            }else{
                $this->dm->getUnitOfWork()->registerManaged($user, $user->getId(), []);

                $metadata->setUser($user);
                $this->dm->persist($user);
                $this->dm->flush();
            }
        }

        $options = new UploadOptions();
        $options->metadata = $metadata;

        return $repo->uploadFromFile($source, $fileName, $options);

The method uploadFromFile() does not exist on Doctrine\Persistence\ObjectRepository. It seems like you code against a sub-type of Doctrine\Persistence\ObjectRepository such as Doctrine\ODM\MongoDB\Repository\GridFSRepository or Doctrine\ODM\MongoDB\Repository\DefaultGridFSRepository.

    }

    /**
     * @param string $entityClass
     * @param FileMetadataInterface $metadata
     * @param string $fileName
     * @param resource $stream
     * @return object|FileInterface|ImageInterface
     */
    public function uploadFromStream(string $entityClass, FileMetadataInterface $metadata, string $fileName, $stream): object
    {
        $repo = $this->getRepository($entityClass);
        $options = new UploadOptions();
        $options->metadata = $metadata;

        return $repo->uploadFromStream($fileName, $stream, $options);

The method uploadFromStream() does not exist on Doctrine\Persistence\ObjectRepository. It seems like you code against a sub-type of Doctrine\Persistence\ObjectRepository such as Doctrine\ODM\MongoDB\Repository\GridFSRepository or Doctrine\ODM\MongoDB\Repository\DefaultGridFSRepository.

    }

    public function remove(FileInterface $file, $andFlush = false)
    {
        $dm = $this->dm;
        $events = $dm->getEventManager();

        $dm->remove($file);
        $events->hasListeners('postRemoveEntity') &&
            $events->dispatchEvent('postRemoveEntity', new LifecycleEventArgs($file, $dm));

        if($andFlush){
            $dm->flush();
        }
    }

    /**
     * @param string $entityClass
     * @return ObjectRepository|GridFSRepository
     */
    private function getRepository(string $entityClass)
    {
        return $this->dm->getRepository($entityClass);
    }
}