ChSimpleMessengerDb.php

Go to the documentation of this file.

<?php
 
require_once(CH_DIRECTORY_PATH_CLASSES . 'ChWsbModuleDb.php');
 
class ChSimpleMessengerDb extends ChWsbModuleDb
{
    var $_oConfig;
 
    var $sTablePrefix;
 
    function __construct(&$oConfig)
    {
        parent::__construct();
 
        $this->_oConfig     = $oConfig;
        $this->sTablePrefix = $oConfig->getDbPrefix();
    }
 
    function createMessage($iSenderId, $iRecipientId, $sMessage)
    {
        // procces vars
        $iSenderId    = (int)$iSenderId;
        $iRecipientId = (int)$iRecipientId;
        $sMessage     = process_db_input($sMessage, CH_TAGS_NO_ACTION);
 
        $sQuery =
            "
                INSERT INTO
                    `{$this -> sTablePrefix}messages`
                SET
                    `SenderID`      = {$iSenderId},
                    `RecipientID`   = {$iRecipientId},
                    `Message`       = '{$sMessage}'
            ";
 
        return (int)$this->query($sQuery) > 0 ? $this->lastId() : false;
    }
 
    function closeChatWindow($iRecipientId, $iLoggedMember)
    {
        $iRecipientId  = (int)$iRecipientId;
        $iLoggedMember = (int)$iLoggedMember;
 
        // define the sender's id;
        $sQuery =
            "
                SELECT
                    `SenderID`
                FROM
                    `{$this -> sTablePrefix}messages`
                WHERE
                    (
                        `SenderID` = {$iLoggedMember}
                            AND
                        `RecipientID` = {$iRecipientId}
                    )
                        OR
                    (
                        `SenderID` = {$iRecipientId}
                            AND
                        `RecipientID` = {$iLoggedMember}
                    )
                ORDER BY
                    `Date` DESC
                LIMIT 1
            ";
 
        $iSenderId = $this->getOne($sQuery);
        $sFieldId  = ($iSenderId == $iLoggedMember) ? 'SenderStatus' : 'RecipientStatus';
 
        $sQuery =
            "
                UPDATE
                    `{$this -> sTablePrefix}messages`
                SET
                    `{$sFieldId}` = 'close'
                WHERE
                    (
                        `SenderID` = {$iLoggedMember}
                            AND
                        `RecipientID` = {$iRecipientId}
                    )
                        OR
                    (
                        `SenderID` = {$iRecipientId}
                            AND
                        `RecipientID` = {$iLoggedMember}
                    )
                ORDER BY
                    `Date` DESC
                LIMIT 1
            ";
 
        return $this->query($sQuery);
    }
 
    function deleteAllMessagesHistory($iProfileId)
    {
        $iProfileId = (int)$iProfileId;
 
        $sQuery =
            "
                DELETE FROM
                    `{$this -> sTablePrefix}messages`
                WHERE
                    `SenderID` = {$iProfileId}
                        OR
                    `RecipientID` = {$iProfileId}
            ";
 
        $this->query($sQuery);
    }
 
    function deleteMessagesHistory($iSender, $iRecipient, $iAllowCountMessages)
    {
        $iSender             = (int)$iSender;
        $iRecipient          = (int)$iRecipient;
        $iAllowCountMessages = (int)$iAllowCountMessages;
 
        $sQuery =
            "
                SELECT
                    COUNT(*)
                FROM
                    `{$this -> sTablePrefix}messages`
                WHERE
                    (
                        `SenderID` = {$iSender}
                            AND
                        `RecipientID` = {$iRecipient}
                    )
                        OR
                    (
                        `SenderID` = {$iRecipient}
                            AND
                        `RecipientID` = {$iSender}
                    )
            ";
 
        $iMessageCount = (int)$this->getOne($sQuery);
        if ($iMessageCount > $iAllowCountMessages) {
            // delete all unnecessary messages ;
            $iRowsDelete = $iMessageCount - $iAllowCountMessages;
 
            $sQuery =
                "
                    DELETE FROM
                        `{$this -> sTablePrefix}messages`
                    WHERE
                        (
                            `SenderID` = {$iSender}
                                AND
                            `RecipientID` = {$iRecipient}
                        )
                            OR
                        (
                            `SenderID` = {$iRecipient}
                                AND
                            `RecipientID` = {$iSender}
                        )
                    ORDER BY `ID`
                    LIMIT {$iRowsDelete}
                ";
 
            $this->query($sQuery);
        }
    }
 
