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.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();
   
    var request = "GET " + urlData['path'] + " HTTP/1.1\n";
    request += "Host: " + urlData['hostname'] + "\n";
    request += "Connection: close\n";
    request += "\n";
   
    this.mySocket.send(request);
}
 
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 "EVENT_DATA":
    this.myBuffer += unescape(data);
    break;
   
    case "EVENT_CLOSED":
    case "EVENT_DIED":
    this.mySocket.stop();
    this.processBuffer();
    break;
   
    case "EVENT_INACTIVITY":
    break;
    }
}
 
HTTP.prototype.processBuffer = function()
{
    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 = "";
   
    this.myUserCallback(result, header, contentData);
}
 

Rev 976	Rev 977
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		9
10	HTTP.prototype.request = function(callback, url)	10	HTTP.prototype.request = function(callback, url)
11	{	11	{
12	this.myUserCallback = callback;	12	this.myUserCallback = callback;
13		13
14	if (this.mySocket)	14	if (this.mySocket)
15	{	15	{
16	this.mySocket.stop();	16	this.mySocket.stop();
17	}	17	}
18		18
19	var self = this;	19	var self = this;
20		20
21	var urlData = this.parseUrl(url);	21	var urlData = this.parseUrl(url);
22		22
23	/*log("hostname: " + urlData['hostname'] + "\n");	23	/*log("hostname: " + urlData['hostname'] + "\n");
24	log("path: " + urlData['path'] + "\n");	24	log("path: " + urlData['path'] + "\n");
25	log("port: " + urlData['port'] + "\n");*/	25	log("port: " + urlData['port'] + "\n");*/
26		26
27	this.myBuffer = "";	27	this.myBuffer = "";
28		28
29	this.mySocket = new Socket(function(event, data) { self.socketCallback(event, data); }, urlData['hostname'], urlData['port'], 0);	29	this.mySocket = new Socket(function(event, data) { self.socketCallback(event, data); }, urlData['hostname'], urlData['port'], 0);
30	this.mySocket.start();	30	this.mySocket.start();
31		31
32	var request = "GET " + urlData['path'] + " HTTP/1.1\n";	32	var request = "GET " + urlData['path'] + " HTTP/1.1\n";
33	request += "Host: " + urlData['hostname'] + "\n";	33	request += "Host: " + urlData['hostname'] + "\n";
34	request += "Connection: close\n";	34	request += "Connection: close\n";
35	request += "\n";	35	request += "\n";
36		36
37	this.mySocket.send(request);	37	this.mySocket.send(request);
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 "EVENT_DATA":	73	case "EVENT_DATA":
74	this.myBuffer += unescape(data);	74	this.myBuffer += unescape(data);
75	break;	75	break;
76		76
77	case "EVENT_CLOSED":	77	case "EVENT_CLOSED":
78	case "EVENT_DIED":	78	case "EVENT_DIED":
79	this.mySocket.stop();	79	this.mySocket.stop();
80	this.processBuffer();	80	this.processBuffer();
81	break;	81	break;
82		82
83	case "EVENT_INACTIVITY":	83	case "EVENT_INACTIVITY":
84	break;	84	break;
85	}	85	}
86	}	86	}
87		87
88	HTTP.prototype.processBuffer = function()	88	HTTP.prototype.processBuffer = function()
89	{	89	{
90	var pos = this.myBuffer.indexOf("\n\n");	90	var pos = this.myBuffer.indexOf("\n\n");
91		91
92	var headerData = this.myBuffer.substr(0, pos);	92	var headerData = this.myBuffer.substr(0, pos);
93	var contentData = this.myBuffer.substr(pos+2);	93	var contentData = this.myBuffer.substr(pos+2);
94		94
95	var headerLines = headerData.split("\n");	95	var headerLines = headerData.split("\n");
96		96
97	var header = new Array();	97	var header = new Array();
98	var result = headerLines[0];	98	var result = headerLines[0];
99		99
100	for (var n = 1; n < headerLines.length; n++)	100	for (var n = 1; n < headerLines.length; n++)
101	{	101	{
102	var headerParts = headerLines[n].split(":", 2);	102	var headerParts = headerLines[n].split(":", 2);
103	header[headerParts[0]] = headerParts[1].trim(' ');	103	header[headerParts[0]] = headerParts[1].trim(' ');
104	}	104	}
-		105
-		106	this.myBuffer = "";
105		107
106	this.myUserCallback(result, header, contentData);	108	this.myUserCallback(result, header, contentData);
107	}	109	}
108		110

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/Atom/Services/System/HTTP.js – Rev 976 → 977