ericmoritz/XMLHttpRequest.js

## esjs.js
var httpProxy = require("http-proxy");
var http = require("http");
var render = require("./render").render;
var XMLHttpRequest = require("./XMLHttpRequest").XMLHttpRequest;

function GET(url, callback) {
            var xhr = new XMLHttpRequest();
            xhr.open("GET", url);
            xhr.onreadystatechange = function(e) {
                if(xhr.readyState == 4) {
                    callback(xhr);
                }
            };
            xhr.send(null);
}

function doESJQ(res, url) {
    console.log(url);
    GET(url, function(xhr) {
      var esjq = JSON.parse(xhr.responseText);
      GET(esjq.template, function(xhr) {
              var source = xhr.responseText;
              GET(esjq.script, function(xhr) {
                      var code = xhr.responseText;
                      render(source, code, function(doc) {
                              res.writeHead(200, {'Content-Type': 'text/plain'});
                              res.write(doc.innerHTML);
                              res.end();
                          });
                  });

          });
        });
}


httpProxy.createServer(function(req, res, proxy){
    // Create an error handler so we can use it temporarily
    var error = function (err) {
        res.writeHead(200, {'Content-Type': 'text/plain'});

        if(req.method !== 'HEAD') {
            res.write('An error has occurred: ' + sys.puts(JSON.stringify(err)));
            }

        res.end();
    };


        if(/.+\.esjq$/.test(req.url)) {
            var full_uri = "http://localhost" + req.url;
            try {
                doESJQ(res, full_uri);
            } catch(e) {
                error(e);
            }
        } else {
            proxy.proxyRequest(80, 'localhost');
        }

    }).listen(10002);

## render.js
var jsdom  = require("jsdom");

function render(template, code, callback) {
    var window = jsdom.jsdom(source).createWindow();
    jsdom.jQueryify(window, __dirname + "/jquery-1.4.2.js",
                    function() {
                        var jQuery = window.jQuery;
                        // This is probably pretty dangerous in node.js
                        eval(code);
                        callback(window.document);
                    })
        }

exports.render = render;

## test.esjq
{
"template":"http://localhost/test.html",
"script":"http://localhost/test.js"
}

## test.html
<!doctype html>
<p>My wife's name is <span id="spouse" /></p>

## test.js
jQuery("#spouse").html("Gina Moritz");

## XMLHttpRequest.js
/**
 * Wrapper for built-in http.js to emulate the browser XMLHttpRequest object.
 *
 * This can be used with JS designed for browsers to improve reuse of code and
 * allow the use of existing libraries.
 *
 * Usage: include("XMLHttpRequest.js") and use XMLHttpRequest per W3C specs.
 *
 * @todo SSL Support
 * @author Dan DeFelippi <dan@driverdan.com>
 * @license MIT
 */

var Url = require("url")
	,sys = require("util");

