Skip to content
GitLab
Select Git revision
  • master default
  • deploy
Find file BlameHistoryPermalink
UploadedFileRepository.php 3.13 KiB
1 
<?php
2
3 
/*
4 
 * Copyright (C) 2015 IRSTEA
5 
 * All rights reserved.
6 
 */
7
8 
namespace Irstea\FileUploadBundle\Entity\Repository;
9
10 
use Doctrine\ORM\EntityRepository;
11 
use Gaufrette\Filesystem;
12 
use Irstea\FileUploadBundle\Entity\UploadedFile;
13 
use Irstea\FileUploadBundle\Event\FileUploadCompleteEvent;
14 
use Irstea\FileUploadBundle\FileUploadEvents;
15 
use Irstea\FileUploadBundle\Service\FileManagerInterface;
16 
use Psr\Log\LogLevel;
17 
use Symfony\Component\EventDispatcher\EventDispatcher;
18 
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
19
20 
/**
21 
 * Description of UploadedFileRepository
22 
 *
23 
 * @author Guillaume Perréal <guillaume.perreal@irstea.fr>
24 
 */
25 
class UploadedFileRepository extends EntityRepository implements FileManagerInterface
26 
{
27 
    use \Psr\Log\LoggerAwareTrait;
28
29 
    /**
30 
     * @var Filesystem
31 
     */
32 
    protected $filesystem;
33
34 
    /**
35 
     * @var EventDispatcher
36 
     */
37 
    protected $eventDispatcher;
38
39 
    /**
40 
     *
41 
     * @param Filesystem $filesystem
42 
     */
43 
    public function setFilesystem(Filesystem $filesystem)
44 
    {
45 
        $this->filesystem = $filesystem;
46 
    }
47
48 
    /**
49 
     *
50 
     * @param EventDispatcherInterface $eventDispatcher
51 
     */
52 
    public function setEventDispatcher(EventDispatcherInterface $eventDispatcher)
53 
    {
54 
        $this->eventDispatcher = $eventDispatcher;
55 
    }
56
57 
    public function create($filename, $size, $mimeType, $lastModified)
58 
    {
59 
        $file = new UploadedFile();
60
61 
        $file
62 
            ->setFilesystem($this->filesystem)
63 
            ->setOriginalFilename($filename)
64 
            ->setMetadata(
65 
                [
66 
                    'original' => [
67 
                        'filename'     => $filename,
68 
                        'size'         => $size,
69 
                        'mimeType'     => $mimeType,
70 
                        'lastModified' => $lastModified
7172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128
] ] ); $this->_em->persist($file); $this->_em->flush(); $this->log(LogLevel::INFO, 'File created', ['file' => $file]); return $file; } public function delete(UploadedFile $file) { $this->_em->remove($file); $this->_em->flush(); $this->log(LogLevel::INFO, 'File deleted', ['file' => $file]); } public function get($id) { return $this->findById($id); } public function completed(UploadedFile $file) { $path = $file->getPath(); $fs = $this->filesystem; $file ->setChecksum($fs->checksum($path)) ->setSize($fs->size($path)) ->setMimeType($fs->mimeType($path)) ->setEtat(UploadedFile::ETAT_ORPHELIN); $this->eventDispatcher->dispatch(FileUploadEvents::UPLOAD_COMPLETE, new FileUploadCompleteEvent($file)); $this->_em->persist($file); $this->_em->flush(); $this->log(LogLevel::INFO, 'File completed', ['file' => $file]); } /** * * @param string $level * @param string $message * @param array $context */ protected function log($level, $message, array $context = []) { if(null !== $this->logger) { $this->logger->log($level, $message, $context); } } }