class.ilECSCmsCourseCommandQueueHandler.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
class ilECSCmsCourseCommandQueueHandler implements ilECSCommandQueueHandler
{
    private ilLogger $logger;
 
    private ilECSSetting $server;
    private int $mid = 0;
 
 
    public function __construct(ilECSSetting $server)
    {
        global $DIC;
 
        $this->logger = $DIC->logger()->wsrv();
 
        $this->server = $server;
    }
 
    public function getServer(): ilECSSetting
    {
        return $this->server;
    }
 
    public function getMid(): int
    {
        return $this->mid;
    }
 
    public function checkAllocationActivation(ilECSSetting $server, $a_content_id): ?bool
    {
        try {
            $crs_reader = new ilECSCourseConnector($server);
            $details = $crs_reader->getCourse($a_content_id, true);
            $this->mid = $details->getMySender();
 
            // Check if import is enabled
            $part = ilECSParticipantSetting::getInstance($this->getServer()->getServerId(), $this->getMid());
            if (!$part->isImportEnabled()) {
                $this->logger->info(__METHOD__ . ': Import disabled for mid ' . $this->getMid());
                return false;
            }
            // Check course allocation setting
            $gl_settings = ilECSNodeMappingSettings::getInstanceByServerMid(
                $this->getServer()->getServerId(),
                $this->getMid()
            );
            $enabled = $gl_settings->isCourseAllocationEnabled();
            if (!$enabled) {
                $this->logger->info(__METHOD__ . ': Course allocation disabled for ' . $this->getMid());
            }
            return $enabled;
        } catch (ilECSConnectorException $e) {
            $this->logger->error(__METHOD__ . ': Reading course details failed with message ' . $e->getMessage());
            return false;
        }
    }
 
 
    public function handleCreate(ilECSSetting $server, $a_content_id): bool
    {
        if (!$this->checkAllocationActivation($server, $a_content_id)) {
            return true;
        }
        try {
            $course = $this->readCourse($server, $a_content_id);
            $this->logger->info(__METHOD__ . ': ' . print_r($course, true));
            $this->doUpdate($a_content_id, $course);
            return true;
        } catch (ilECSConnectorException $e) {
            $this->logger->error(__METHOD__ . ': Course creation failed  with mesage ' . $e->getMessage());
            return false;
        }
        return true;
    }
 
    public function handleDelete(ilECSSetting $server, $a_content_id): bool
    {
        // nothing todo
        return true;
    }
 
    public function handleUpdate(ilECSSetting $server, $a_content_id): bool
    {
        if (!$this->checkAllocationActivation($server, $a_content_id)) {
            return true;
        }
 
        try {
            $course = $this->readCourse($server, $a_content_id);
            $this->doUpdate($a_content_id, $course);
            return true;
        } catch (ilECSConnectorException $e) {
            $this->logger->error(__METHOD__ . ': Course creation failed  with mesage ' . $e->getMessage());
            return false;
        }
        return true;
    }
 
 
    protected function doUpdate(int $a_content_id, $course): void
    {
        $this->logger->info(__METHOD__ . ': Starting course creation/update');
 
        $creation_handler = new ilECSCourseCreationHandler($this->getServer(), $this->mid);
        $creation_handler->handle($a_content_id, $course);
    }
 
    private function readCourse(ilECSSetting $server, $a_content_id)
    {
        return (new ilECSCourseConnector($server))->getCourse($a_content_id, false);
    }
}