movim_ynh/sources/app/models/message/MessageDAO.php

<?php

namespace modl;

class MessageDAO extends SQL {
    function set(Message $message) {
        $this->_sql = '
            update message
                set id              = :thread,
                    body            = :body,
                    html            = :html,
                    published       = :published,
                    delivered       = :delivered,
                    edited          = :edited

                where session       = :session
                    and id          = :id
                    and jidto       = :jidto
                    and jidfrom     = :jidfrom';

        $this->prepare(
            'Message',
            array(
                'thread'    => $message->newid, // FIXME
                'id'        => $message->id,
                'session'   => $message->session,
                'jidto'     => $message->jidto,
                'edited'    => $message->edited,
                'jidfrom'   => $message->jidfrom,
                'body'      => $message->body,
                'html'      => $message->html,
                'published' => $message->published,
                'delivered' => $message->delivered
            )
        );

        $this->run('Message');

        if(!$this->_effective) {
            $this->_sql = '
                insert into message
                (
                id,
                session,
                jidto,
                jidfrom,
                resource,
                type,
                subject,
                thread,
                body,
                html,
                published,
                delivered,
                sticker)
                values(
                    :id,
                    :session,
                    :jidto,
                    :jidfrom,
                    :resource,
                    :type,
                    :subject,
                    :thread,
                    :body,
                    :html,
                    :published,
                    :delivered,
                    :sticker
                    )';

            $this->prepare(
                'Message',
                array(
                    'id'        => $message->id,
                    'session'   => $message->session,
                    'jidto'     => $message->jidto,
                    'jidfrom'   => $message->jidfrom,
                    'resource'  => $message->resource,
                    'type'      => $message->type,
                    'subject'   => $message->subject,
                    'thread'    => $message->thread,
                    'body'      => $message->body,
                    'html'      => $message->html,
                    'published' => $message->published,
                    'delivered' => $message->delivered,
                    'sticker'   => $message->sticker
                )
            );
        }

        return $this->run('Message');
    }

    function getId($id)
    {
        $this->_sql = '
            select * from message
            where session = :session
                and id = :id
            limit 1';

        $this->prepare(
            'Message',
            array(
                'session' => $this->_user,
                'id' => $id
            )
        );

        return $this->run('Message', 'item');
    }

    function getLastItem($to)
    {
        $this->_sql = '
            select * from message
            where session = :session
                and jidto = :jidto
                and jidfrom = :jidfrom
            order by published desc
            limit 1';

        $this->prepare(
            'Message',
            array(
                'session' => $this->_user,
                'jidto'   => $to,
                'jidfrom' => $this->_user
            )
        );

        return $this->run('Message', 'item');
    }

    function getAll($limitf = false, $limitr = false)
    {
        $this->_sql = '
            select * from message
            where session = :session
            order by published desc';

        if($limitr)
            $this->_sql = $this->_sql.' limit '.$limitr.' offset '.$limitf;

        $this->prepare(
            'Message',
            array(
                'session' => $this->_user
            )
        );

        return $this->run('Message');
    }

    function getContact($jid, $limitf = false, $limitr = false)
    {
        $this->_sql = '
            select * from message
            where session = :session
                and (jidfrom = :jidfrom
                or jidto = :jidto)
            order by published desc';

        if($limitr)
            $this->_sql = $this->_sql.' limit '.$limitr.' offset '.$limitf;

        $this->prepare(
            'Message',
            array(
                'session' => $this->_user,
                'jidfrom' => $jid,
                'jidto' => $jid
            )
        );

        return $this->run('Message');
    }

    function deleteContact($jid) {
        $this->_sql = '
            delete from message
            where session = :session
                and (jidfrom = :jidfrom
                or jidto   = :jidto)';

        $this->prepare(
            'Message',
            array(
                'jidfrom'   => $jid,
                'jidto'     => $jid,
                'session' => $this->_user
            )
        );

        return $this->run('Message');
    }

    function getHistory($jid, $date, $limit = 30) {
        $this->_sql = '
            select * from message
            where session = :session
                and (jidfrom = :jidfrom
                or jidto = :jidto)
                and published < :published
            order by published desc';

        $this->_sql .= ' limit '.(string)$limit;

        $this->prepare(
            'Message',
            array(
                'session' => $this->_user,
                'jidfrom' => $jid,
                'jidto' => $jid,
                'published' => $date
            )
        );

        return $this->run('Message');
    }

    function getRoomSubject($room) {
        $this->_sql = '
            select * from message
            where jidfrom = :jidfrom
              and subject != \'\'
              order by published desc
              limit 1';

        $this->prepare(
            'Message',
            array(
                'jidfrom'   => $room
            )
        );

        return $this->run('Message', 'item');
    }

    function clearMessage() {
        $this->_sql = '
            delete from message
            where session = :session';

        $this->prepare(
            'Message',
            array(
                'session' => $this->_user
            )
        );

        return $this->run('Message');
    }
}