From 8bea7893af3b812ce0a4765b90569b0ab24f9db8 Mon Sep 17 00:00:00 2001
From: deuce <>
Date: Thu, 14 May 2009 04:29:36 +0000
Subject: [PATCH] Add start of HTTP library... currently only does basic
HTTP/1.0 and only supports the GET method.
---
exec/load/http.js | 103 ++++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 103 insertions(+)
create mode 100644 exec/load/http.js
diff --git a/exec/load/http.js b/exec/load/http.js
new file mode 100644
index 0000000000..9b93f30fee
--- /dev/null
+++ b/exec/load/http.js
@@ -0,0 +1,103 @@
+load('sockdefs.js');
+load("URL.js");
+
+/*
+ * TODO Stuff:
+ * Asynchronous requests
+ * Keep-alive support
+ * HTTP/1.1 (chunked, trailers, etc)
+ * Parse response headers
+ */
+
+function HTTPRequest()
+{
+ this.AddDefaultHeaders=function(){
+ // General Headers
+ this.request_headers.push("Connection: close");
+ if(js.global.client != undefined)
+ this.request_headers.push("Via: "+client.protocol.toLowerCase()+"/1.0 "+system.name);
+ // Request Headers
+ this.request_headers.push("Accept: text/*");
+ this.request_headers.push("Accept-Charset: ISO-8859-13,Latin-9,ISO-8859-15");
+ this.request_headers.push("Accept-Encoding: ");
+ this.request_headers.push("Host: "+this.url.host);
+ if(this.referer != undefined)
+ this.request_headers.push("Referer: "+referer);
+ this.request_headers.push("User-Agent: SYNXv0.1");
+ };
+
+ this.SetupGet=function(url, referer, base) {
+ this.referer=referer;
+ this.base=base;
+ this.url=new URL(url, this.base);
+ if(this.url.scheme!='http')
+ throw("Unknown scheme! '"+this.url.scheme+"'");
+ if(this.url.path=='')
+ this.url.path='/';
+ this.request="GET "+url.path+" HTTP/1.0";
+ this.request_headers=[];
+ this.AddDefaultHeaders();
+ };
+
+ this.SendRequest=function() {
+ var i;
+
+ if((this.sock=new Socket(SOCK_STREAM))==null)
+ throw("Unable to create socket");
+ if(!this.sock.connect(this.url.host, this.url.port?this.url.port:80))
+ throw("Unable to connect");
+ if(!this.sock.send(this.request+"\r\n"))
+ throw("Unable to send request");
+ for(i in this.request_headers) {
+ if(!this.sock.send(this.request_headers[i]+"\r\n"))
+ throw("Unable to send headers");
+ }
+ if(!this.sock.send("\r\n"))
+ throw("Unable to terminate headers");
+ if(this.body != undefined) {
+ if(!this.sock.send(this.body))
+ throw("Unable to send body");
+ }
+ };
+
+ this.ReadStatus=function() {
+ this.status_line=this.sock.recvline(4096);
+ if(this.status_line==null)
+ throw("Unable to read status");
+ };
+
+ this.ReadHeaders=function() {
+ var header='';
+ this.response_headers=[];
+
+ for(;;) {
+ header=this.sock.recvline(4096);
+ if(header==null)
+ throw("Unable to receive headers");
+ if(header=='')
+ return;
+ }
+ };
+
+ this.ReadBody=function() {
+ var ch;
+
+ this.body='';
+ while((ch=this.sock.recv(1))!=null && ch != '') {
+ this.body += ch;
+ }
+ };
+
+ this.ReadResponse=function() {
+ this.ReadStatus();
+ this.ReadHeaders();
+ this.ReadBody();
+ };
+
+ this.Get=function(url, referer, base) {
+ this.SetupGet(url,referer,base);
+ this.SendRequest();
+ this.ReadResponse();
+ return(this.body);
+ };
+}
--
GitLab