exports.XMLHttpRequest = function() {
	/**
	 * Private variables
	 */
	var self = this;
	var http = require('http');

	// Holds http.js objects
	var client;
	var request;
	var response;

	// Request settings
	var settings = {};

	// Set some default headers
	var defaultHeaders = {
		"User-Agent": "node.js",
		"Accept": "*/*",
	};

	var headers = defaultHeaders;

	/**
	 * Constants
	 */
	this.UNSENT = 0;
	this.OPENED = 1;
	this.HEADERS_RECEIVED = 2;
	this.LOADING = 3;
	this.DONE = 4;

	/**
	 * Public vars
	 */
	// Current state
	this.readyState = this.UNSENT;

	// default ready state change handler in case one is not set or is set late
	this.onreadystatechange = function() {};

	// Result & response
	this.responseText = "";
	this.responseXML = "";
	this.status = null;
	this.statusText = null;

	/**
	 * Open the connection. Currently supports local server requests.
	 *
	 * @param string method Connection method (eg GET, POST)
	 * @param string url URL for the connection.
	 * @param boolean async Asynchronous connection. Default is true.
	 * @param string user Username for basic authentication (optional)
	 * @param string password Password for basic authentication (optional)
	 */
	this.open = function(method, url, async, user, password) {
		settings = {
			"method": method,
			"url": url,
			"async": async || null,
			"user": user || null,
			"password": password || null
		};

		this.abort();

		setState(this.OPENED);
	};

	/**
	 * Sets a header for the request.
	 *
	 * @param string header Header name
	 * @param string value Header value
	 */
	this.setRequestHeader = function(header, value) {
		headers[header] = value;
	};

	/**
	 * Gets a header from the server response.
	 *
	 * @param string header Name of header to get.
	 * @return string Text of the header or null if it doesn't exist.
	 */
	this.getResponseHeader = function(header) {
		if (this.readyState > this.OPENED && response.headers[header]) {
			return header + ": " + response.headers[header];
		}

		return null;
	};

	/**
	 * Gets all the response headers.
	 *
	 * @return string
	 */
	this.getAllResponseHeaders = function() {
		if (this.readyState < this.HEADERS_RECEIVED) {
			throw "INVALID_STATE_ERR: Headers have not been received.";
		}
		var result = "";

		for (var i in response.headers) {
			result += i + ": " + response.headers[i] + "\r\n";
		}
		return result.substr(0, result.length - 2);
	};

	/**
	 * Sends the request to the server.
	 *
	 * @param string data Optional data to send as request body.
	 */
	this.send = function(data) {
		if (this.readyState != this.OPENED) {
			throw "INVALID_STATE_ERR: connection must be opened before send() is called";
		}

		var ssl = false;
		var url = Url.parse(settings.url);

		// Determine the server
		switch (url.protocol) {
			case 'https:':
				ssl = true;
			// SSL & non-SSL both need host, no break here.
			case 'http:':
				var host = url.hostname;
				break;

			case undefined:
			case '':
				var host = "localhost";
				break;

			default:
				throw "Protocol not supported.";
		}

		// Default to port 80. If accessing localhost on another port be sure
		// to use http://localhost:port/path
		var port = url.port || (ssl ? 443 : 80);
		// Add query string if one is used
		var uri = url.pathname + (url.search ? url.search : '');

		// Set the Host header or the server may reject the request
		this.setRequestHeader("Host", host);

		client = http.createClient(port, host, ssl);

		// Error checking
		client.addListener('error', function (error) {
			self.status = 503;
			self.statusText = error;
			self.responseText = error.stack;
			setState(self.DONE);
			// @todo throw error?
		})

		// Set content length header
		if (settings.method == "GET" || settings.method == "HEAD") {
			data = null;
		} else if (data) {
			this.setRequestHeader("Content-Length", data.length);

			if (!headers["Content-Type"]) {
				this.setRequestHeader("Content-Type", "text/plain;charset=UTF-8");
			}
		}

		// Use the correct request method
        request = client.request(settings.method, uri, headers);

		// Send data to the server
		if (data) {
			request.write(data);
		}

		request.addListener('response', function(resp) {
			response = resp;
			response.setEncoding("utf8");

			setState(self.HEADERS_RECEIVED);

			self.status = response.statusCode;

			response.addListener("data", function(chunk) {
				// Make sure there's some data
				if (chunk) {
					self.responseText += chunk;
				}
				setState(self.LOADING);
			});

			response.addListener("end", function() {
				setState(self.DONE);
			});
		});
		request.end();
	};

	/**
	 * Aborts a request.
	 */
	this.abort = function() {
		headers = defaultHeaders;
		this.readyState = this.UNSENT;
		this.responseText = "";
		this.responseXML = "";
	};

	/**
	 * Changes readyState and calls onreadystatechange.
	 *
	 * @param int state New state
	 */
	var setState = function(state) {
		self.readyState = state;
		self.onreadystatechange();
	}
};
	var httpProxy = require("http-proxy");
	var http = require("http");
	var render = require("./render").render;
	var XMLHttpRequest = require("./XMLHttpRequest").XMLHttpRequest;

	function GET(url, callback) {
	var xhr = new XMLHttpRequest();
	xhr.open("GET", url);
	xhr.onreadystatechange = function(e) {
	if(xhr.readyState == 4) {
	callback(xhr);
	}
	};
	xhr.send(null);
	}

	function doESJQ(res, url) {
	console.log(url);
	GET(url, function(xhr) {
	var esjq = JSON.parse(xhr.responseText);
	GET(esjq.template, function(xhr) {
	var source = xhr.responseText;
	GET(esjq.script, function(xhr) {
	var code = xhr.responseText;
	render(source, code, function(doc) {
	res.writeHead(200, {'Content-Type': 'text/plain'});
	res.write(doc.innerHTML);
	res.end();
	});
	});

	});
	});
	}



	httpProxy.createServer(function(req, res, proxy){
	// Create an error handler so we can use it temporarily
	var error = function (err) {
	res.writeHead(200, {'Content-Type': 'text/plain'});

	if(req.method !== 'HEAD') {
	res.write('An error has occurred: ' + sys.puts(JSON.stringify(err)));
	}

	res.end();
	};


	if(/.+\.esjq$/.test(req.url)) {
	var full_uri = "http://localhost" + req.url;
	try {
	doESJQ(res, full_uri);
	} catch(e) {
	error(e);
	}
	} else {
	proxy.proxyRequest(80, 'localhost');
	}

	}).listen(10002);
	var jsdom = require("jsdom");

	function render(template, code, callback) {
	var window = jsdom.jsdom(source).createWindow();
	jsdom.jQueryify(window, __dirname + "/jquery-1.4.2.js",
	function() {
	var jQuery = window.jQuery;
	// This is probably pretty dangerous in node.js
	eval(code);
	callback(window.document);
	})
	}

	exports.render = render;
	{
	"template":"http://localhost/test.html",
	"script":"http://localhost/test.js"
	}
	<!doctype html>
	<p>My wife's name is <span id="spouse" /></p>
	/**
	* Wrapper for built-in http.js to emulate the browser XMLHttpRequest object.
	*
	* This can be used with JS designed for browsers to improve reuse of code and
	* allow the use of existing libraries.
	*
	* Usage: include("XMLHttpRequest.js") and use XMLHttpRequest per W3C specs.
	*
	* @todo SSL Support
	* @author Dan DeFelippi <dan@driverdan.com>
	* @license MIT
	*/

	var Url = require("url")
	,sys = require("util");

	exports.XMLHttpRequest = function() {
	/**
	* Private variables
	*/
	var self = this;
	var http = require('http');

	// Holds http.js objects
	var client;
	var request;
	var response;

	// Request settings
	var settings = {};

	// Set some default headers
	var defaultHeaders = {
	"User-Agent": "node.js",
	"Accept": "/",
	};

	var headers = defaultHeaders;

	/**
	* Constants
	*/
	this.UNSENT = 0;
	this.OPENED = 1;
	this.HEADERS_RECEIVED = 2;
	this.LOADING = 3;
	this.DONE = 4;

	/**
	* Public vars
	*/
	// Current state
	this.readyState = this.UNSENT;

	// default ready state change handler in case one is not set or is set late
	this.onreadystatechange = function() {};

	// Result & response
	this.responseText = "";
	this.responseXML = "";
	this.status = null;
	this.statusText = null;

	/**
	* Open the connection. Currently supports local server requests.
	*
	* @param string method Connection method (eg GET, POST)
	* @param string url URL for the connection.
	* @param boolean async Asynchronous connection. Default is true.
	* @param string user Username for basic authentication (optional)
	* @param string password Password for basic authentication (optional)
	*/
	this.open = function(method, url, async, user, password) {
	settings = {
	"method": method,
	"url": url,
	"async": async \|\| null,
	"user": user \|\| null,
	"password": password \|\| null
	};

	this.abort();

	setState(this.OPENED);
	};

	/**
	* Sets a header for the request.
	*
	* @param string header Header name
	* @param string value Header value
	*/
	this.setRequestHeader = function(header, value) {
	headers[header] = value;
	};

	/**
	* Gets a header from the server response.
	*
	* @param string header Name of header to get.
	* @return string Text of the header or null if it doesn't exist.
	*/
	this.getResponseHeader = function(header) {
	if (this.readyState > this.OPENED && response.headers[header]) {
	return header + ": " + response.headers[header];
	}

	return null;
	};

	/**
	* Gets all the response headers.
	*
	* @return string
	*/
	this.getAllResponseHeaders = function() {
	if (this.readyState < this.HEADERS_RECEIVED) {
	throw "INVALID_STATE_ERR: Headers have not been received.";
	}
	var result = "";

	for (var i in response.headers) {
	result += i + ": " + response.headers[i] + "\r\n";
	}
	return result.substr(0, result.length - 2);
	};

	/**
	* Sends the request to the server.
	*
	* @param string data Optional data to send as request body.
	*/
	this.send = function(data) {
	if (this.readyState != this.OPENED) {
	throw "INVALID_STATE_ERR: connection must be opened before send() is called";
	}

	var ssl = false;
	var url = Url.parse(settings.url);

	// Determine the server
	switch (url.protocol) {
	case 'https:':
	ssl = true;
	// SSL & non-SSL both need host, no break here.
	case 'http:':
	var host = url.hostname;
	break;

	case undefined:
	case '':
	var host = "localhost";
	break;

	default:
	throw "Protocol not supported.";
	}

	// Default to port 80. If accessing localhost on another port be sure
	// to use http://localhost:port/path
	var port = url.port \|\| (ssl ? 443 : 80);
	// Add query string if one is used
	var uri = url.pathname + (url.search ? url.search : '');

	// Set the Host header or the server may reject the request
	this.setRequestHeader("Host", host);

	client = http.createClient(port, host, ssl);

	// Error checking
	client.addListener('error', function (error) {
	self.status = 503;
	self.statusText = error;
	self.responseText = error.stack;
	setState(self.DONE);
	// @todo throw error?
	})

	// Set content length header
	if (settings.method == "GET" \|\| settings.method == "HEAD") {
	data = null;
	} else if (data) {
	this.setRequestHeader("Content-Length", data.length);

	if (!headers["Content-Type"]) {
	this.setRequestHeader("Content-Type", "text/plain;charset=UTF-8");
	}
	}

	// Use the correct request method
	request = client.request(settings.method, uri, headers);

	// Send data to the server
	if (data) {
	request.write(data);
	}

	request.addListener('response', function(resp) {
	response = resp;
	response.setEncoding("utf8");

	setState(self.HEADERS_RECEIVED);

	self.status = response.statusCode;

	response.addListener("data", function(chunk) {
	// Make sure there's some data
	if (chunk) {
	self.responseText += chunk;
	}
	setState(self.LOADING);
	});

	response.addListener("end", function() {
	setState(self.DONE);
	});
	});
	request.end();
	};

	/**
	* Aborts a request.
	*/
	this.abort = function() {
	headers = defaultHeaders;
	this.readyState = this.UNSENT;
	this.responseText = "";
	this.responseXML = "";
	};

	/**
	* Changes readyState and calls onreadystatechange.
	*
	* @param int state New state
	*/
	var setState = function(state) {
	self.readyState = state;
	self.onreadystatechange();
	}
	};