From 0331aee519b939d9a050e2aa53b29795a8b7f330 Mon Sep 17 00:00:00 2001
From: erickson <erickson@9efc2488-bf62-4759-914b-345cdb29e865>
Date: Thu, 6 Mar 2008 20:22:01 +0000
Subject: [PATCH] added connect/disconnect support, with onconnect callback

git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@1260 9efc2488-bf62-4759-914b-345cdb29e865
---
 src/javascript/opensrf.js     | 45 +++++++++++++++++++++++++++++++----
 src/javascript/opensrf_xhr.js | 15 ++++++++++--
 2 files changed, 54 insertions(+), 6 deletions(-)

diff --git a/src/javascript/opensrf.js b/src/javascript/opensrf.js
index e52c145..af19873 100644
--- a/src/javascript/opensrf.js
+++ b/src/javascript/opensrf.js
@@ -61,6 +61,7 @@ OpenSRF.set_subclass = function(cls, pcls) {
 /* general session superclass */
 OpenSRF.Session = function() {
     this.remote_id = null;
+    this.state = OSRF_APP_SESSION_DISCONNECTED;
 }
 
 OpenSRF.Session.transport = OSRF_TRANSPORT_TYPE_XHR; /* default to XHR */
@@ -102,11 +103,34 @@ OpenSRF.ClientSession = function(service) {
     this.thread = Math.random() + '' + new Date().getTime();
     this.do_connect = false;
     this.requests = [];
+    this.onconnect = null;
     OpenSRF.Session.cache[this.thread] = this;
 }
 OpenSRF.set_subclass('OpenSRF.ClientSession', 'OpenSRF.Session');
 
 
+OpenSRF.ClientSession.prototype.connect = function(args) {
+    if(args && args.onconnect)
+        this.onconnect = args.onconnect;
+
+    message = new osrfMessage({
+        'threadTrace' : this.reqid, 
+        'type' : OSRF_MESSAGE_TYPE_CONNECT,
+    });
+
+    this.send(message, {'timeout' : this.timeout});
+}
+
+OpenSRF.ClientSession.prototype.disconnect = function(args) {
+    this.send(
+        new osrfMessage({
+            'threadTrace' : this.reqid, 
+            'type' : OSRF_MESSAGE_TYPE_DISCONNECT,
+        })
+    );
+}
+
+
 OpenSRF.ClientSession.prototype.request = function(args) {
 
     if(typeof args == 'string') { 
@@ -118,6 +142,9 @@ OpenSRF.ClientSession.prototype.request = function(args) {
             method : args, 
             params : params
         };
+    } else {
+        if(typeof args == 'undefined')
+            args = {};
     }
 
     var req = new OpenSRF.Request(this, this.last_id++, args);
@@ -193,20 +220,30 @@ OpenSRF.Stack.handle_message = function(ses, osrf_msg, stack_callback) {
     var req = null;
 
     if(osrf_msg.type() == OSRF_MESSAGE_TYPE_STATUS) {
+
         var payload = osrf_msg.payload();
         var status = payload.statusCode();
         var status_text = payload.status();
 
+        if(status == OSRF_STATUS_COMPLETE) {
+            req = ses.find_request(osrf_msg.threadTrace());
+            if(req) req.complete = true;
+        }
+
+        if(status == OSRF_STATUS_OK) {
+            ses.state = OSRF_APP_SESSION_CONNECTED;
+        }
+
         if(status == OSRF_STATUS_NOTFOUND) {
-            alert('status = ' + status_text);
+            alert('NOT_FOUND: ' + status_text);
+            return;
         }
     }
 
     if(osrf_msg.type() == OSRF_MESSAGE_TYPE_RESULT) {
         req = ses.find_request(osrf_msg.threadTrace());
-        if(req) {
+        if(req) 
             req.response_queue.push(osrf_msg.payload());
-        }
     }
 
     if(stack_callback)
@@ -245,7 +282,7 @@ osrfMessage.prototype.serialize = function() {
         "__p": {
             'threadTrace' : this.hash.threadTrace,
             'type' : this.hash.type,
-            'payload' : this.hash.payload.serialize(),
+            'payload' : (this.hash.payload) ? this.hash.payload.serialize() : 'null',
             'locale' : this.hash.locale
         }
     };
diff --git a/src/javascript/opensrf_xhr.js b/src/javascript/opensrf_xhr.js
index bea2bc5..0ea7f55 100644
--- a/src/javascript/opensrf_xhr.js
+++ b/src/javascript/opensrf_xhr.js
@@ -60,14 +60,25 @@ OpenSRF.XHRequest.prototype.core_handler = function() {
     stat = this.xreq.status;
 
     var xhr = this;
-    var req = OpenSRF.Stack.push(
+    OpenSRF.Stack.push(
         new OpenSRF.NetMessage(null, sender, thread, json),
+
         function(ses, req) {
+            if(ses) {
+                if(ses.state == OSRF_APP_SESSION_CONNECTED && 
+                    ses.onconnect && !ses.onconnect_called) {
+                        ses.onconnect_called = true;
+                        ses.onconnect();
+                }
+            }
+
             if(req) {
                 if(req.response_queue.length > 0 && xhr.args.onresponse) 
                     return xhr.args.onresponse(req);
-                if(req.complete && xhr.args.oncomplete)
+                if(req.complete && xhr.args.oncomplete && !xhr.args.oncomplete_called) {
+                    xhr.args.oncomplete_called = true;
                     return xhr.args.oncomplete(req);
+                }
             }
         }
     );
-- 
2.43.2