class.ilBuddySystemRelationRepository.php

Go to the documentation of this file.

<?php declare(strict_types=1);
/* Copyright (c) 1998-2015 ILIAS open source, Extended GPL, see docs/LICENSE */

class ilBuddySystemRelationRepository
{
    const TYPE_APPROVED = 'app';
    const TYPE_REQUESTED = 'req';
    const TYPE_IGNORED = 'ign';

    protected $db;

    protected $usrId;

    public function __construct(int $usrId)
    {
        global $DIC;

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

    public function getAll() : array
    {
        $relations = [];

        $res = $this->db->queryF(
            "
                        SELECT
                               buddylist.usr_id, buddylist.buddy_usr_id, buddylist.ts, %s rel_type
            FROM buddylist
                        INNER JOIN usr_data ud
                ON ud.usr_id = buddylist.usr_id
                        WHERE buddylist.usr_id = %s
                        UNION
                        SELECT
                               buddylist_requests.usr_id, buddylist_requests.buddy_usr_id, buddylist_requests.ts, (CASE WHEN ignored = 1 THEN %s ELSE %s END) rel_type
                        FROM buddylist_requests
                        INNER JOIN usr_data ud ON ud.usr_id = buddylist_requests.usr_id
                        INNER JOIN usr_data udbuddy ON udbuddy.usr_id = buddylist_requests.buddy_usr_id
                        WHERE buddylist_requests.usr_id = %s OR buddylist_requests.buddy_usr_id = %s
                        ",
            [
                'text',
                'integer',
                'text',
                'text',
                'integer',
                'integer'
            ],
            [
                self::TYPE_APPROVED,
                $this->usrId,
                self::TYPE_IGNORED,
                self::TYPE_REQUESTED,
                $this->usrId,
                $this->usrId
            ]
        );

        while ($row = $this->db->fetchAssoc($res)) {
            $relation = $this->getRelationByDatabaseRecord($row);
            $relation->setUsrId((int) $row['usr_id']);
            $relation->setBuddyUsrId((int) $row['buddy_usr_id']);
            $relation->setTimestamp((int) $row['ts']);
            $relation->setIsOwnedByActor($relation->getUsrId() === $this->usrId);
            $key = $this->usrId === $relation->getUsrId() ? $relation->getBuddyUsrId() : $relation->getUsrId();
            $relations[$key] = $relation;
        }

        return $relations;
    }

    private function getRelationByDatabaseRecord($row)
    {
        if (self::TYPE_APPROVED === $row['rel_type']) {
            return new ilBuddySystemRelation(new ilBuddySystemLinkedRelationState());
        } elseif (self::TYPE_IGNORED === $row['rel_type']) {
            return new ilBuddySystemRelation(new ilBuddySystemIgnoredRequestRelationState());
        }

        return new ilBuddySystemRelation(new ilBuddySystemRequestedRelationState());
    }

    public function destroy()
    {
        $this->db->queryF(
            "DELETE FROM buddylist WHERE usr_id = %s OR buddy_usr_id = %s",
            ['integer', 'integer'],
            [$this->usrId, $this->usrId]
        );

        $this->db->queryF(
            "DELETE FROM buddylist_requests WHERE usr_id = %s OR buddy_usr_id = %s",
            ['integer', 'integer'],
            [$this->usrId, $this->usrId]
        );
    }

    private function addToApprovedBuddies(ilBuddySystemRelation $relation)
    {
        $this->db->replace(
            'buddylist',
            [
                'usr_id' => ['integer', $relation->getUsrId()],
                'buddy_usr_id' => ['integer', $relation->getBuddyUsrId()]
            ],
            [
                'ts' => ['integer', $relation->getTimestamp()]
            ]
        );

        $this->db->replace(
            'buddylist',
            [
                'usr_id' => ['integer', $relation->getBuddyUsrId()],
                'buddy_usr_id' => ['integer', $relation->getUsrId()]
            ],
            [
                'ts' => ['integer', $relation->getTimestamp()]
            ]
        );
    }

    private function removeFromApprovedBuddies(ilBuddySystemRelation $relation)
    {
        $this->db->manipulateF(
            "DELETE FROM buddylist WHERE usr_id = %s AND buddy_usr_id = %s",
            ['integer', 'integer'],
            [$relation->getUsrId(), $relation->getBuddyUsrId()]
        );

        $this->db->manipulateF(
            "DELETE FROM buddylist WHERE buddy_usr_id = %s AND usr_id = %s",
            ['integer', 'integer'],
            [$relation->getUsrId(), $relation->getBuddyUsrId()]
        );
    }

    private function addToRequestedBuddies(ilBuddySystemRelation $relation, $ignored)
    {
        $this->db->replace(
            'buddylist_requests',
            [
                'usr_id' => ['integer', $relation->getUsrId()],
                'buddy_usr_id' => ['integer', $relation->getBuddyUsrId()]
            ],
            [
                'ts' => ['integer', $relation->getTimestamp()],
                'ignored' => ['integer', (int) $ignored]
            ]
        );
    }

    private function removeFromRequestedBuddies(ilBuddySystemRelation $relation)
    {
        $this->db->manipulateF(
            "DELETE FROM buddylist_requests WHERE usr_id = %s AND buddy_usr_id = %s",
            ['integer', 'integer'],
            [$relation->getUsrId(), $relation->getBuddyUsrId()]
        );

        $this->db->manipulateF(
            "DELETE FROM buddylist_requests WHERE buddy_usr_id = %s AND usr_id = %s",
            ['integer', 'integer'],
            [$relation->getUsrId(), $relation->getBuddyUsrId()]
        );
    }

    public function save(ilBuddySystemRelation $relation) : void
    {
        $ilAtomQuery = $this->db->buildAtomQuery();
        $ilAtomQuery->addTableLock('buddylist_requests');
        $ilAtomQuery->addTableLock('buddylist');

        $ilAtomQuery->addQueryCallable(function (ilDBInterface $ilDB) use ($relation) {
            if ($relation->isLinked()) {
                $this->addToApprovedBuddies($relation);
            } elseif ($relation->wasLinked()) {
                $this->removeFromApprovedBuddies($relation);
            }

            if ($relation->isRequested()) {
                $this->addToRequestedBuddies($relation, false);
            } elseif ($relation->isIgnored()) {
                $this->addToRequestedBuddies($relation, true);
            } elseif ($relation->wasRequested() || $relation->wasIgnored()) {
                $this->removeFromRequestedBuddies($relation);
            }
        });

        $ilAtomQuery->run();
    }
}