class.ilECSRemoteUserRepository.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

class ilECSRemoteUserRepository
{
    private ilDBInterface $db;

    public function __construct()
    {
        global $DIC;

        $this->db = $DIC['ilDB'];
    }

    private function exists(
        int $sid,
        int $mid,
        int $usr_id
    ): bool {
        $query = 'SELECT eru_id FROM ecs_remote_user ' .
            'WHERE sid = ' . $this->db->quote($sid, 'integer') . ' ' .
            'AND mid = ' . $this->db->quote($mid, 'integer') . ' ' .
            'AND usr_id = ' . $this->db->quote($usr_id, 'integer');
        $res = $this->db->query($query);
        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return (bool) $row->eru_id;
        }
        return false;
    }

    private function remoteUserExists(
        int $sid,
        int $mid,
        string $remote_usr_id
    ): bool {
        $query = 'SELECT eru_id FROM ecs_remote_user ' .
            'WHERE sid = ' . $this->db->quote($sid, 'integer') . ' ' .
            'AND mid = ' . $this->db->quote($mid, 'integer') . ' ' .
            'AND remote_usr_id = ' . $this->db->quote($remote_usr_id, 'text');
        $res = $this->db->query($query);
        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return (bool) $row->eru_id;
        }
        return false;
    }

    public function createIfNotExisting(
        int $sid,
        int $mid,
        int $usr_id,
        string $remote_usr_id
    ): void {
        if (!$this->exists($sid, $mid, $usr_id)) {
            $next_id = $this->db->nextId('ecs_remote_user');
            $query = 'INSERT INTO ecs_remote_user (eru_id, sid, mid, usr_id, remote_usr_id) ' .
                'VALUES( ' .
                $this->db->quote($next_id) . ', ' .
                $this->db->quote($sid, 'integer') . ', ' .
                $this->db->quote($mid, 'integer') . ', ' .
                $this->db->quote($usr_id, 'integer') . ', ' .
                $this->db->quote($remote_usr_id, 'text') . ' ' .
                ')';
            $this->db->manipulate($query);
        }
    }
    public function createIfRemoteUserNotExisting(
        int $sid,
        int $mid,
        int $usr_id,
        string $remote_usr_id
    ): void {
        if (!$this->remoteUserExists($sid, $mid, $remote_usr_id)) {
            $next_id = $this->db->nextId('ecs_remote_user');
            $query = 'INSERT INTO ecs_remote_user (eru_id, sid, mid, usr_id, remote_usr_id) ' .
                'VALUES( ' .
                $this->db->quote($next_id) . ', ' .
                $this->db->quote($sid, 'integer') . ', ' .
                $this->db->quote($mid, 'integer') . ', ' .
                $this->db->quote($usr_id, 'integer') . ', ' .
                $this->db->quote($remote_usr_id, 'text') . ' ' .
                ')';
            $this->db->manipulate($query);
        }
    }
    public function getECSRemoteUserById(int $remoteUserId): ?ilECSRemoteUser
    {
        $query = 'SELECT * FROM ecs_remote_user ' .
            'WHERE eru_id = ' . $this->db->quote($remoteUserId, 'integer');
        $res = $this->db->query($query);
        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return new ilECSRemoteUser(
                $remoteUserId,
                (int) $row->sid,
                (int) $row->mid,
                (int) $row->usr_id,
                $row->remote_usr_id
            );
        }
        return null;
    }

    public function getECSRemoteUserByUsrId(int $a_usr_id): ?ilECSRemoteUser
    {
        $query = 'SELECT eru_id FROM ecs_remote_user ' .
            'WHERE usr_id = ' . $this->db->quote($a_usr_id, 'integer');
        $res = $this->db->query($query);
        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $this->getECSRemoteUserById((int) $row->eru_id);
        }
        return null;
    }

    public function getECSRemoteUserByRemoteId(string $remoteUserId): ?ilECSRemoteUser
    {
        $query = 'SELECT eru_id FROM ecs_remote_user ' .
            'WHERE remote_usr_id = ' . $this->db->quote($remoteUserId, 'text');
        $res = $this->db->query($query);
        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $this->getECSRemoteUserById($row->eru_id);
        }
        return null;
    }
}