Got some XHR tests to run, still some hanging threads (need to investigate). Started...

[jquery.git] / build / runtest / env.js

diff --git a/build/runtest/env.js b/build/runtest/env.js
index bf53efa..b2a94ff 100644 (file)
--- a/build/runtest/env.js
+++ b/build/runtest/env.js
@@ -17,16 +17,21 @@ var window = this;
                }
        };
        
+       var curLocation = (new java.io.File("./")).toURL();
+       
        window.__defineSetter__("location", function(url){
+               curLocation = new java.net.URL( curLocation, url );
+               
                window.document = new DOMDocument(
-                       new Packages.org.xml.sax.InputSource(\r                  new java.io.InputStreamReader(
-                               new java.io.FileInputStream(url))));
+                       new Packages.org.xml.sax.InputSource(
+                       new java.io.InputStreamReader(
+                               new java.io.FileInputStream( url ))));
        });
        
        window.__defineGetter__("location", function(url){
                return {
                        get protocol(){
-                               return "file:";
+                               return curLocation.getProtocol() + ":";
                        }
                };
        });
@@ -468,16 +473,114 @@ var window = this;
        }
        
        // XMLHttpRequest
+       // Originally implemented by Yehuda Katz
 
-       window.XMLHttpRequest = function(){ };
+       window.XMLHttpRequest = function(){
+               this.headers = {};
+               this.responseHeaders = {};
+       };
        
        XMLHttpRequest.prototype = {
-               open: function(){ },
-               setRequestHeader: function(){ },
-               getResponseHeader: function(){ },
+               open: function(method, url, async, user, password){ 
+                       this.readyState = 1;
+                       if (async)
+                               this.async = true;
+                       this.method = method || "GET";
+                       this.url = url;
+                       this.onreadystatechange();
+               },
+               setRequestHeader: function(header, value){
+                       this.headers[header] = value;
+               },
+               getResponseHeader: function(header){ },
+               send: function(data){
+                       var self = this;
+                       
+                       function makeRequest(){
+                               var url = new java.net.URL(curLocation, self.url),
+                                       connection = url.openConnection();
+                               
+                               // Add headers to Java connection
+                               for (var header in self.headers)
+                                       connection.addRequestProperty(header, self.headers[header]);
+                       
+                               connection.connect();
+                               
+                               // Stick the response headers into responseHeaders
+                               for (var i=0; ; i++) { 
+                                       var headerName = connection.getHeaderFieldKey(i); 
+                                       var headerValue = connection.getHeaderField(i); 
+                                       if (!headerName && !headerValue) break; 
+                                       if (headerName)
+                                               self.responseHeaders[headerName] = headerValue;
+                               }
+                               
+                               self.readyState = 4;
+                               self.status = parseInt(connection.responseCode);
+                               self.statusText = connection.responseMessage;
+                               
+                               var stream = new java.io.InputStreamReader(
+                                               connection.getInputStream()),
+                                       buffer = new java.io.BufferedReader(stream),
+                                       line;
+                               
+                               while ((line = buffer.readLine()) != null)
+                                       self.responseText += line;
+                                       
+                               self.responseXML = null;
+                               
+                               if ( self.responseText.match(/^\s*</) ) {
+                                       try {
+                                               self.responseXML = new DOMDocument(
+                                                       new java.io.ByteArrayInputStream(
+                                                               (new java.lang.String(
+                                                                       self.responseText)).getBytes("UTF8")));
+                                       } catch(e) {}
+                               }
+
+                               self.onreadystatechange();
+                       }
+
+                       if (this.async)
+                               (new java.lang.Thread(new java.lang.Runnable({
+                                       run: makeRequest
+                               }))).start();
+                       else
+                               makeRequest();
+               },
+               abort: function(){},
+               onreadystatechange: function(){},
+               getResponseHeader: function(header){
+                       if (this.readyState < 3)
+                               throw new Error("INVALID_STATE_ERR");
+                       else {
+                               var returnedHeaders = [];
+                               for (var rHeader in this.responseHeaders) {
+                                       if (rHeader.match(new Regexp(header, "i")))
+                                               returnedHeaders.push(this.responseHeaders[rHeader]);
+                               }
+                       
+                               if (returnedHeaders.length)
+                                       return returnedHeaders.join(", ");
+                       }
+                       
+                       return null;
+               },
+               getAllResponseHeaders: function(header){
+                       if (this.readyState < 3)
+                               throw new Error("INVALID_STATE_ERR");
+                       else {
+                               var returnedHeaders = [];
+                               
+                               for (var header in this.responseHeaders)
+                                       returnedHeaders.push( header + ": " + this.responseHeaders[header] );
+                               
+                               return returnedHeaders.join("\r\n");
+                       }
+               },
+               async: true,
                readyState: 0,
                responseText: "",
-               responseXML: {},
                status: 0
        };
 })();