movim/app/widgets/Chat/Chat.php

<?php

/**
 * @package Widgets
 *
 * @file Chat.php
 * This file is part of MOVIM.
 * 
 * @brief A jabber chat widget.
 *
 * @author Guillaume Pasquet <etenil@etenilsrealm.nl>
 *
 * @version 1.0
 * @date 20 October 2010
 *
 * Copyright (C)2010 MOVIM project
 * 
 * See COPYING for licensing information.
 */

class Chat extends WidgetBase
{
    function WidgetLoad()
    {
        $this->addcss('chat.css');
        $this->addjs('chat.js');
        $this->registerEvent('message', 'onMessage');
        $this->registerEvent('messagepublished', 'onMessagePublished');
        $this->registerEvent('composing', 'onComposing');
        $this->registerEvent('paused', 'onPaused');
        $this->registerEvent('attention', 'onAttention');
        $this->registerEvent('presence', 'onPresence');

        $this->view->assign('chats', $this->prepareChats());
    }
    
    function onPresence($presence)
    {
        $arr = $presence->getPresence();

        $rc = new \modl\ContactDAO();
        $contact = $rc->getRosterItem(echapJid($presence->jid));

        if(isset($contact) && $contact->chaton == 2) {
            $txt = array(
                    1 => t('Online'),
                    2 => t('Away'),
                    3 => t('Do Not Disturb'),
                    4 => t('Extended Away'),
                    5 => t('Offline'),
                );
        
            
            $html = '
                <div class="message presence">
                    <span class="date">'.date('G:i', time()).'</span>'.
                    prepareString(htmlentities($txt[$arr['presence']], ENT_COMPAT, "UTF-8")).'
                </div>';

            RPC::call('movim_append',
                           'messages'.$arr['jid'],
                           $html); 
                           
            RPC::call('scrollTalk',
                           'messages'.$arr['jid']);
        } elseif(!isset($contact)) {
            //RPC::call('movim_fill', 'chats', $this->prepareChats());
            //RPC::call('scrollAllTalks');
        }
    }
    
    function onMessage($message)
    {
        if($message->session == $message->jidfrom) {
            $key = $message->jidfrom;
            $jid = $message->jidto;
        } else {
            $key = $message->jidto;
            $jid = $message->jidfrom;
        }

        if($message->session != $message->jidfrom)
            RPC::call('notify');

        $rd = new \modl\RosterLinkDAO();

        $rc = new \modl\ContactDAO();
        $contact = $rc->getRosterItem(echapJid($jid));
        
        if($contact != null && $contact->chaton == 0) {
            $contact->chaton = 2;
            $rd->setChat($jid, 2);
            
            $evt = new Event();
            $evt->runEvent('openchat');  

            RPC::call('movim_prepend',
                           'chats',
                           $this->prepareChat($contact));
            RPC::call('scrollAllTalks');
        } elseif($contact != null && $message->body != '') {
            $html = $this->prepareMessage($message);

            if($contact->chaton == 1) {
                RPC::call('colorTalk',
                            'messages'.$contact->jid);
            }
            
            RPC::call('movim_append',
                           'messages'.$contact->jid,
                           $html);
            
            if($message->session != $message->jidfrom)
                RPC::call('hideComposing',
                           $contact->jid); 
            if($message->session != $message->jidfrom)
                RPC::call('hidePaused',
                           $contact->jid); 
                           
            RPC::call('scrollTalk',
                           'messages'.$contact->jid);
        } 
    
        // Muc case
        elseif($message->ressource != '') {
            $html = $this->prepareMessage($message, true);
            RPC::call('movim_append',
                           'messages'.$message->jidfrom,
                           $html);
            RPC::call('scrollTalk',
                           'messages'.$message->jidfrom);
        }
    }
    
    function onMessagePublished($jid)
    {
        Notification::appendNotification(t('Message Published'), 'success');
    }
    
