DownloadAllCollectFilesJob.php

Go to the documentation of this file.

<?php
 
namespace ILIAS\MediaCast\BackgroundTasks;
 
use ILIAS\BackgroundTasks\Implementation\Tasks\AbstractJob;
use ILIAS\BackgroundTasks\Value;
use ILIAS\BackgroundTasks\Observer;
use ILIAS\BackgroundTasks\Types\SingleType;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\StringValue;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\IntegerValue;
 
class DownloadAllCollectFilesJob extends AbstractJob
{
    private ?\ilLogger $logger = null;
    protected int $user_id = 0;
    protected int $mcst_id = 0;
    protected int $mcst_ref_id = 0;
    protected \ilLanguage $lng;
    protected string $target_directory = "";
    protected string $temp_dir = "";
    protected string $sanitized_title = "";
    protected \ilObjMediaCast $media_cast;
 
    public function __construct()
    {
        global $DIC;
        $this->lng = $DIC->language();
        $this->lng->loadLanguageModule('mcst');
        $this->logger = $DIC->logger()->mcst();
 
        $this->sanitized_title = "images";
    }
 
    public function getInputTypes(): array
    {
        return
            [
                new SingleType(IntegerValue::class),
                new SingleType(IntegerValue::class)
            ];
    }
 
    public function getOutputType(): \ILIAS\BackgroundTasks\Types\Type
    {
        return new SingleType(StringValue::class);
    }
 
    public function isStateless(): bool
    {
        return true;
    }
 
    public function getExpectedTimeOfTaskInSeconds(): int
    {
        return 30;
    }
 
    public function run(array $input, Observer $observer): StringValue
    {
        $this->user_id = $input[0]->getValue();
        $this->mcst_ref_id = $input[1]->getValue();
 
        $this->logger->debug("Get Mediacast " . $this->mcst_ref_id);
        $this->media_cast = new \ilObjMediaCast($this->mcst_ref_id);
 
        $target_dir = $this->createDirectory();
 
        $this->logger->debug("Collect in " . $target_dir);
        $this->collectMediaFiles($target_dir);
        $this->logger->debug("Finished collecting.");
 
        $out = new StringValue();
        $out->setValue($target_dir);
        return $out;
    }
 
    protected function createDirectory(): string
    {
        // temp dir
        $this->temp_dir = \ilFileUtils::ilTempnam();
 
        // target dir
        $path = $this->temp_dir . DIRECTORY_SEPARATOR;
        $this->target_directory = $path . $this->sanitized_title;
        \ilFileUtils::makeDirParents($this->target_directory);
 
        return $this->target_directory;
    }
 
    public function collectMediaFiles(string $target_dir): void
    {
        $cnt = 0;
        foreach ($this->media_cast->getSortedItemsArray() as $item) {
            $mob = new \ilObjMediaObject($item["mob_id"]);
            $med = $mob->getMediaItem("Standard");
 
            $cnt++;
            $str_cnt = str_pad($cnt, 4, "0", STR_PAD_LEFT);
 
            if ($med->getLocationType() === "Reference") {
                $resource = $med->getLocation();
                copy($resource, $target_dir . DIRECTORY_SEPARATOR . $str_cnt . basename($resource));
            } else {
                try {   // this skips broken objects
                    $stream = $med->getLocationStream();
                    file_put_contents(
                        $target_dir . DIRECTORY_SEPARATOR . $str_cnt . $med->getLocation(),
                        $stream->getContents()
                    );
                } catch (\Exception $e) {
                }
            }
        }
    }
}