58f8093689
- Updated all component headers and documentation
- Changed navbar and footer branding
- Updated homepage hero badge
- Modified page title in index.html
- Simplified footer text to 'Built with ❤️'
- Consistent V2 capitalization across all references
65 lines
2.5 KiB
JavaScript
65 lines
2.5 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
const enums_1 = require("../enums");
|
|
const sandbox = (processFile, childPool) => {
|
|
return async function process(job, token) {
|
|
const child = await childPool.retain(processFile);
|
|
let msgHandler;
|
|
let exitHandler;
|
|
await child.send({
|
|
cmd: enums_1.ChildCommand.Start,
|
|
job: job.asJSONSandbox(),
|
|
token,
|
|
});
|
|
const done = new Promise((resolve, reject) => {
|
|
msgHandler = async (msg) => {
|
|
var _a, _b;
|
|
switch (msg.cmd) {
|
|
case enums_1.ParentCommand.Completed:
|
|
resolve(msg.value);
|
|
break;
|
|
case enums_1.ParentCommand.Failed:
|
|
case enums_1.ParentCommand.Error: {
|
|
const err = new Error();
|
|
Object.assign(err, msg.value);
|
|
reject(err);
|
|
break;
|
|
}
|
|
case enums_1.ParentCommand.Progress:
|
|
await job.updateProgress(msg.value);
|
|
break;
|
|
case enums_1.ParentCommand.Log:
|
|
await job.log(msg.value);
|
|
break;
|
|
case enums_1.ParentCommand.MoveToDelayed:
|
|
await job.moveToDelayed((_a = msg.value) === null || _a === void 0 ? void 0 : _a.timestamp, (_b = msg.value) === null || _b === void 0 ? void 0 : _b.token);
|
|
break;
|
|
case enums_1.ParentCommand.Update:
|
|
await job.updateData(msg.value);
|
|
break;
|
|
}
|
|
};
|
|
exitHandler = (exitCode, signal) => {
|
|
reject(new Error('Unexpected exit code: ' + exitCode + ' signal: ' + signal));
|
|
};
|
|
child.on('message', msgHandler);
|
|
child.on('exit', exitHandler);
|
|
});
|
|
try {
|
|
await done;
|
|
return done;
|
|
}
|
|
finally {
|
|
child.off('message', msgHandler);
|
|
child.off('exit', exitHandler);
|
|
if (child.exitCode !== null || /SIG.*/.test(`${child.signalCode}`)) {
|
|
childPool.remove(child);
|
|
}
|
|
else {
|
|
childPool.release(child);
|
|
}
|
|
}
|
|
};
|
|
};
|
|
exports.default = sandbox;
|
|
//# sourceMappingURL=sandbox.js.map
|