src/Entity/Profile/FileProcessingTask.php line 15

Open in your IDE?
  1. <?php
  3. namespace App\Entity\Profile;
  5. use App\Entity\ContainsDomainEvents;
  6. use App\Entity\DomainEventsRecorderTrait;
  7. use App\Event\Profile\FileProcessingTaskWasCompleted;
  8. use App\Message\ProcessUploadedVideoMessage;
  9. use DateTimeImmutable;
  10. use DateTimeZone;
  11. use Doctrine\ORM\Mapping AS ORM;
  13. #[ORM\Entity]
  14. #[ORM\Table(name: 'file_processing_tasks')]
  15. class FileProcessingTask implements ContainsDomainEvents
  16. {
  17.     use DomainEventsRecorderTrait;
  19.     public const STATE_PENDING = 'pending';
  20.     public const STATE_PROCESSING = 'processing';
  21.     public const STATE_COMPLETED = 'completed';
  22.     public const STATE_FAILED = 'failed';
  24.     #[ORM\Id, ORM\GeneratedValue(strategy: 'AUTO'), ORM\Column(name: 'id', type: 'integer')]
  25.     private int $id;
  27.     #[ORM\JoinColumn(name: 'profile_id', referencedColumnName: 'id')]
  28.     #[ORM\ManyToOne(targetEntity: Profile::class, inversedBy: 'processingFiles')]
  29.     protected Profile $profile;
  31.     #[ORM\Column(name: 'path', type: 'string', length: 128)]
  32.     protected string $path;
  34.     #[ORM\Column(name: 'state', type: 'string', length: 32)]
  35.     protected string $state;
  37.     #[ORM\Column(name: 'added_at', type: 'datetimetz_immutable')]
  38.     protected DateTimeImmutable $addedAt;
  40.     #[ORM\Column(name: 'started_at', type: 'datetimetz_immutable', nullable: true)]
  41.     protected ?DateTimeImmutable $startedAt = null;
  43.     #[ORM\Column(name: 'last_error', type: 'text', nullable: true)]
  44.     protected ?string $lastError = null;
  46.     public function __construct(Profile $profile, string $path)
  47.     {
  48.         $this->profile = $profile;
  49.         $this->path = $path;
  50.         $this->state = self::STATE_PENDING;
  51.         $this->addedAt = new DateTimeImmutable('now', new DateTimeZone('UTC'));
  52.     }
  54.     public function start(): void
  55.     {
  56.         $this->state = self::STATE_PROCESSING;
  57.         $this->startedAt = new DateTimeImmutable('now', new DateTimeZone('UTC'));
  58.     }
  60.     public function isStarted(): bool
  61.     {
  62.         return $this->state === self::STATE_PROCESSING;
  63.     }
  65.     public function completeVideoTranscoding(string $videoPath, string $posterPath): void
  66.     {
  67.         $this->state = self::STATE_COMPLETED;
  68.         $this->profile->addVideo($videoPath, $posterPath);
  70.         $this->recordEvent(new FileProcessingTaskWasCompleted($this->profile, $this));
  71.     }
  73.     public function isCompleted(): bool
  74.     {
  75.         return $this->state === self::STATE_COMPLETED;
  76.     }
  78.     public function fail(string $errorMessage): void
  79.     {
  80.         $this->state = self::STATE_FAILED;
  81.         $this->lastError = $errorMessage;
  82.     }
  84.     public function createCommandToProcessUploadedVideo(): ProcessUploadedVideoMessage
  85.     {
  86.         return new ProcessUploadedVideoMessage(
  87.             $this->id,
  88.             $this->profile->getId(),
  89.             $this->path,
  90.         );
  91.     }
  92. }