    function onComposing($jid)
    {       
        $rd = new \modl\RosterLinkDAO();
        $contact = $rd->get(echapJid($jid));
        
        if(in_array($contact->chaton, array(1, 2))) {
            RPC::call('showComposing',
                       $contact->jid);
                           
            RPC::call('scrollTalk',
                      'messages'.$contact->jid);
        }
    }

    function onPaused($jid)
    {        
        $rd = new \modl\RosterLinkDAO();
        $contact = $rd->get(echapJid($jid));
        
        if(in_array($contact->chaton, array(1, 2))) {
            RPC::call('showPaused',
                       $contact->jid);
                           
            RPC::call('scrollTalk',
                      'messages'.$contact->jid);
        }
    }
    
    function onAttention($jid)
    {        
        $rc = new \modl\ContactDAO();
        $contact = $rc->getRosterItem(echapJid($jid));
        
        $html = '
            <div style="font-weight: bold; color: black;" class="message" >
                <span class="date">'.date('G:i', time()).'</span>'.
                t('%s needs your attention', $contact->getTrueName()).'
            </div>';

        RPC::call('movim_append',
                       'messages'.$jid,
                       $html); 
                       
        RPC::call('scrollTalk',
                       'messages'.$jid);
    }
    
    
    /**
     * Open a new talk
     *
     * @param string $jid
     * @return void
     */
    function ajaxOpenTalk($jid) 
    {        
        $rc = new \modl\ContactDAO();
        $contact = $rc->getRosterItem(echapJid($jid));

        if(
            isset($contact) 
         && $contact->chaton == 0 
         && !in_array($contact->presence, array(5, 6))) {
             
            $contact->chaton = 2;
            
            $rd = new \modl\RosterLinkDAO();
            $rd->setChat(echapJid($jid), 2);

            RPC::call('movim_prepend',
                           'chats',
                           $this->prepareChat($contact));
                               
            RPC::call('scrollAllTalks');

            RPC::commit();
        }
        
        $evt = new Event();
        $evt->runEvent('openchat');
    }

    /**
     * Send an encrypted message
     *
     * @param string $to
     * @param string $message
     * @return void
     */
    function ajaxSendEncryptedMessage($to, $message, $muc = false, $ressource = false)
    {
        $this->ajaxSendMessage($to, $message, $muc, $ressource, true);
    }
    
    /**
     * Send a message
     *
     * @param string $to
     * @param string $message
     * @return void
     */
    function ajaxSendMessage($to, $message, $muc = false, $ressource = false, $encrypted = false)
    {        
        $m = new \modl\Message();
        
        $m->session     = $this->user->getLogin();
        $m->jidto      = echapJid($to);
        $m->jidfrom    = $this->user->getLogin();
    
        global $session;
        
        $m->type    = 'chat';
        $m->ressource = $session['ressource'];
    
        if($muc) {
            $m->type = 'groupchat';
            $m->ressource = $session['user'];
            $m->jidfrom = $to;
        }
        
        $m->body    = rawurldecode($message);
        
        $m->published = date('Y-m-d H:i:s');
        $m->delivered = date('Y-m-d H:i:s');
    
        $md = new \modl\MessageDAO();
        $md->set($m);

        $evt = new Event();
        $evt->runEvent('message', $m);  

        if($ressource != false)
            $to = $to.'/'.$ressource;
        
        // We decode URL codes to send the correct message to the XMPP server
        $m = new \moxl\MessagePublish();
        $m->setTo($to)
          //->setEncrypted($encrypted)
          ->setContent(htmlspecialchars(rawurldecode($message)));
        if($muc)
            $m->setMuc();
        $m->request();
    }

    /**
     * Send a "composing" message
     * 
     * @param string $to
     * @return void
     */
    function ajaxSendComposing($to)
    {
        $mc = new \moxl\MessageComposing();
        $mc->setTo($to)
           ->request();
    }

    /**
     * Send a "paused" message
     * 
     * @param string $to
     * @return void
     */
    function ajaxSendPaused($to)
    {
        $mp = new \moxl\MessagePaused();
        $mp->setTo($to)
           ->request();
    }
    
