Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add service worker support #3419

Merged
merged 26 commits into from
Mar 11, 2024
Merged
Changes from 1 commit
Commits
Show all changes
26 commits
Select commit Hold shift + click to select a range
fec22b7
Generate Web Worker script for every test file
kainino0x Feb 16, 2024
533afe4
Add service worker support
beaufortfrancois Feb 19, 2024
20444d0
Update wpt.ts
beaufortfrancois Feb 26, 2024
23f0a47
Run tests
beaufortfrancois Mar 4, 2024
675f6ad
Address kainino0x feedback
beaufortfrancois Mar 6, 2024
5d0e4c0
Address feedback | part 2
beaufortfrancois Mar 6, 2024
4ea5270
Address feedback | part 3
beaufortfrancois Mar 6, 2024
46683bf
Address feedback | part 4
beaufortfrancois Mar 7, 2024
b5b8538
Address feedback | part 5
beaufortfrancois Mar 7, 2024
0f173fa
Address feedback | part 6
beaufortfrancois Mar 7, 2024
1a6123a
Address feedback | part 7
beaufortfrancois Mar 7, 2024
e3b63ff
Address feedback | part 8
beaufortfrancois Mar 7, 2024
01750a3
Address feedback | part 9
beaufortfrancois Mar 7, 2024
8730e55
Apply suggestions from code review
kainino0x Mar 7, 2024
ffff9fd
use WorkerTestRunRequest in the postMessage/onmessage interface
kainino0x Mar 7, 2024
4d78304
Clean up resolvers map
kainino0x Mar 7, 2024
0571de7
Use express routing for .worker.js
kainino0x Mar 7, 2024
465dd64
Skip worker tests when run in a worker that can't support them
kainino0x Mar 7, 2024
d66ce41
Clean up all service workers on startup and shutdown
kainino0x Mar 8, 2024
01f8b22
Avoid reinitializing service workers for every single case
kainino0x Mar 8, 2024
d03d129
Merge branch 'main' into service-worker
kainino0x Mar 8, 2024
5eb75c3
lint fixes
kainino0x Mar 8, 2024
749ee9c
Merge branch 'main' into service-worker
kainino0x Mar 8, 2024
4c8178f
Catch errors in wrapTestGroupForWorker onMessage
kainino0x Mar 8, 2024
97e378e
Make sure the service worker has the correct URL
kainino0x Mar 8, 2024
53173a5
Merge branch 'main' into service-worker
kainino0x Mar 11, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
41 changes: 25 additions & 16 deletions src/common/runtime/helper/wrap_for_worker.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
import { Fixture } from '../../framework/fixture';
import { LogMessageWithStack } from '../../internal/logging/log_message.js';
import { comparePaths, comparePublicParamsPaths, Ordering } from '../../internal/query/compare.js';
import { parseQuery } from '../../internal/query/parseQuery.js';
import { TestQuerySingleCase } from '../../internal/query/query.js';
Expand All @@ -10,25 +11,33 @@ import { setupWorkerEnvironment, WorkerTestRunRequest } from './utils_worker.js'
export function wrapTestGroupForWorker(g: TestGroup<Fixture>) {
self.onmessage = async (ev: MessageEvent) => {
const { query, expectations, ctsOptions } = ev.data as WorkerTestRunRequest;
try {
const log = setupWorkerEnvironment(ctsOptions);

const log = setupWorkerEnvironment(ctsOptions);

const testQuery = parseQuery(query);
assert(testQuery instanceof TestQuerySingleCase);
let testcase = null;
for (const t of g.iterate()) {
if (comparePaths(t.testPath, testQuery.testPathParts) !== Ordering.Equal) {
continue;
}
for (const c of t.iterate(testQuery.params)) {
if (comparePublicParamsPaths(c.id.params, testQuery.params) === Ordering.Equal) {
testcase = c;
const testQuery = parseQuery(query);
assert(testQuery instanceof TestQuerySingleCase);
let testcase = null;
for (const t of g.iterate()) {
if (comparePaths(t.testPath, testQuery.testPathParts) !== Ordering.Equal) {
continue;
}
for (const c of t.iterate(testQuery.params)) {
if (comparePublicParamsPaths(c.id.params, testQuery.params) === Ordering.Equal) {
testcase = c;
}
}
}
assert(!!testcase, 'testcase not found');
const [rec, result] = log.record(query);
await testcase.run(rec, testQuery, expectations);

ev.source?.postMessage({ query, result });
} catch (thrown) {
const ex = thrown instanceof Error ? thrown : new Error(`${thrown}`);
kainino0x marked this conversation as resolved.
Show resolved Hide resolved
ev.source?.postMessage({
query,
result: { status: 'fail', timems: 0, logs: [new LogMessageWithStack('INTERNAL', ex)] },
});
}
assert(!!testcase);
const [rec, result] = log.record(query);
await testcase.run(rec, testQuery, expectations);
ev.source?.postMessage({ query, result });
};
}