-
-
- `,
- {
- runScripts: 'dangerously',
- virtualConsole,
- url: 'http://localhost'
- }
- );
-
- const { window } = dom;
- const document = window.document;
-
- global.window = window;
- global.document = document;
-
- global.navigator = {
- userAgent: 'node.js'
- };
- global.requestAnimationFrame = callback => setTimeout(callback, 0);
- global.cancelAnimationFrame = id => clearTimeout(id);
-
- // Provide dependencies, just provide all of them
- dom.window.React = require('react');
- dom.window.ReactDOM = require('react-dom');
- dom.window.PropTypes = require('prop-types');
- dom.window.Redux = require('redux');
- dom.window.ReduxThunk = require('redux-thunk');
- dom.window.ReactRedux = require('react-redux');
- dom.window.Enzyme = require('enzyme');
- const Adapter16 = require('enzyme-adapter-react-16');
- dom.window.Enzyme.configure({ adapter: new Adapter16() });
-
- dom.window.require = require;
- dom.window.code = code;
- dom.window.editor = {
- getValue() {
- return code;
- }
- };
-
- await runTestInJsdom(dom, test.testString, scriptString);
-}
-
-async function runTestInJsdom(dom, testString, scriptString = '') {
- // jQuery used by tests
- jQuery(dom.window);
-
- dom.window.assert = assert;
- dom.window.DeepEqual = DeepEqual;
- dom.window.DeepFreeze = DeepFreeze;
-
- dom.window.__test = testString;
- scriptString += `;
- window.__result =
- (async () => {
- try {
- const testResult = eval(__test);
- if (typeof testResult === 'function') {
- await testResult(() => code);
- }
- }catch (e) {
- window.__error = e;
- }
- })();`;
- const script = new vm.Script(scriptString);
- dom.runVMScript(script, { timeout: 5000 });
- await dom.window.__result;
- if (dom.window.__error) {
- throw dom.window.__error;
+ } finally {
+ testWorker.killWorker();
}
}
diff --git a/curriculum/test/utils/pseudo-worker.js b/curriculum/test/utils/pseudo-worker.js
new file mode 100644
index 0000000000..304bf2eeec
--- /dev/null
+++ b/curriculum/test/utils/pseudo-worker.js
@@ -0,0 +1,85 @@
+function createPseudoWorker(context) {
+ class PseudoWorker {
+ constructor(path) {
+ this.terminated = false;
+ this.worker = context.evaluateHandle(path => new Worker(path), path);
+ this.listenToWorker('onmessage');
+ this.listenToWorker('onerror');
+ }
+
+ terminate() {
+ this.terminated = true;
+ this.worker.then(worker =>
+ context.evaluate(worker => worker.terminate(), worker)
+ );
+ }
+
+ listenToWorker(eventName) {
+ this.worker.then(async worker => {
+ const producer = await context.evaluateHandle(
+ (worker, eventName) => {
+ let callback;
+ const queue = [];
+ function send(event) {
+ if (!queue.length && callback) {
+ callback();
+ }
+ queue.push(event);
+ }
+
+ worker[eventName] = e => send(e);
+
+ const resolver = resolve => (callback = resolve);
+ async function* produce() {
+ while (true) {
+ while (queue.length) {
+ yield queue.shift();
+ }
+ await new Promise(resolver);
+ }
+ }
+ return produce();
+ },
+ worker,
+ eventName
+ );
+ while (!this.terminated) {
+ try {
+ const data = await context.evaluate(
+ producer =>
+ producer
+ .next()
+ .then(({ value: { data, message } }) => ({ data, message })),
+ producer
+ );
+ if (this[eventName]) {
+ this[eventName](data);
+ }
+ } catch (err) {
+ break;
+ }
+ }
+ });
+ }
+
+ async postMessage(msg) {
+ if (this.terminated) {
+ throw new Error('Worker is terminated.');
+ }
+ try {
+ await this.worker.then(worker =>
+ worker
+ .executionContext()
+ .evaluate((worker, msg) => worker.postMessage(msg), worker, msg)
+ );
+ } catch (e) {
+ if (this.onerror) {
+ this.onerror({ message: e.message });
+ }
+ }
+ }
+ }
+ return PseudoWorker;
+}
+
+module.exports = createPseudoWorker;