    function getLastMessagesId($iRecipient, $iSender)
    {
        $iRecipient = (int)$iRecipient;
        $iSender    = (int)$iSender;
 
        $sQuery =
            "
                SELECT
                    `ID`
                FROM
                    `{$this -> sTablePrefix}messages`
                WHERE
                    (
                        `SenderID` = {$iSender}
                            AND
                        `RecipientID` = {$iRecipient}
                            OR
                        `SenderID` = {$iRecipient}
                            AND
                        `RecipientID` = {$iSender}
                    )
                ORDER BY
                    `ID` DESC
                LIMIT 1
            ";
 
        return $this->getOne($sQuery);
    }
 
    function getChatBoxesCount($iSender)
    {
        $iSender = (int)$iSender;
 
        $sQuery =
            "
                SELECT
                    DISTINCT IF(`{$this -> sTablePrefix}messages`.`SenderID` = {$iSender}, `{$this -> sTablePrefix}messages`.`RecipientID`, `{$this -> sTablePrefix}messages`.`SenderID`) AS `RecipientID`
                FROM
                    `{$this -> sTablePrefix}messages`
                INNER JOIN
                    `Profiles`
                ON
                    `Profiles`.`ID` = {$iSender}
                WHERE
                    `{$this -> sTablePrefix}messages`.`RecipientID` = {$iSender}
                        OR
                    `{$this -> sTablePrefix}messages`.`SenderID` = {$iSender}
            ";
 
        $aSenders          = $this->getAll($sQuery);
        $aProcessedSenders = array();
 
        // procces all recived id;
        foreach ($aSenders as $iKey => $aItems) {
            $aItems['RecipientID'] = (int)$aItems['RecipientID'];
 
            $sQuery =
                "
                    SELECT
                        IF(`SenderID` = {$aItems['RecipientID']}, `SenderStatus`, `RecipientStatus`) AS `Status`
                    FROM
                        `{$this -> sTablePrefix}messages`
                    WHERE
                        (
                            `RecipientID` = {$aItems['RecipientID']}
                                AND
                            `SenderID` = {$iSender}
                        )
                            OR
                        (
                            `RecipientID` = {$iSender}
                                AND
                            `SenderID` = {$aItems['RecipientID']}
                        )
                        ORDER BY
                            `Date` DESC
                        LIMIT 1
                ";
 
            if ($this->getOne($sQuery) != 'close') {
                $aProcessedSenders[] = $aItems['RecipientID'];
            }
        }
 
        return $aProcessedSenders;
    }
 
    function getMessagesCount($iRecipient, $iSender)
    {
        $iRecipient = (int)$iRecipient;
        $iSender    = (int)$iSender;
 
        $sQuery =
            "
                SELECT
                    COUNT(*)
                FROM
                    `{$this -> sTablePrefix}messages`
                WHERE
                    (
                        `SenderID` = {$iSender}
                            AND
                        `RecipientID` = {$iRecipient}
                    )
                        OR
                    (
                        `SenderID` = {$iRecipient}
                            AND
                        `RecipientID` = {$iSender}
                    )
            ";
 
        return $this->getOne($sQuery);
    }
 
    function getHistoryList(&$aCoreSettings, $iRecipient, $iSender, $iLastMessageId = 0, $iMessageLimit = 0)
    {
        $iRecipient     = (int)$iRecipient;
        $iSender        = (int)$iSender;
        $iLastMessageId = (int)$iLastMessageId;
        $iMessageLimit  = (int)$iMessageLimit;
 
        // define the rows limit ;
        $sRowsLimit = ($iMessageLimit) ? " LIMIT {$iMessageLimit}" : null;
 
        // check if chat history is enabled now;
        if ($aCoreSettings['save_chat_history'] && !$sRowsLimit) {
 
            $iMessagesCount = $this->getMessagesCount($iRecipient, $iSender);
            $iLimitFrom     = $iMessagesCount - $aCoreSettings['number_visible_messages'];
            $sRowsLimit     = " LIMIT {$iLimitFrom}, 18446744073709551615";
        }
 
        $sQuery =
            "
                SELECT
                   `ID`, `Message`, `SenderID`,
                   `RecipientID`, UNIX_TIMESTAMP(`Date`) AS `DateTS`
                FROM
                    `{$this -> sTablePrefix}messages`
                WHERE
                    (
                        (
                           `SenderID` = {$iSender}
                                AND
                            `RecipientID` = {$iRecipient}
                        )
                                OR
                        (
                            `SenderID` = {$iRecipient}
                                AND
                            `RecipientID` = {$iSender}
                        )
                    )
                        AND
                    (
                        `ID` > {$iLastMessageId}
                    )
                ORDER BY
                    `ID`
                {$sRowsLimit}
            ";
 
        return $this->getAll($sQuery);
    }
 
