Changeset 21

Timestamp:

02/25/06 13:42:53 (3 years ago)

Author:

atack2

Message:

Combined server and client code, we should start testing with this

Files:

• test_projects/pseudoServer/content/overlay.js (modified) (1 diff)

test_projects/pseudoServer/content/overlay.js

@@ -90 +90 @@
-serverSocket.asyncListen(serverListener);
-myDump("Listening!");
+
+var myObserver = {
+        observe: function(subject,topic,data){
+                subject = subject.QueryInterface(Components.interfaces.nsIHttpChannel);
+                subject.setRequestHeader("Supports", "Overhaul 50 5000", false);
+        }
+}
+
+var observerService = Components.classes["@mozilla.org/observer-service;1"]
+.getService(Components.interfaces.nsIObserverService);
+
+observerService.addObserver(myObserver,"http-on-modify-request",false);
+var host="128.174.253.222";
+var port="7055";
+
+var transportService =Components.classes["@mozilla.org/network/socket-transport-service;1"]
+                                .getService(Components.interfaces.nsISocketTransportService);
+var cliantSocket = transportService.createTransport(null,0,host,port,null);
+var outstream = cliantSocket.openOutputStream(0,0,0);
+var sendingMessage="GET /file.html CHUNK <#> HTTP\1.0\n\n";
+outstream.write(sendingMessage,sendingMessage.length);
+
+var sendingSecondMessage="HOST localhost\n\n";
+outstream.write(sendingSecondMessage,sendingSecondMessage.length);
+
+var sendingPortMessage="Overhaul-port: <7055>\n\n";
+outstream.write(sendingPortMessage,sendingPortMessage.length);
+
+var sendingHostsPortMessage="Overhaul-hosts: <localhost:7055>\n\n";
+outstream.write(sendingHostsPortMessage,sendingHostsPortMessage.length);
+
+var sendingChunkMessage="Overhaul-hosts: <CHUNKDATA>\n\n";
+outstream.write(sendingChunkMessage,sendingChunkMessage.length);
+
+var listener = {
+        finished : function(data){
+        dump(data);
+        }
+}   
+var stream = cliantSocket.openInputStream(0,0,0);
+var instream = Components.classes["@mozilla.org/scriptableinputstream;1"]
+  .createInstance(Components.interfaces.nsIScriptableInputStream);
+instream.init(stream);
+var dataListener2 = {
+        data : "",  
+        onStartRequest: function(request, context){},
+        onStopRequest: function(request, context, status){
+        instream.close();
+        listener.finished(this.data);
+        alert(this.data);
+        outstream.write(this.data,this.data.length);
+        outstream.close();
+  },
+        onDataAvailable: function(request, context, inputStream, offset, count){
+        this.data += instream.read(count);
+  }
+};
+
+
+var pump = Components.classes["@mozilla.org/network/input-stream-pump;1"].
+        createInstance(Components.interfaces.nsIInputStreamPump);
+pump.init(stream, -1, -1, 0, 0, true);
+pump.asyncRead(dataListener2,null);