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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
/**
* @license
* Copyright 2020 Google Inc.
* SPDX-License-Identifier: Apache-2.0
*/
import expect from 'expect';
import type {WebWorker} from 'puppeteer-core/internal/api/WebWorker.js';
import type {ConsoleMessage} from 'puppeteer-core/internal/common/ConsoleMessage.js';
import {getTestState, setupTestBrowserHooks} from './mocha-utils.js';
import {waitEvent} from './utils.js';
describe('Workers', function () {
setupTestBrowserHooks();
it('Page.workers', async () => {
const {page, server} = await getTestState();
await Promise.all([
waitEvent(page, 'workercreated'),
page.goto(server.PREFIX + '/worker/worker.html'),
]);
const worker = page.workers()[0]!;
expect(worker?.url()).toContain('worker.js');
expect(
await worker?.evaluate(() => {
return (globalThis as any).workerFunction();
})
).toBe('worker function result');
await page.goto(server.EMPTY_PAGE);
expect(page.workers()).toHaveLength(0);
});
it('should emit created and destroyed events', async () => {
const {page} = await getTestState();
const workerCreatedPromise = waitEvent<WebWorker>(page, 'workercreated');
using workerObj = await page.evaluateHandle(() => {
return new Worker('data:text/javascript,1');
});
const worker = await workerCreatedPromise;
using workerThisObj = await worker.evaluateHandle(() => {
return this;
});
const workerDestroyedPromise = waitEvent(page, 'workerdestroyed');
await page.evaluate((workerObj: Worker) => {
return workerObj.terminate();
}, workerObj);
expect(await workerDestroyedPromise).toBe(worker);
const error = await workerThisObj.getProperty('self').catch(error => {
return error;
});
expect(error.message).toContain('Most likely the worker has been closed.');
});
it('should report console logs', async () => {
const {page} = await getTestState();
const [message] = await Promise.all([
waitEvent(page, 'console'),
page.evaluate(() => {
return new Worker(`data:text/javascript,console.log(1)`);
}),
]);
expect(message.text()).toBe('1');
expect(message.location()).toEqual({
url: '',
lineNumber: 0,
columnNumber: 8,
});
});
it('should have JSHandles for console logs', async () => {
const {page} = await getTestState();
const logPromise = waitEvent<ConsoleMessage>(page, 'console');
await page.evaluate(() => {
return new Worker(`data:text/javascript,console.log(1,2,3,this)`);
});
const log = await logPromise;
expect(log.text()).toBe('1 2 3 JSHandle@object');
expect(log.args()).toHaveLength(4);
expect(await (await log.args()[3]!.getProperty('origin')).jsonValue()).toBe(
'null'
);
});
it('should have an execution context', async () => {
const {page} = await getTestState();
const workerCreatedPromise = waitEvent<WebWorker>(page, 'workercreated');
await page.evaluate(() => {
return new Worker(`data:text/javascript,console.log(1)`);
});
const worker = await workerCreatedPromise;
expect(await worker.evaluate('1+1')).toBe(2);
});
it('should report errors', async () => {
const {page} = await getTestState();
const errorPromise = waitEvent<Error>(page, 'pageerror');
await page.evaluate(() => {
return new Worker(
`data:text/javascript, throw new Error('this is my error');`
);
});
const errorLog = await errorPromise;
expect(errorLog.message).toContain('this is my error');
});
});
|
