91 lines
2.3 KiB
PHP
91 lines
2.3 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Entity;
|
|
|
|
use App\Entity\Interfaces\IdentifiableEntityInterface;
|
|
use App\Entity\Interfaces\PathAwareInterface;
|
|
use App\Entity\Interfaces\ProcessableMediaInterface;
|
|
use Doctrine\ORM\Mapping as ORM;
|
|
|
|
#[
|
|
ORM\Entity,
|
|
ORM\Table(name: 'unprocessable_media'),
|
|
ORM\UniqueConstraint(name: 'path_unique_idx', columns: ['path', 'storage_location_id'])
|
|
]
|
|
class UnprocessableMedia implements ProcessableMediaInterface, PathAwareInterface, IdentifiableEntityInterface
|
|
{
|
|
use Traits\HasAutoIncrementId;
|
|
|
|
public const REPROCESS_THRESHOLD_MINIMUM = 604800; // One week
|
|
|
|
#[ORM\ManyToOne(inversedBy: 'unprocessable_media')]
|
|
#[ORM\JoinColumn(name: 'storage_location_id', referencedColumnName: 'id', nullable: false, onDelete: 'CASCADE')]
|
|
protected StorageLocation $storage_location;
|
|
|
|
#[ORM\Column(nullable: false, insertable: false, updatable: false)]
|
|
protected int $storage_location_id;
|
|
|
|
#[ORM\Column(length: 500)]
|
|
protected string $path;
|
|
|
|
#[ORM\Column(nullable: true)]
|
|
protected ?int $mtime = 0;
|
|
|
|
#[ORM\Column(type: 'text', nullable: true)]
|
|
protected ?string $error = null;
|
|
|
|
public function __construct(StorageLocation $storageLocation, string $path)
|
|
{
|
|
$this->storage_location = $storageLocation;
|
|
|
|
$this->setPath($path);
|
|
}
|
|
|
|
public function getStorageLocation(): StorageLocation
|
|
{
|
|
return $this->storage_location;
|
|
}
|
|
|
|
public function getPath(): string
|
|
{
|
|
return $this->path;
|
|
}
|
|
|
|
public function setPath(string $path): void
|
|
{
|
|
$this->path = $path;
|
|
}
|
|
|
|
public function getMtime(): ?int
|
|
{
|
|
return $this->mtime;
|
|
}
|
|
|
|
public function setMtime(?int $mtime): void
|
|
{
|
|
$this->mtime = $mtime;
|
|
}
|
|
|
|
public function getError(): ?string
|
|
{
|
|
return $this->error;
|
|
}
|
|
|
|
public function setError(?string $error): void
|
|
{
|
|
$this->error = $error;
|
|
}
|
|
|
|
public static function needsReprocessing(int $fileModifiedTime = 0, int $dbModifiedTime = 0): bool
|
|
{
|
|
if ($fileModifiedTime > $dbModifiedTime) {
|
|
return true;
|
|
}
|
|
|
|
$threshold = $dbModifiedTime + self::REPROCESS_THRESHOLD_MINIMUM + random_int(0, 86400);
|
|
return time() > $threshold;
|
|
}
|
|
}
|