Wed, 31 Dec 2014 06:55:46 +0100
Added tag TORBROWSER_REPLICA for changeset 6474c204b198
1 /* Any copyright is dedicated to the Public Domain.
2 * http://creativecommons.org/publicdomain/zero/1.0/
3 */
5 var bodyPartIndex = -1;
6 var bodyParts = [
7 ["red.png", "image/png"],
8 ["animated-gif2.gif", "image/gif"],
9 ["red.png", "image/png"],
10 ["lime100x100.svg", "image/svg+xml"],
11 ["lime100x100.svg", "image/svg+xml"],
12 ["animated-gif2.gif", "image/gif"],
13 ["red.png", "image/png"],
14 // Mime type intentionally wrong (test for bug 907575)
15 ["shaver.png", "image/gif"],
16 ["red.png", "image/png"],
17 ["damon.jpg", "image/jpeg"],
18 ["damon.jpg", "application/octet-stream"],
19 ["damon.jpg", "image/jpeg"],
20 ["rillybad.jpg", "application/x-unknown-content-type"],
21 ["damon.jpg", "image/jpeg"],
22 ["bad.jpg", "image/jpeg"],
23 ["red.png", "image/png"],
24 ["invalid.jpg", "image/jpeg"],
25 ["animated-gif2.gif", "image/gif"]
26 ];
27 var timer = Components.classes["@mozilla.org/timer;1"];
28 var partTimer = timer.createInstance(Components.interfaces.nsITimer);
30 function getFileAsInputStream(aFilename) {
31 var file = Components.classes["@mozilla.org/file/directory_service;1"]
32 .getService(Components.interfaces.nsIProperties)
33 .get("CurWorkD", Components.interfaces.nsIFile);
35 file.append("tests");
36 file.append("image");
37 file.append("test");
38 file.append("mochitest");
39 file.append(aFilename);
41 var fileStream = Components.classes['@mozilla.org/network/file-input-stream;1']
42 .createInstance(Components.interfaces.nsIFileInputStream);
43 fileStream.init(file, 1, 0, false);
44 return fileStream;
45 }
47 function handleRequest(request, response)
48 {
49 if (!getSharedState("next-part")) {
50 setSharedState("next-part", "-1");
51 }
52 response.setHeader("Content-Type",
53 "multipart/x-mixed-replace;boundary=BOUNDARYOMG", false);
54 response.setHeader("Cache-Control", "no-cache", false);
55 response.setStatusLine(request.httpVersion, 200, "OK");
56 // We're sending parts off in a delayed fashion, to let the tests occur.
57 response.processAsync();
58 response.write("--BOUNDARYOMG\r\n");
59 sendParts(response);
60 }
62 function sendParts(response) {
63 let wait = false;
64 let nextPart = parseInt(getSharedState("next-part"), 10);
65 if (nextPart == bodyPartIndex) {
66 // Haven't been signaled yet, remain in holding pattern
67 wait = true;
68 } else {
69 bodyPartIndex = nextPart;
70 }
71 if (bodyParts.length > bodyPartIndex) {
72 let callback;
73 if (!wait) {
74 callback = getSendNextPart(response);
75 } else {
76 callback = function () { sendParts(response); };
77 }
78 partTimer.initWithCallback(callback, 1000,
79 Components.interfaces.nsITimer.TYPE_ONE_SHOT);
80 }
81 else {
82 sendClose(response);
83 }
84 }
86 function sendClose(response) {
87 response.write("--BOUNDARYOMG--\r\n");
88 response.finish();
89 }
91 function getSendNextPart(response) {
92 var part = bodyParts[bodyPartIndex];
93 var nextPartHead = "Content-Type: " + part[1] + "\r\n\r\n";
94 var inputStream = getFileAsInputStream(part[0]);
95 return function () {
96 response.bodyOutputStream.write(nextPartHead, nextPartHead.length);
97 response.bodyOutputStream.writeFrom(inputStream, inputStream.available());
98 inputStream.close();
99 // Toss in the boundary, so the browser can know this part is complete
100 response.write("--BOUNDARYOMG\r\n");
101 sendParts(response);
102 }
103 }