Changeset 477

Timestamp:

08/09/08 12:47:45 (5 months ago)

Author:

heyadayo

Message:

Some preliminary X-domain code for XHRs -- not testing (nor working, i imagine) yet.

Location:

trunk/daemon/orbited

Files:

• static/JSON.js (added)
• static/Orbited.js (modified) (1 diff)
• static/xsdrBridge.html (added)
• transports/base.py (modified) (2 diffs)

trunk/daemon/orbited/static/Orbited.js

@@ -741 +741 @@
 
 
+
+
+
+// XXX: the Orbited.XSDR stuff (presumably) doesn't work yet.
+//      mcarter - 8-9-08 (~rev 476)
+
+Orbited.singleton.XSDR = {
+    receiveCbs: {},
+    queues: {},
+    id: 0,
+    register: function(receive, queue) {
+        var id = ++Orbited.singleton.XSDR;
+        Orbited.singleton.XSDR.receiveCbs[id] = receive;
+        Orbited.singleton.XSDR.queues[id] = queue;
+    }
+}
+
+Orbited.XSDR = function() {
+    var self = this;
+
+    var ifr = null;
+    var url;
+    var method;
+    var data;
+    var requestHeaders;
+    var queue = []
+    var id = Orbited.singleton.XSDR.register(
+        function(data) { receive(data) }, 
+        queue
+    )
+    var bridgeUrl = new URL("")
+    bridgeUrl.domain = Orbited.hostname
+    bridgeUrl.port = Orbited.port
+    bridgeUrl.path = '/static/xsdrBridge.html'
+    bridgeUrl.hash = id;
+    
+    var reset = function() {
+        self.responseText = ""
+        self.status = null;
+        self.readyState = 0;
+        url = null;
+        method = null;
+        data = null;
+        requestHeaders = {};
+
+    }
+    reset();
+
+    self.open = function(_method, _url, async) {
+        if (self.readyState == 4) {
+            reset();
+        }
+        if (self.readyState != 0) {
+            throw new Error("Invalid readyState");
+        }
+        if (!async) {
+            throw new Error("Only Async XSDR supported")
+        }
+        self.readyState = 1;
+        url = _url;
+        method = _method;        
+    }
+
+    self.send = function(data) {
+        if (self.readyState != 1) {
+            throw new Error("Invalid readyState");
+        }
+        if (!ifr) {
+            ifr = document.createElement("iframe")
+            hideIframe(ifr);
+            ifr.src = bridgeUrl.render()
+            document.body.appendChild(ifr);
+        }
+        else {
+            queue.push([method, url, data, requestHeaders]);
+        }
+    }
+
+    self.abort = function() {
+        if (self.readyState > 0 && self.readyState < 4) {
+            queue.push(['ABORT']);
+        }
+    }
+
+    self.setRequestHeader = function(key, val) {
+        if (self.readyState != 0) {
+            throw new Error("Invalid readyState");
+        }
+        requestHeaders[key] = val;
+    }
+
+    self.getResponseHeader = function() {
+        if (self.readyState < 2) {
+            throw new Error("Invalid readyState");
+        }
+        return responseHeaders[key]
+    }
+
+    var receive = function(payload) {
+        switch(payload[0]) {
+            case 'initialize':
+                push([method, url, data, requestHeaders]);
+                break;
+            case 'readystatechange':
+                var data = payload[1]
+                self.readyState = data.readyState
+                if (data.status) {
+                    self.status = data.status
+                }
+                if (data.responseText) {
+                    self.responseText += data.responseText
+                }
+                self.onreadystatechange();
+        }
+    }
+
+    var hideIframe =function (ifr) {
+        ifr.style.display = 'block';
+        ifr.style.width = '0';
+        ifr.style.height = '0';
+        ifr.style.border = '0';
+        ifr.style.margin = '0';
+        ifr.style.padding = '0';
+        ifr.style.overflow = 'hidden';
+        ifr.style.visibility = 'hidden';
+    }
+    
+}
+Orbited.XSDR.prototype.logger = Orbited.getLogger("Orbited.XSDR");
 
 

trunk/daemon/orbited/transports/base.py

@@ -4 +4 @@
 logger = logging.get_logger('orbited.transports.base.CometTransport')
 class CometTransport(resource.Resource):
-  
+    HEARTBEAT_INTERVAL = 5
     
   
@@ -24 +24 @@
     
     def resetHeartbeat(self):
-        self.heartbeatTimer = reactor.callLater(5, self.doHeartbeat)
+        self.heartbeatTimer = reactor.callLater(self.HEARTBEAT_INTERVAL, self.doHeartbeat)
         
     def doHeartbeat(self):