Changeset 235 for trunk/instant_messenger/js/connector.js

Timestamp:

03/19/08 17:15:13 (16 years ago)

Author:

niltonneto

Message:

 

File:

• trunk/instant_messenger/js/connector.js (modified) (7 diffs)

trunk/instant_messenger/js/connector.js

@@ -1 +1 @@
 function Connector()
 {
+        this.__HTTP__ = [];
+        this.__THREADS__ = [];
 }
 
@@ -7 +9 @@
         {
                 // connection
-                var __HTTP__ = null;
-                var __THREADS__ = [];
+                //var __HTTP__ = null;
+                //var __THREADS__ = [];
                 var index = 0;
                 var rtlen = 0;
                 var ie = false; // ie don't has stream
-                function makeConnection()
-                {
-                        if ( __HTTP__ == null )
-                                __HTTP__ = xhr();
+                var __this__ = this;
+                function makeConnection(pThread)
+                {
+                        //if ( __this__.__HTTP__ === false )
+                                __this__.__HTTP__[pThread] = xhr();
                 }
                 function setPost(pThread)
                 {
-                        __THREADS__[pThread].__METHOD__ = 'POST';
+                        __this__.__THREADS__[pThread].__METHOD__ = 'POST';
                         return true;
                 }
-                // this set __THREADS__[?].__TYPE__ to 4 for request or 3 for stream
+                // this set __this__.__THREADS__[?].__TYPE__ to 4 for request or 3 for stream
                 function setStream(pThread)
                 {
-                        __THREADS__[pThread].__TYPE__ = ( !ie ) ? 3 : 4;
+                        __this__.__THREADS__[pThread].__TYPE__ = ( !ie ) ? 3 : 4;
                         return true;
                 }
@@ -81 +84 @@
                 }
 
-                var __HANDLER__ = function()
+                function __HANDLER__()
                 {
                         try
                         {
-                                if ( ie && __HTTP__.readyState != 4 )
+                                if ( ie && __this__.__HTTP__[arguments[0]].readyState != 4 )
                                         return false;
 
-                                var threadId = __HTTP__.getResponseHeader('ThreadId');
+                                //var threadId = __this__.__HTTP__[arguments[0]].getResponseHeader('ThreadId');
+                                var threadId = arguments[0];
+
                                 if ( !threadId )
                                         return false;
 
-                                var type = __THREADS__[threadId].__TYPE__;
-                                if ( __HTTP__.readyState == 3 || __HTTP__.readyState == 4 )
-                                {
-                                        if ( !ie && __HTTP__.readyState == 3 && __THREADS__[threadId].__HANDLER__.stream )
-                                        {
-                                                var data = trim(__HTTP__.responseText.substr(index));
-                                                rtlen = __HTTP__.responseText.length;
+                                if ( __this__.__HTTP__[threadId].readyState == 3 || __this__.__HTTP__[threadId].readyState == 4 )
+                                {
+                                        if ( !ie && __this__.__HTTP__[threadId].readyState == 3 && __this__.__THREADS__[threadId].__HANDLER__.stream )
+                                        {
+                                                var data = trim(__this__.__HTTP__[threadId].responseText.substr(index));
+                                                rtlen = __this__.__HTTP__[threadId].responseText.length;
                                                 if ( index < rtlen && data.length )
                                                 {
-                                                        __THREADS__[threadId].__HANDLER__.stream(data);
+                                                        __this__.__THREADS__[threadId].__HANDLER__.stream(data);
                                                         index = rtlen;
                                                 }
                                         }
-                                        if ( __THREADS__[threadId].__HANDLER__.request && __HTTP__.readyState == 4 )
-                                        {
-                                                switch ( __HTTP__.status )
+                                        if ( __this__.__THREADS__[threadId].__HANDLER__.request && __this__.__HTTP__[threadId].readyState == 4 )
+                                        {
+                                                switch ( __this__.__HTTP__[threadId].status )
                                                 {
                                                         case 200:
-                                                                var data = ( __THREADS__[threadId].__MODE__ == 'XML' ) ?
-                                                                        __HTTP__.responseXML :
-                                                                        __HTTP__.responseText;
-
-                                                                if ( ie && __THREADS__[threadId].__HANDLER__.stream )
-                                                                        __THREADS__[threadId].__HANDLER__.stream(data);
-
-                                                                if ( __THREADS__[threadId].__HANDLER__.request )
-                                                                        __THREADS__[threadId].__HANDLER__.request(data);
+                                                                var stream = false;
+                                                                var request = false;
+                                                                var data = ( __this__.__THREADS__[threadId].__MODE__ == 'XML' ) ?
+                                                                        __this__.__HTTP__[threadId].responseXML :
+                                                                        __this__.__HTTP__[threadId].responseText;
+
+                                                                if ( ie && __this__.__THREADS__[threadId].__HANDLER__.stream )
+                                                                        stream = __this__.__THREADS__[threadId].__HANDLER__.stream;
+
+                                                                if ( __this__.__THREADS__[threadId].__HANDLER__.request )
+                                                                        request = __this__.__THREADS__[threadId].__HANDLER__.request;
+
+                                                                delete __this__.__THREADS__[threadId];
+
+                                                                if ( stream )
+                                                                        stream(data);
+
+                                                                if ( request )
+                                                                        request(data);
 
                                                                 break; // [case : status 200]
@@ -128 +142 @@
                                         }
                                 }
-                                if ( __HTTP__.readyState == 4 )
-                                {
-                                        delete __THREADS__[threadId];
-                                }
+                                //if ( __this__.__HTTP__.readyState == 4 )
+                                //{
+                                //      delete __this__.__THREADS__[threadId];
+                                //}
                         }
                         catch(e)
                         {
                                 //alert("__HANDLER__\n" + threadId + "\n " + e + "\n ErroR: " + e.description);
-                                //delete __THREADS__[threadId];
+                                //delete __this__.__THREADS__[threadId];
                         }
                 };
@@ -144 +158 @@
                         return {'error':'#0 - invalid params'};
 
-                if ( __THREADS__[arguments[0]] )
+                if ( __this__.__THREADS__[arguments[0]] )
                         return {'error':'#2 - request is running'};
 
-                __THREADS__[arguments[0]] = {
+                __this__.__THREADS__[arguments[0]] = {
                         '__HANDLER__' : arguments[1],
                         '__METHOD__'  : 'GET',  // __METHOD__ = [GET | POST]
@@ -154 +168 @@
                 };
 
-                makeConnection();
+                makeConnection(arguments[0]);
 
                 if ( !verifyUserHandler(arguments[0], arguments[1]) )
                 {
-                        delete __THREADS__[arguments[0]];
+                        //delete __this__.__THREADS__[arguments[0]];
                         return {'error':'#1 - invalid handler'};
                 }
@@ -165 +179 @@
                         setPost(arguments[0]);
 
-                if ( __HTTP__ != null )
+                if ( __this__.__HTTP__[arguments[0]] != null )
                 {
                         try
                         {
                                 var __TARGET__ = path_im + 'controller.php?act=' + arguments[0];
+
+                                //alert("__METHOD__: " + __this__.__THREADS__[arguments[0]].__METHOD__ + "\n__TARGET__: " + __TARGET__)
+
                                 var __SEND__ = null;
-                                __HTTP__.open(__THREADS__[arguments[0]].__METHOD__, __TARGET__, true);
-                                if ( __THREADS__[arguments[0]].__METHOD__ == 'POST' )
-                                {
-                                        __HTTP__.setRequestHeader('Content-Type','application/x-www-form-urlencoded');
-                                        __HTTP__.setRequestHeader('Cache-Control',  'no-store, no-cache, must-revalidate');
-                                        __HTTP__.setRequestHeader('Cache-Control', 'post-check=0, pre-check=0');
-                                        __HTTP__.setRequestHeader('Pragma', 'no-cache');
+                                __this__.__HTTP__[arguments[0]].open(__this__.__THREADS__[arguments[0]].__METHOD__, __TARGET__, true);
+                                if ( __this__.__THREADS__[arguments[0]].__METHOD__ == 'POST' )
+                                {
+                                        __this__.__HTTP__[arguments[0]].setRequestHeader('Content-Type','application/x-www-form-urlencoded');
+                                        __this__.__HTTP__[arguments[0]].setRequestHeader('Cache-Control',  'no-store, no-cache, must-revalidate');
+                                        __this__.__HTTP__[arguments[0]].setRequestHeader('Cache-Control', 'post-check=0, pre-check=0');
+                                        __this__.__HTTP__[arguments[0]].setRequestHeader('Pragma', 'no-cache');
                                         __SEND__ = arguments[2];
                                 }
-                                //__HTTP__.setRequestHeader('ThreadId', arguments[0]);
-                                //__HTTP__.setRequestHeader('Connection', 'close');
-                                //__HTTP__.setRequestHeader('Keep-Alive', '0');
-                                __HTTP__.onreadystatechange = __HANDLER__;
-                                __HTTP__.send(__SEND__);
+                                //__this__.__HTTP__.setRequestHeader('ThreadId', arguments[0]);
+                                //__this__.__HTTP__.setRequestHeader('Connection', 'close');
+                                //__this__.__HTTP__.setRequestHeader('Keep-Alive', '0');
+                                var tst = arguments[0];
+                                __this__.__HTTP__[arguments[0]].onreadystatechange = function(){__HANDLER__(tst)};
+                                __this__.__HTTP__[arguments[0]].send(__SEND__);
                         }
                         catch(e)