|
1 /* Any copyright is dedicated to the Public Domain. |
|
2 * http://creativecommons.org/publicdomain/zero/1.0/ |
|
3 */ |
|
4 |
|
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); |
|
29 |
|
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); |
|
34 |
|
35 file.append("tests"); |
|
36 file.append("image"); |
|
37 file.append("test"); |
|
38 file.append("mochitest"); |
|
39 file.append(aFilename); |
|
40 |
|
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 } |
|
46 |
|
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 } |
|
61 |
|
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 } |
|
85 |
|
86 function sendClose(response) { |
|
87 response.write("--BOUNDARYOMG--\r\n"); |
|
88 response.finish(); |
|
89 } |
|
90 |
|
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 } |
|
104 |