src/Tus/EventListener/TusListener.php line 36

Open in your IDE?
  1. <?php
  3. namespace App\Tus\EventListener;
  5. use App\Entity\UserUpload;
  6. use App\Tus\Service\FileCollectorService;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use Roothirsch\CoreBundle\Behaviors\Attributable\MappedSuperclass\AbstractAttributable;
  9. use Roothirsch\CoreBundle\Behaviors\Attributable\MappedSuperclass\AbstractAttributeValue;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\Filesystem\Filesystem;
  12. use Symfony\Component\HttpKernel\KernelInterface;
  13. use Symfony\Component\Routing\RouterInterface;
  14. use TusPhp\Events\UploadComplete;
  15. use TusPhp\Events\UploadCreated;
  16. use TusPhp\Events\UploadProgress;
  17. use TusPhp\File;
  19. class TusListener implements EventSubscriberInterface
  20. {
  21. public function __construct(
  22. private KernelInterface $kernel,
  23. private RouterInterface $router,
  24. private FileCollectorService $collectorService,
  25. private EntityManagerInterface $entityManager,
  26. private ?File $file = null
  27. ){}
  29. public static function getSubscribedEvents()
  30. {
  31. return [
  32. UploadComplete::NAME => ['onComplete'],
  33. ];
  34. }
  36. public function onComplete(UploadComplete $event){
  37. $this->file = $event->getFile();
  38. if(!$this->hasRequiredMetaData(['entity_id', 'entity_fqcn', 'property_name'])){
  39. return;
  40. }
  41. $metaData = $this->getMetaData();
  42. $entity = $this->entityManager->getRepository($metaData['entity_fqcn'])->find($metaData['entity_id']);
  43. $fileCollector = $this->collectorService->findCollectorSupports($metaData['entity_fqcn']);
  44. $fileCollector->setProperty($metaData['property_name']);
  45. $fileCollector->setEntity($entity);
  46. $file = $fileCollector->relocate($event->getFile());
  47. $hash = $fileCollector->hashFile($file);
  48. $event->getResponse()->setHeaders([
  49. 'x-file-download' => $this->router->generate('tus_file_action', [
  50. 'hash' => $hash ,
  51. "action" => 'download'
  52. ], 0),
  53. 'x-file-delete' => $this->router->generate('tus_file_action', [
  54. 'hash' => $hash ,
  55. "action" => 'delete'
  56. ], 0),
  57. 'x-file-id' => $hash,
  58. 'x-file-public' => str_replace($this->kernel->getProjectDir().'/public/', "", $file->getRealPath())
  59. ]);
  60. }
  62. private function getTargetDir(){
  64. return $this->getUploadsDir().'/' .$this->getEntityDir();
  65. }
  67. private function getEntityDir()
  68. {
  69. return static::getEntityDirFromMeta(
  70. $this->getMetaData('entity_fqcn'),
  71. $this->getMetaData('property_name'),
  72. $this->getMetaData('entity_id')
  73. );
  74. }
  77. public static function getEntityDirFromMeta($class, $prop, $entityId){
  78. if(!$class && !$prop && !$entityId) {return ''; }
  79. return sprintf("%s/%s/%s",
  80. strtolower((new \ReflectionClass($class))->getShortName()), // class
  81. md5($entityId), // id
  82. $prop
  83. );
  84. }
  86. private function getUploadsDir()
  87. {
  88. return $this->kernel->getProjectDir().'/public/uploads';
  89. }
  91. private function getMetaData($key=null)
  92. {
  93. $meta = $this->file->details()['metadata'];
  94. if($key === null) {
  95. return $meta;
  96. }
  97. if(array_key_exists($key, $meta)){
  98. return $meta[$key];
  99. }
  100. return null;
  101. }
  103. private function hasRequiredMetaData(array $keys){
  104. $exists = array_filter($keys, function($key) {
  105. return !!$this->getMetaData($key);
  106. });
  107. return count($keys) === count($exists);
  108. }
  109. }