    /**
     * Close a talk
     *
     * @param string $jid
     * @return void
     */
    function ajaxCloseTalk($jid) 
    {                
        $rd = new \modl\RosterLinkDAO();
        $contact = $rd->get(echapJid($jid));

        /*foreach($contacts as $contact) {
            if(
                $contact->jid == echapJid($jid) 
                && (
                    (int)$contact->chaton == 1 
                 || (int)$contact->chaton == 2)
            ) {
                $contact->chaton = 0;
                $rd->setNow($contact);
            }
        }*/
        
        $contact->chaton = 0;
        $rd->setNow($contact);
        
        RPC::call('movim_delete',
                   'chat'.echapJid($jid));
        
        RPC::commit();
            
        $evt = new Event();
        $evt->runEvent('closechat');
    }
    
    function ajaxHideTalk($jid)
    {
        $rd = new \modl\RosterLinkDAO();
        $contact = $rd->get(echapJid($jid));
        
        if($contact->chaton == 1)
            $contact->chaton = 2;
        else 
            $contact->chaton = 1;
        $rd->setNow($contact);
        
        RPC::call('scrollTalk',
                   'messages'.$contact->jid);
        RPC::commit();
    }
    
    function prepareMessage($message, $muc = false) {
        if($message->body != '') {
            $html = '<div class="message ';
                if($message->session == $message->jidfrom)
                    $html.= 'me';
                   
            $content = $message->body;
                    
            if(preg_match("#^/me#", $message->body)) {
                $html .= ' own ';
                $content = '** '.substr($message->body, 4);
            }
            
            if(preg_match("#^\?OTR:#", $message->body)) {
                $html .= ' crypt ';
                $content = t('Encrypted message');
            }
            
            
            $c = new \modl\Contact();
                    
            $html .= '">
                <img class="avatar" src="'.$c->getPhoto('xs', $message->jidfrom).'" />
                <span class="date">'.date('H:i', strtotime($message->published)).'</span>';
            
            if($muc != false)
                $html .= '
                    <span class="ressource '.$this->colorNameMuc($message->ressource).'">'.
                        $message->ressource.'
                    </span>';
                
            $html.= prepareString(htmlentities($content, ENT_COMPAT, "UTF-8")).'</div>';
            return $html;
        } else {
            return '';
        }
    }
    
    function prepareChats()
    {
        $rc = new \modl\ContactDAO();
        $contacts = $rc->getRosterChat();
        
        $html = '';

        // Another filter to fix the database request
        $check = array();

        if(isset($contacts)) {
            foreach($contacts as $contact) {
                if(!in_array($contact->jid,$check)) {
                    $html .= trim($this->prepareChat($contact));
                    //$jid = $contact->jid;
                    array_push($check, $contact->jid);
                }
            }
        }
        
        $bk = Cache::c('bookmark');
        if(is_array($bk))
            foreach($bk as $b) {
                if($b['type'] == 'conference') 
                    $html .= trim($this->prepareMuc($b['jid']));
            }
        
        return $html;
    }
    
    function prepareMuc($jid)
    {
        // Zeu messages
        $md = new \modl\MessageDAO();
        $messages = $md->getContact($jid, 0, 10);
        
        $messageshtml = '';
        
        if(!empty($messages)) {
            $messages = array_reverse($messages);
            $day = '';
            foreach($messages as $m) {
                if($day != date('d',strtotime($m->published))) {
                    $messageshtml .= '<div class="message presence">'.prepareDate(strtotime($m->published), false).'</div>';
                    $day = date('d',strtotime($m->published));
                }
                $messageshtml .= $this->prepareMessage($m, true);
            }
        }
        
        // Zeu muc list
        $pd = new \modl\PresenceDAO();
        $presences = $pd->getJid($jid);

        $mucview = $this->tpl();
        $mucview->assign('jid', $jid);
        $mucview->assign('messageshtml', $messageshtml);
        $mucview->assign('muclist', $presences);
        $mucview->assign('toggle', 
                            $this->genCallAjax(
                                "ajaxToggleMuc", "'".$jid."'")
                        );
        $mucview->assign('sendmessage',
                            $this->genCallAjax(
                                'ajaxSendMessage', 
                                "'".$jid."'", 
                                "sendMessage(this, '".$jid."')",
                                "true"
                        ));
        
        $sess = \Session::start(APP_NAME);
        $state = $sess->get('muc'.$jid);
        
        if($state == 1) {
            $mucview->assign('tabstyle', 'style="display: none;"');            
            $mucview->assign('panelstyle', 'style="display: block;"');
        } else {
            $mucview->assign('tabstyle', '');            
            $mucview->assign('panelstyle', '');   
        }

        $html = $mucview->draw('_chat_muc', true);

        return $html;
    }
    
