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 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->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;
            }
        } catch (ilECSConnectorException $e) {
            $this->logger->error(__METHOD__ . ': Error connecting to ECS server. ' . $e->getMessage());
            throw $e;
        }
    }
}