TTK-26902 add generate jobs for downloaded videos from YouTube

Command/ImportJobsFromYouTubeDownloadCommand.php

@@ -0,0 +1,113 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Pumukit\YoutubeBundle\Command;
+
+use Pumukit\SchemaBundle\Document\MultimediaObject;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Helper\ProgressBar;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+final class ImportJobsFromYouTubeDownloadCommand extends Command
+{
+    public const DEFAULT_PROFILE_ENCODER = 'broadcastable_master';
+    private JobService $jobService;
+    private string $tempDir;
+    private string $channelId;
+    private $youtubeErrors = [];
+
+    public function __construct(
+        DocumentManager $documentManager,
+        JobService $jobService,
+        string $tempDir
+    ) {
+        $this->documentManager = $documentManager;
+        $this->jobService = $jobService;
+        $this->tempDir = $tempDir;
+        parent::__construct();
+    }
+
+    protected function configure(): void
+    {
+        $this
+            ->setName('pumukit:youtube:import:add:jobs')
+            ->addOption('account', null, InputOption::VALUE_REQUIRED, 'Account')
+            ->addOption('channel', null, InputOption::VALUE_REQUIRED, 'Channel ID')
+            ->addOption('limit', null, InputOption::VALUE_OPTIONAL, 'limit')
+            ->setDescription('Import all videos from Youtube channel')
+            ->setHelp(
+                <<<'EOT'
+
+Generate jobs for all videos downloaded from Youtube channel
+
+Limit is optional to test the command.
+
+Usage: php bin/console pumukit:youtube:import:add:jobs --account={ACCOUNT} --channel={CHANNEL_ID} --limit={LIMIT}
+
+EOT
+            )
+        ;
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+        $channel = $input->getOption('channel');
+        $limit = (int) $input->getOption('limit');
+
+        $youtubeAccount = $this->ensureYouTubeAccountExists($input);
+
+        $multimediaObjects = $this->documentManager->getRepository(MultimediaObject::class)->findBy([
+            'status' => ['$in' => [MultimediaObject::STATUS_PUBLISHED, MultimediaObject::STATUS_HIDDEN]],
+            'properties.youtube_import_status' => ['$exists' => true],
+            'properties.youtube_import_channel' => $channel,
+        ], [], $limit ?? null);
+
+        $progressBar = new ProgressBar($output, count($multimediaObjects));
+        $progressBar->start();
+
+        $count = 0;
+        foreach ($multimediaObjects as $multimediaObject) {
+            $progressBar->advance();
+            if (null !== $input->getOption('limit') && $count >= $input->getOption('limit')) {
+                break;
+            }
+            ++$count;
+            $this->addJob($multimediaObject, $multimediaObject->getProperty('youtube_import_id'));
+        }
+
+        $progressBar->finish();
+        $output->writeln(' ');
+
+        foreach ($this->youtubeErrors as $error) {
+            $output->writeln($error);
+        }
+
+        return 0;
+    }
+
+    private function addJob(MultimediaObject $multimediaObject, string $youtubeId): MultimediaObject
+    {
+        $path = $this->tempDir.'/'.$this->channelId.'/';
+        $trackUrl = FinderUtils::findFilePathname($path, $youtubeId);
+
+        if (!$trackUrl) {
+            $this->youtubeErrors[] = 'Cannot find file: '.$path.$youtubeId;
+
+            return $multimediaObject;
+        }
+
+        return $this->jobService->createTrackFromInboxOnServer(
+            $multimediaObject,
+            $trackUrl,
+            self::DEFAULT_PROFILE_ENCODER,
+            0,
+            null,
+            '',
+            [],
+            0,
+            0
+        );
+    }
+}