    function ajaxToggleMuc($jid)
    {
        $sess = \Session::start(APP_NAME);
        $state = $sess->get('muc'.$jid);
        if($state == 1)
            $sess->set('muc'.$jid, 0);
        else
            $sess->set('muc'.$jid, 1);
    }
    
    function colorNameMuc($jid)
    {
        $colors = array(
            0 => 'purple',
            1 => 'purple',
            2 => 'wine',
            3 => 'yellow',
            4 => 'orange',
            5 => 'green',
            6 => 'red',
            7 => 'blue');
            
        $s = base_convert($jid, 32, 8);
        return $colors[$s[7]];
    }
    
    // Prepare Chat
    function prepareChat($contact)
    {
        $md = new \modl\MessageDAO();
        $messages = $md->getContact(echapJid($contact->jid), 0, 10);
        
        $messageshtml = '';

        if($messages != null) {
            $messages = array_reverse($messages);
            
            $day = '';
            foreach($messages as $m) {
                if($day != date('d',strtotime($m->published))) {
                    $messageshtml .= '<div class="message presence">'.prepareDate(strtotime($m->published), false).'</div>';
                    $day = date('d',strtotime($m->published));
                }
                $messageshtml .= $this->prepareMessage($m);
            }
        }
        
        $style = '';
        $panelstyle='';
        $tabstyle ='';

        if($contact->chaton == 2) {
            $tabstyle = ' style="display: none;" ';
            $panelstyle = ' style="display: block;" ';
        }

        $chatview = $this->tpl();

        /*if($contact->publickey) {
            $chatview->assign('publickey', $contact->publickey);
            $chatview->assign(
                'send', 
                $this->genCallAjax(
                    'ajaxSendEncryptedMessage', 
                    "'".$contact->jid."'", 
                    "sendEncryptedMessage(this, '".$contact->jid."')",
                    "false", 
                    "'".$contact->ressource."'"
                )
            );
        } else {*/
            $chatview->assign(
                'send', 
                $this->genCallAjax(
                    'ajaxSendMessage', 
                    "'".$contact->jid."'", 
                    "sendMessage(this, '".$contact->jid."')",
                    "false", 
                    "'".$contact->ressource."'"
                )
            );
        //}
        
        $chatview->assign('contact', $contact);
        $chatview->assign('tabstyle', $tabstyle);
        $chatview->assign('panelstyle', $panelstyle);
        $chatview->assign('messageshtml', $messageshtml);
        $chatview->assign(
            'closetalk', 
            $this->genCallAjax("ajaxCloseTalk", "'".$contact->jid."'")
        );
        $chatview->assign(
            'hidetalk', 
            $this->genCallAjax("ajaxHideTalk", "'".$contact->jid."'")
        );

        $chatview->assign(
            'composing', 
            $this->genCallAjax(
                'ajaxSendComposing', 
                "'".$contact->jid."'"
            )
        );
        $chatview->assign(
            'paused', 
            $this->genCallAjax(
                'ajaxSendPaused', 
                "'".$contact->jid."'"
            )
        );
        

        
        $html = $chatview->draw('_chat_contact', true);

        return $html;
    }
}