WebSVN – HomeAutomation – Diff – /trunk/PcSoftware/Atom/Services/System/HTTP.js


 
function HTTP()
{
}
 
HTTP.prototype.mySocket = null;
HTTP.prototype.myUserCallback = null;
HTTP.prototype.myBuffer = null;
HTTP.prototype.myRequest = null;
 
HTTP.prototype.request = function(callback, url)
{
    this.myUserCallback = callback;
   
    if (this.mySocket)
    {
        this.mySocket.stop();
    }
   
    var self = this;
   
    var urlData = this.parseUrl(url);
   
    /*log("hostname: " + urlData['hostname'] + "\n");
    log("path: " + urlData['path'] + "\n");
    log("port: " + urlData['port'] + "\n");*/
   
    this.myBuffer = "";
   
    this.mySocket = new Socket(function(event, data) { self.socketCallback(event, data); }, urlData['hostname'], urlData['port'], 0);
    this.mySocket.start();
   
    this.myRequest = "GET " + urlData['path'] + " HTTP/1.1\r\n";
    this.myRequest += "Host: " + urlData['hostname'] + ":" + urlData['port'] + "\r\n";
    this.myRequest += "User-Agent: Mozilla/5.0 (X11; U; Linux x86_64; en-US; rv:1.9.1.2) Gecko/20090730 SUSE/3.5.2-1.1 Firefox/3.5.2\r\n";
    this.myRequest += "Connection: close\r\n";
    this.myRequest += "\r\n";
}
 
HTTP.prototype.parseUrl = function(url)
{
    var result = new Array();
    result['port'] = 80;
    result['path'] = "/";
 
    var firstSlash = url.indexOf('/');
   
    if (firstSlash == -1)
    {
        result['hostname'] = url;
    }
    else
    {
        result['hostname'] = url.substr(0, firstSlash);
        result['path'] = url.substr(firstSlash);
    }
   
    var firstColon = result['hostname'].indexOf(':');
   
    if (firstColon != -1)
    {
        result['port'] = result['hostname'].substr(firstColon+1);
        result['hostname'] = result['hostname'].substr(0, firstColon);
    }
 
    return result;
}
 
HTTP.prototype.socketCallback = function(event, data)
{
    switch (event)
    {
    case "CONNECTED":
    this.mySocket.send(this.myRequest);
    break;
   
    case "DATA":
    this.myBuffer += unescape(data);
    break;
   
    case "RESET":
    case "CLOSED":
    case "DIED":
    this.mySocket.stop();
    this.processBuffer();
    this.mySocket = null;
    break;
    }
}
 
HTTP.prototype.processBuffer = function()
{
    ///FIXME: This is a bit ugly code... also not fully HTTP/1.1 compliant look at http://www.jmarshall.com/easy/http/
 
    var pos = this.myBuffer.indexOf("\n\n");
   
    var headerData = this.myBuffer.substr(0, pos);
    var contentData = this.myBuffer.substr(pos+2);
   
    var headerLines = headerData.split("\n");
   
    var header = new Array();
    var result = headerLines[0];
   
    for (var n = 1; n < headerLines.length; n++)
    {
        var headerParts = headerLines[n].split(":", 2);
        header[headerParts[0]] = headerParts[1].trim(' ');
    }
   
    this.myBuffer = "";
   
    if (this.myUserCallback != null)
    {
        this.myUserCallback(result, header, contentData);
        this.myUserCallback = null;
    }
}
 

