blob: bee7bd70154c4900cdf02f74a00ffc09d0464b4e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
"use strict";
Cu.import("resource://gre/modules/Timer.jsm");
function actuallyHandleRequest(req, res) {
res.setHeader("Content-Type", "application/octet-stream", false);
res.write("abc123");
res.finish();
}
function handleRequest(req, res) {
if (req.queryString.includes('finish')) {
res.write("OK");
let downloadReq = null;
getObjectState("downloadReq", o => { downloadReq = o });
// Two possibilities: either the download request has already reached us, or not.
if (downloadReq) {
downloadReq.wrappedJSObject.callback();
} else {
// Set a variable to allow the request to complete immediately:
setState("finishReq", "true");
}
} else if (req.queryString.includes('reset')) {
res.write("OK");
setObjectState("downloadReq", null);
setState("finishReq", "false");
} else {
res.processAsync();
if (getState("finishReq") === "true") {
actuallyHandleRequest(req, res);
} else {
let o = {callback() { actuallyHandleRequest(req, res) }};
o.wrappedJSObject = o;
o.QueryInterface = () => o;
setObjectState("downloadReq", o);
}
}
}
|
