Changeset 151 for trunk/instant_messenger/inc/Jabberd2.abstract.php

Timestamp:

01/18/08 15:17:58 (16 years ago)

Author:

niltonneto

Message:

Commit da nova versão do módulo, usando agente em C.
Vide Página do módulo do Trac:
http://www.expressolivre.org/dev/wiki/messenger

A versão anterior encontra-se na subpasta bkp (32/64).

File:

• trunk/instant_messenger/inc/Jabberd2.abstract.php (modified) (2 diffs)

trunk/instant_messenger/inc/Jabberd2.abstract.php

@@ -7 +7 @@
 class Jabberd2 extends Jabber
 {
-   final function connect($pUser = false, $pPassword = false)
-   {
-      try
-      {
-         if ( parent::connect($pUser, $pPassword) )
-            if ( $this->presence() )
-               return true;
+        final function connect($pUser = false, $pPassword = false)
+        {
+                try
+                {
+                        if ( $_connect = parent::connect($pUser, $pPassword) )
+                                return $_connect;
 
-         return false;
-      }
-      catch(Exception $e)
-      {
-         $this->writeLog('ERROR', $e->getMessage());
-         return false;
-      }
-   }
+                        return false;
+                }
+                catch(Exception $e)
+                {
+                        $this->writeLog('ERROR', $e->getMessage());
+                        return false;
+                }
+        }
 
-   function disconnect()
-   {
-      $this->_disconnect();
-   }
+        function closeSocket()
+        {
+                $this->close($this->_socket);
+        }
 
-   final function readSocket()
-   {
-      return $this->read();
-   }
+        function disconnect()
+        {
+                $this->_disconnect();
+        }
 
-   final function writeSocket($pData)
-   {
-      return $this->write($pData);
-   }
+        final function readSocket()
+        {
+                return $this->read();
+        }
+
+        final function writeSocket($pData)
+        {
+                return $this->write($pData);
+        }
+
+        /*
+         * Jabber - Functions
+         */
+
+        final function addContacts($pContact)
+        {
+                $jid = explode("@",$pContact['email']);
+                $jid = $jid[0]."@".$this->_server;
+                $name = $pContact['name'];
+                $group = $pContact['group'];
+
+                if(trim($jid[0]) != trim($this->_user))
+                {
+                        if ( $jid )
+                        {
+                                $newcontact  = "<item jid='".$jid."'";
+                                $newcontact .= " name='" . $name . "'";
+                                $newcontact .= "><group>" . $group . "</group></item>";
+                        }
+                }
+                $addid = "adduser_" . time();
+                if ( !$this->connected )
+                        echo "disconnected";
+                else
+                {
+                        if($this->writeSocket($this->iq('set', $addid, NULL, NULL, "jabber:iq:roster", $newcontact)))
+                        {
+                                $this->getContacts();
+                                if($this->subscription($pContact['jid'],"subscribe"))
+                                        echo "OK";
+                        }
+                }
+        }
+
+        final function getContacts()
+        {
+                $this->iq('get', 'contacts', NULL, NULL, 'jabber:iq:roster');
+        }
+
+        final function getVcard($pJid)
+        {
+                if(is_array($pJid))
+                {
+                        $jid = (trim($pJid['jid']) == "this") ? $this->_user . '@' . $this->_server : $pJid['jid'];
+
+                        if ( !$this->connected )
+                                echo "disconnected";
+                        else
+                        {
+                                $this->writeSocket($this->iq('get', 'vCard', $jid, NULL, "vcard-temp", "<vCard xmlns='vcard-temp'/>"));
+                                echo "OK";
+                        }
+                }
+                else
+                {
+                        $this->iq('get', 'vCard', $pJid, NULL, "vcard-temp", "<vCard xmlns='vcard-temp'/>");
+                }
+        }
+
+        final function newVcard($NewVcard)
+        {
+                $id = $this->_user;
+
+                if ( !$this->connected )
+                        echo "disconnected";
+                else
+                {               
+                        $this->writeSocket($this->iq('set', $id, NULL, NULL, "vcard-temp", "<vCard xmlns='vcard-temp'>".$NewVcard['vcard']."</vCard>"));
+                        echo "OK";
+                }                       
+        }
         
-        final function setPresence($pPresence)
+        final function removeContact($pContact)
         {
+                $delid  = 'deluser_' . time();
+                if( !$this->connected )
+                        echo "disconnected";
+                else
+                {
+                        if($this->writeSocket($this->iq('set',$delid,NULL,NULL,"jabber:iq:roster","<item jid='".$pContact['jid']."' subscription='remove'/>")))
+                        {
+                                $this->getContacts();
+                                if($this->subscription($pContact['jid'],"unsubscribed"))
+                                        echo "OK";                      
+                        }
+                }
+        }
+
+        final function subscription($pTo, $pType = false)
+        {
+                $jid = (is_array($pTo)) ? $pTo['jid'] : $pTo ;
+                $type = (is_array($pTo)) ? $pTo['type'] : $pType ;
+
+                if ( !$this->connected )
+                        return false;
+                else
+                {
+                        $this->writeSocket("<presence xmlns='jabber:client' from='".$this->_user."@".$this->_server."' type='".$type."' to='".$jid."'/>");
+                        return true;                    
+                }
+        }
+
+        final function setPresence($pPresence = false)
+        {
+                
+                if ( !$pPresence )
+                        $this->presence();
+
                 $type = ( isset($pPresence['type']) ) ? $pPresence['type'] : NULL;
                 $to = ( isset($pPresence['to']) ) ? $pPresence['to'] : NULL;
@@ -46 +156 @@
                 $status = ( isset($pPresence['status']) ) ? $pPresence['status'] : NULL;
                 $priority = ( isset($pPresence['priority']) ) ? $pPresence['priority'] : NULL;
-                
+
                 $this->presence($type, $to, $show, $status, $priority);
-        }
-        /*
-         * Vcard
-         */
 
-   final function getVcard($pVcard)
-   {
-                $this->iq('get', $pVcard, $pVcard, NULL, "vcard-temp", "<vCard xmlns='vcard-temp'/>");
-   }
-
-   final function newVcard($NewVcard)
-   {
-        $id = $_SESSION['phpgw_info']['instant_messenger']['user'];
-        $this->iq('set', $id, NULL, NULL, "vcard-temp", "<vCard xmlns='vcard-temp'>".$NewVcard."</vCard>");     
-   }
-        
-        /*
-         *  Contacts
-         */
-
-   final function getContacts()
-   {
-                $this->iq('get', 'contacts', NULL, NULL, 'jabber:iq:roster');
-   }
-   
-   final function addContacts($pContact)
-   {
-        $addid = "adduser_" . time();
-        $this->iq('set', $addid, NULL, NULL, "jabber:iq:roster", $pContact);
-   }
-   
-   final function removeContact($pContact)
-   {
-        $delid  = 'deluser_' . time();
-        $this->iq('set',$delid,NULL,NULL,"jabber:iq:roster","<item jid='".$pContact."' subscription='remove'/>");
-   }
-   
-   final function updateContact($pContact)
-   {
-        $upid = 'updateuser_' . time();
-        $this->iq('set', $upid, NULL, NULL, "jabber:iq:roster", $pContact);
-   }
-   
-   /*
-    * Presence 
-    */
-   
-   final function SubscriptionAcceptRequest($to = NULL)
-        {
-                $this->presence("subscribed", $to);
         }
 
-        final function SubscriptionDenyRequest($to = NULL)
+        final function updateContact($pContact)
         {
-                $this->presence("unsubscribed", $to);
-        }
+                $jid   = $pContact['jid'];
+                $name  = $pContact['name'];
+                $group = $pContact['group'];
 
-        final function Subscribe($to = NULL)
-        {
-                $this->presence("subscribe", $to);
-        }
+                if ( $jid )
+                {
+                        $updatecontact  = "<item jid='$jid'";
+                        $updatecontact .= " name='" . $name . "'";
+                        $updatecontact .= "><group>" . $group . "</group></item>";
+                }
 
-        final function Unsubscribe($to = NULL)
-        {
-                $this->presence("unsubscribe", $to);
+                $upid = 'updateuser_' . time();
+                if ( !$this->connected )
+                        echo "disconnected";
+                else
+                {
+                        $this->writeSocket($this->iq('set', $upid, NULL, NULL, "jabber:iq:roster", $updatecontact));
+                        $this->getContacts();
+                        echo "OK";
+                }
         }
 }