81 lines
2.8 KiB
PHP
81 lines
2.8 KiB
PHP
<?php
|
|
|
|
namespace App\Download\Action\Handler;
|
|
|
|
use App\Download\Action\Command\DownloadMediaCommand;
|
|
use App\Download\Action\Result\DownloadMediaResult;
|
|
use App\Download\DownloadEvents;
|
|
use App\Download\Framework\Repository\DownloadRepository;
|
|
use App\Download\Downloader\DownloaderInterface;
|
|
use App\EventLog\Action\Command\AddEventLogCommand;
|
|
use App\User\Framework\Repository\UserRepository;
|
|
use OneToMany\RichBundle\Contract\CommandInterface;
|
|
use OneToMany\RichBundle\Contract\HandlerInterface;
|
|
use OneToMany\RichBundle\Contract\ResultInterface;
|
|
use Symfony\Component\Messenger\Exception\UnrecoverableMessageHandlingException;
|
|
use Symfony\Component\Messenger\MessageBusInterface;
|
|
|
|
/** @implements HandlerInterface<DownloadMediaCommand, DownloadMediaResult> */
|
|
readonly class DownloadMediaHandler implements HandlerInterface
|
|
{
|
|
public function __construct(
|
|
private MessageBusInterface $bus,
|
|
private DownloaderInterface $downloader,
|
|
private DownloadRepository $downloadRepository,
|
|
private UserRepository $userRepository,
|
|
) {}
|
|
|
|
public function handle(CommandInterface $command): ResultInterface
|
|
{
|
|
$user = $this->userRepository->find($command->userId);
|
|
$this->bus->dispatch(new AddEventLogCommand(
|
|
$user,
|
|
DownloadEvents::DOWNLOAD_STARTED->type(),
|
|
DownloadEvents::DOWNLOAD_STARTED->message(),
|
|
(array) $command
|
|
));
|
|
|
|
if (null === $command->downloadId) {
|
|
$download = $this->downloadRepository->insert(
|
|
$user,
|
|
$command->url,
|
|
$command->title,
|
|
$command->filename,
|
|
$command->imdbId,
|
|
$command->mediaType,
|
|
""
|
|
);
|
|
} else {
|
|
$download = $this->downloadRepository->find($command->downloadId);
|
|
}
|
|
|
|
try {
|
|
if ($download->getStatus() !== 'Paused') {
|
|
$this->downloadRepository->updateStatus($download->getId(), 'In Progress');
|
|
}
|
|
|
|
$this->downloader->download(
|
|
$command->mediaType,
|
|
$command->title,
|
|
$command->url,
|
|
$download->getId()
|
|
);
|
|
|
|
if ($download->getStatus() !== 'Paused') {
|
|
$this->downloadRepository->updateStatus($download->getId(), 'Complete');
|
|
}
|
|
|
|
} catch (\Throwable $exception) {
|
|
throw new UnrecoverableMessageHandlingException($exception->getMessage(), 500);
|
|
}
|
|
|
|
$this->bus->dispatch(new AddEventLogCommand(
|
|
$user,
|
|
DownloadEvents::DOWNLOAD_FINISHED->type(),
|
|
DownloadEvents::DOWNLOAD_FINISHED->message(),
|
|
(array) $command
|
|
));
|
|
return new DownloadMediaResult(200, "Success.");
|
|
}
|
|
}
|