class.ilECSCommunityReader.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
class ilECSCommunityReader
{
    private static ?array $instances = null;
 
    private int $position = 0;
 
    private ilLogger $logger;
    private ilECSSetting $settings;
    private ilECSConnector $connector;
    private ilDBInterface $database;
 
    private array $communities = array();
    private array $participants = array();
    private array $own_ids = array();
 
    private function __construct(ilECSSetting $setting)
    {
        global $DIC;
 
        $this->logger = $DIC->logger()->wsrv();
        $this->logger->debug(print_r($setting->getServerId(), true));
        $this->database = $DIC->database();
        $this->settings = $setting;
 
        $this->connector = new ilECSConnector($this->settings);
 
        $this->read();
        $this->logger->debug(__METHOD__ . ': Finished reading communities');
    }
 
    public static function getInstanceByServerId(int $a_server_id): \ilECSCommunityReader
    {
        return self::$instances[$a_server_id] ?? (self::$instances[$a_server_id] = new ilECSCommunityReader(ilECSSetting::getInstanceByServerId($a_server_id)));
    }
 
    public function getServer(): \ilECSSetting
    {
        return $this->settings;
    }
 
    public function getParticipants(): array
    {
        return $this->participants;
    }
 
 
    public function getOwnMIDs(): array
    {
        return $this->own_ids ?: [];
    }
 
    public function getCommunities(): array
    {
        return $this->communities ?: [];
    }
 
    public function getCommunityById($a_id): ?ilECSCommunity
    {
        foreach ($this->communities as $community) {
            if ($community->getId() === $a_id) {
                return $community;
            }
        }
        return null;
    }
 
    public function getParticipantsByPid(int $a_pid): array
    {
        $participants = [];
        foreach ($this->getCommunities() as $community) {
            foreach ($community->getParticipants() as $participant) {
                if ($participant->getPid() === $a_pid) {
                    $participants[] = $participant;
                }
            }
        }
        return $participants;
    }
 
    public function getParticipantByMID($a_mid)
    {
        return $this->participants[$a_mid] ?? false;
    }
 
    public function getParticipantNameByMid($a_mid): string
    {
        return isset($this->participants[$a_mid]) ?
            $this->participants[$a_mid]->getParticipantName() :
            '';
    }
 
    public function getCommunityByMID(int $a_mid): ?\ilECSCommunity
    {
        foreach ($this->communities as $community) {
            foreach ($community->getParticipants() as $part) {
                if ($part->getMID() === $a_mid) {
                    return $community;
                }
            }
        }
        return null;
    }
 
    public function getEnabledParticipants(): array
    {
        $ps = ilECSParticipantSettings::getInstanceByServerId($this->getServer()->getServerId());
        $en = $ps->getEnabledParticipants();
        $e_part = [];
        foreach ($this->getCommunities() as $community) {
            foreach ($community->getParticipants() as $participant) {
                if (in_array($participant->getMid(), $en, true)) {
                    $e_part[] = $participant;
                }
            }
        }
        return $e_part;
    }
 
    private function read(): void
    {
        try {
            $res = $this->connector->getMemberships();
 
            if (!is_array($res->getResult())) {
                return;
            }
            foreach ($res->getResult() as $community) {
                $tmp_comm = new ilECSCommunity($community);
                foreach ($tmp_comm->getParticipants() as $participant) {
                    $this->participants[$participant->getMID()] = $participant;
                    if ($participant->isSelf()) {
                        $this->own_ids[] = $participant->getMID();
                    }
                }
                $this->communities[] = $tmp_comm;
            }
 
            $this->createNewParticipants();
        } catch (ilECSConnectorException $e) {
            $this->logger->error(__METHOD__ . ': Error connecting to ECS server. ' . $e->getMessage());
            throw $e;
        }
    }
 
    private function createNewParticipants(): void
    {
        $query = $this->database->queryF(
            "SELECT mid FROM ecs_part_settings WHERE sid = %s",
            [ilDBConstants::T_INTEGER],
            [$this->connector->getServer()->getServerId()]
        );
        $existing_ids = array_map(fn($row) => $row['mid'], $this->database->fetchAll($query));
        $missing_ids = array_diff(array_keys($this->participants), $existing_ids);
 
        foreach ($missing_ids as $mid) {
            $participant = $this->getParticipantByMID($mid);
            $community = $this->getCommunityByMID($mid);
 
            $part_settings = ilECSParticipantSetting::getInstance($this->getServer()->getServerId(), $mid);
            $part_settings->setTitle($participant->getParticipantName());
            $part_settings->setCommunityName($community->getTitle());
            $part_settings->update();
        }
    }
}