fix Data URLs and add Data URL tests

fix Data URLs and add Data URL tests

Author: developit

src/node/index.js

@@ -176,7 +176,7 @@ function workerThread() {
 
 	const isDataUrl = /^data:/.test(mod);
 	if (type === 'module') {
-		import(URL.pathToFileURL(mod))
+		import(isDataUrl ? mod : URL.pathToFileURL(mod))
 			.catch(err => {
 				if (isDataUrl && err.message === 'Not supported') {
 					console.warn('Worker(): Importing data: URLs requires Node 12.10+. Falling back to classic worker.');

test/index.test.js

@@ -19,8 +19,8 @@ import Worker from '../dist/node/index.cjs';
 
 let worker;
 
-function createModuleWorker(url) {
-	const worker = new Worker(url, { type: 'module' });
+function createModuleWorker(url, opts) {
+	const worker = new Worker(url, opts || { type: 'module' });
 	worker.events = [];
 	worker.addEventListener('message', e => {
 		worker.events.push(e);
@@ -36,7 +36,7 @@ test.after.always(t => {
 
 test.serial('instantiation', async t => {
 	worker = createModuleWorker('./test/fixtures/worker.mjs');
-	await sleep(500);
+	await sleep(50);
 	t.is(worker.events.length, 1, 'should have received a message event');
 	t.is(worker.events[0].data, 42);
 });
@@ -49,7 +49,7 @@ test.serial('postMessage', async t => {
 	worker.postMessage(msg);
 	const timestamp = Date.now();
 
-	await sleep(500);
+	await sleep(50);
 
 	t.is(worker.events.length, 2, 'should have received two message responses');
 
@@ -75,3 +75,19 @@ test.serial('close', async t => {
 	});
 	t.is(closed, true, 'should have closed itself');
 });
+
+test.serial('data URL - module', async t => {
+	t.teardown(() => worker && worker.terminate());
+	const worker = createModuleWorker('data:application/javascript,postMessage(42)');
+	await sleep(50);
+	t.is(worker.events.length, 1, 'should have received a message event');
+	t.is(worker.events[0].data, 42);
+});
+
+test.serial('data URL - classic', async t => {
+	t.teardown(() => worker && worker.terminate());
+	const worker = createModuleWorker('data:application/javascript,postMessage(42)', {});
+	await sleep(50);
+	t.is(worker.events.length, 1, 'should have received a message event');
+	t.is(worker.events[0].data, 42);
+});