class.ilBuddySystemRelationRepository.php

Go to the documentation of this file.

<?php
/* 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 $usr_id;

    public function __construct($usr_id)
    {
        global $DIC;

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

    public function getDatabaseAdapter()
    {
        return $this->db;
    }

    public function setDatabaseAdapter(ilDBInterface $db)
    {
        $this->db = $db;
    }

    public function getAll()
    {
        $relations = array();

        $res = $this->db->queryF(
            "
                        SELECT usr_id, buddy_usr_id, ts, %s rel_type FROM buddylist WHERE usr_id = %s
                        UNION
                        SELECT usr_id, buddy_usr_id, ts, (CASE WHEN ignored = 1 THEN %s ELSE %s END) rel_type FROM buddylist_requests WHERE usr_id = %s OR buddy_usr_id = %s
                        ",
            array(
                'text', 'integer', 'text', 'text', 'integer', 'integer'
            ),
            array(
                self::TYPE_APPROVED, $this->usr_id, self::TYPE_IGNORED, self::TYPE_REQUESTED, $this->usr_id, $this->usr_id
            )
        );

        while ($row = $this->db->fetchAssoc($res)) {
            $relation = $this->getRelationByDatabaseRecord($row);
            $relation->setUserId($row['usr_id']);
            $relation->setBuddyUserId($row['buddy_usr_id']);
            $relation->setTimestamp($row['ts']);
            $relation->setIsOwnedByRequest($relation->getUserId() == $this->usr_id);
            $key = $this->usr_id == $relation->getUserId() ? $relation->getBuddyUserId() : $relation->getUserId();
            $relations[$key] = $relation;
        }

        return $relations;
    }

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

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

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

    private function addToApprovedBuddies(ilBuddySystemRelation $relation)
    {
        $this->db->replace(
            'buddylist',
            array(
                'usr_id' => array('integer', $relation->getUserId()),
                'buddy_usr_id' => array('integer', $relation->getBuddyUserId())
            ),
            array(
                'ts' => array('integer', $relation->getTimestamp())
            )
        );

        $this->db->replace(
            'buddylist',
            array(
                'usr_id' => array('integer', $relation->getBuddyUserId()),
                'buddy_usr_id' => array('integer', $relation->getUserId())
            ),
            array(
                'ts' => array('integer', $relation->getTimestamp())
            )
        );
    }

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

        $this->db->manipulateF(
            "DELETE FROM buddylist WHERE buddy_usr_id = %s AND usr_id = %s",
            array('integer', 'integer'),
            array($relation->getUserId(), $relation->getBuddyUserId())
        );
    }

    private function addToRequestedBuddies(ilBuddySystemRelation $relation, $ignored)
    {
        $this->db->replace(
            'buddylist_requests',
            array(
                'usr_id' => array('integer', $relation->getUserId()),
                'buddy_usr_id' => array('integer', $relation->getBuddyUserId())
            ),
            array(
                'ts' => array('integer', $relation->getTimestamp()),
                'ignored' => array('integer', (int) $ignored)
            )
        );
    }

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

        $this->db->manipulateF(
            "DELETE FROM buddylist_requests WHERE buddy_usr_id = %s AND usr_id = %s",
            array('integer', 'integer'),
            array($relation->getUserId(), $relation->getBuddyUserId())
        );
    }

    public function save(ilBuddySystemRelation $relation)
    {
        $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();
    }
}