    function getNewChatBoxes($iRecipientId, $aRegBoxes = array())
    {
        $iRecipientId = (int)$iRecipientId;
 
        // define registered chat boxes;
        $sFilter = '';
        if ($aRegBoxes && is_array($aRegBoxes)) {
            foreach ($aRegBoxes as $iKey => $aItem) {
                $iKey = (int)$iKey;
                $sFilter .= " AND (`{$this -> sTablePrefix}messages`.`SenderID` <> {$iKey}  AND  `{$this -> sTablePrefix}messages`.`RecipientID` <> {$iKey})";
            }
        }
 
        $sQuery =
            "
                SELECT
                    DISTINCT IF(`{$this -> sTablePrefix}messages`.`SenderID` = {$iRecipientId},  `{$this -> sTablePrefix}messages`.`RecipientID`,  `{$this -> sTablePrefix}messages`.`SenderID`) AS `RecipientID`
                FROM
                    `{$this -> sTablePrefix}messages`
                INNER JOIN
                    `Profiles`
                ON
                    `Profiles`.`ID` = `RecipientID`
                WHERE
                (
                    `{$this -> sTablePrefix}messages`.`RecipientID` = {$iRecipientId}
                        OR
                    `{$this -> sTablePrefix}messages`.`SenderID` = {$iRecipientId}
                )
                    {$sFilter}
            ";
 
        $aSenders          = $this->getAll($sQuery);
        $aProcessedSenders = array();
 
        // procces all recived id;
        foreach ($aSenders as $iKey => $aItems) {
            $aItems['RecipientID'] = (int)$aItems['RecipientID'];
 
            $sQuery =
                "
                    SELECT
                        IF(`SenderID` = {$aItems['RecipientID']}, `SenderStatus`, `RecipientStatus`) AS `Status`
                    FROM
                        `{$this -> sTablePrefix}messages`
                    WHERE
                        (
                            `RecipientID` = {$aItems['RecipientID']}
                                AND
                            `SenderID` = {$iRecipientId}
                        )
                            OR
                        (
                            `RecipientID` = {$iRecipientId}
                                AND
                            `SenderID` = {$aItems['RecipientID']}
                        )
                        ORDER BY
                            `Date` DESC
                        LIMIT 1
                ";
 
            if ($this->getOne($sQuery) != 'close') {
                $aProcessedSenders[] = $aItems['RecipientID'];
            }
        }
 
        return $aProcessedSenders;
    }
 
    function createPrivacyGroup($iMemberId, $iGroupValue = 0)
    {
        $iMemberId   = (int)$iMemberId;
        $iGroupValue = (int)$iGroupValue;
 
        $sQuery = "SELECT COUNT(*) FROM `{$this -> sTablePrefix}privacy` WHERE `author_id` = {$iMemberId}";
        if ($this->getOne($sQuery)) {
            // update existeng';
            $sQuery = "UPDATE `{$this -> sTablePrefix}privacy` SET `allow_contact_to` = {$iGroupValue} WHERE `author_id` = {$iMemberId}";
            $this->query($sQuery);
        } else {
            // create new;
            $sQuery = "INSERT INTO `{$this -> sTablePrefix}privacy` SET `allow_contact_to` = {$iGroupValue}, `author_id` = {$iMemberId}";
            $this->query($sQuery);
        }
    }
 
    function getPrivacyGroupValue($iMemberId)
    {
        $iMemberId = (int)$iMemberId;
 
        $sQuery = "SELECT `allow_contact_to` FROM `{$this -> sTablePrefix}privacy` WHERE `author_id` = {$iMemberId}";
 
        return $this->getOne($sQuery);
    }
 
    function shieldData($sData)
    {
        return process_db_input($sData, CH_TAGS_NO_ACTION);
    }
}