Rev 1348	Rev 1402
1		1
2	function HTTP()	2	function HTTP()
3	{	3	{
4	}	4	}
5		5
6	HTTP.prototype.mySocket = null;	6	HTTP.prototype.mySocket = null;
7	HTTP.prototype.myUserCallback = null;	7	HTTP.prototype.myUserCallback = null;
8	HTTP.prototype.myBuffer = null;	8	HTTP.prototype.myBuffer = null;
9	HTTP.prototype.myRequest = null;	9	HTTP.prototype.myRequest = null;
10		10
11	HTTP.prototype.request = function(callback, url)	11	HTTP.prototype.request = function(callback, url)
12	{	12	{
13	this.myUserCallback = callback;	13	this.myUserCallback = callback;
14		14
15	if (this.mySocket)	15	if (this.mySocket)
16	{	16	{
17	this.mySocket.stop();	17	this.mySocket.stop();
18	}	18	}
19		19
20	var self = this;	20	var self = this;
21		21
22	var urlData = this.parseUrl(url);	22	var urlData = this.parseUrl(url);
23		23
24	/*log("hostname: " + urlData['hostname'] + "\n");	24	/*log("hostname: " + urlData['hostname'] + "\n");
25	log("path: " + urlData['path'] + "\n");	25	log("path: " + urlData['path'] + "\n");
26	log("port: " + urlData['port'] + "\n");*/	26	log("port: " + urlData['port'] + "\n");*/
27		27
28	this.myBuffer = "";	28	this.myBuffer = "";
29		29
30	this.mySocket = new Socket(function(event, data) { self.socketCallback(event, data); }, urlData['hostname'], urlData['port'], 0);	30	this.mySocket = new Socket(function(event, data) { self.socketCallback(event, data); }, urlData['hostname'], urlData['port'], 0);
31	this.mySocket.start();	31	this.mySocket.start();
32		32
33	this.myRequest = "GET " + urlData['path'] + " HTTP/1.1\r\n";	33	this.myRequest = "GET " + urlData['path'] + " HTTP/1.1\r\n";
34	this.myRequest += "Host: " + urlData['hostname'] + ":" + urlData['port'] + "\r\n";	34	this.myRequest += "Host: " + urlData['hostname'] + ":" + urlData['port'] + "\r\n";
35	this.myRequest += "User-Agent: Mozilla/5.0 (X11; U; Linux x86_64; en-US; rv:1.9.1.2) Gecko/20090730 SUSE/3.5.2-1.1 Firefox/3.5.2\r\n";	35	this.myRequest += "User-Agent: Mozilla/5.0 (X11; U; Linux x86_64; en-US; rv:1.9.1.2) Gecko/20090730 SUSE/3.5.2-1.1 Firefox/3.5.2\r\n";
36	this.myRequest += "Connection: close\r\n";	36	this.myRequest += "Connection: close\r\n";
37	this.myRequest += "\r\n";	37	this.myRequest += "\r\n";
38	}	38	}
39		39
40	HTTP.prototype.parseUrl = function(url)	40	HTTP.prototype.parseUrl = function(url)
41	{	41	{
42	var result = new Array();	42	var result = new Array();
43	result['port'] = 80;	43	result['port'] = 80;
44	result['path'] = "/";	44	result['path'] = "/";
45		45
46	var firstSlash = url.indexOf('/');	46	var firstSlash = url.indexOf('/');
47		47
48	if (firstSlash == -1)	48	if (firstSlash == -1)
49	{	49	{
50	result['hostname'] = url;	50	result['hostname'] = url;
51	}	51	}
52	else	52	else
53	{	53	{
54	result['hostname'] = url.substr(0, firstSlash);	54	result['hostname'] = url.substr(0, firstSlash);
55	result['path'] = url.substr(firstSlash);	55	result['path'] = url.substr(firstSlash);
56	}	56	}
57		57
58	var firstColon = result['hostname'].indexOf(':');	58	var firstColon = result['hostname'].indexOf(':');
59		59
60	if (firstColon != -1)	60	if (firstColon != -1)
61	{	61	{
62	result['port'] = result['hostname'].substr(firstColon+1);	62	result['port'] = result['hostname'].substr(firstColon+1);
63	result['hostname'] = result['hostname'].substr(0, firstColon);	63	result['hostname'] = result['hostname'].substr(0, firstColon);
64	}	64	}
65		65
66	return result;	66	return result;
67	}	67	}
68		68
69	HTTP.prototype.socketCallback = function(event, data)	69	HTTP.prototype.socketCallback = function(event, data)
70	{	70	{
71	switch (event)	71	switch (event)
72	{	72	{
73	case "CONNECTED":	73	case "CONNECTED":
74	this.mySocket.send(this.myRequest);	74	this.mySocket.send(this.myRequest);
75	break;	75	break;
76		76
77	case "DATA":	77	case "DATA":
78	this.myBuffer += unescape(data);	78	this.myBuffer += unescape(data);
79	break;	79	break;
80		80
81	case "RESET":	81	case "RESET":
82	case "CLOSED":	82	case "CLOSED":
83	case "DIED":	83	case "DIED":
84	this.mySocket.stop();	84	this.mySocket.stop();
85	this.processBuffer();	85	this.processBuffer();
86	this.mySocket = null;	86	this.mySocket = null;
87	break;	87	break;
88	}	88	}
89	}	89	}
90		90
91	HTTP.prototype.processBuffer = function()	91	HTTP.prototype.processBuffer = function()
92	{	92	{
93	///FIXME: This is a bit ugly code... also not fully HTTP/1.1 compliant look at http://www.jmarshall.com/easy/http/	93	///FIXME: This is a bit ugly code... also not fully HTTP/1.1 compliant look at http://www.jmarshall.com/easy/http/
94		94
95	var pos = this.myBuffer.indexOf("\n\n");	95	var pos = this.myBuffer.indexOf("\n\n");
96		96
97	var headerData = this.myBuffer.substr(0, pos);	97	var headerData = this.myBuffer.substr(0, pos);
98	var contentData = this.myBuffer.substr(pos+2);	98	var contentData = this.myBuffer.substr(pos+2);
99		99
100	var headerLines = headerData.split("\n");	100	var headerLines = headerData.split("\n");
101		101
102	var header = new Array();	102	var header = new Array();
103	var result = headerLines[0];	103	var result = headerLines[0];
104		104
105	for (var n = 1; n < headerLines.length; n++)	105	for (var n = 1; n < headerLines.length; n++)
106	{	106	{
107	var headerParts = headerLines[n].split(":", 2);	107	var headerParts = headerLines[n].split(":", 2);
108	header[headerParts[0]] = headerParts[1].trim(' ');	108	header[headerParts[0]] = headerParts[1].trim(' ');
109	}	109	}
110		110
111	this.myBuffer = "";	111	this.myBuffer = "";
112		112
-		113	if (this.myUserCallback != null)
-		114	{
113	this.myUserCallback(result, header, contentData);	115	this.myUserCallback(result, header, contentData);
-		116	this.myUserCallback = null;
-		117	}
114	}	118	}
115		119

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/Atom/Services/System/HTTP.js – Rev 1348 → 1402