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
|
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';
import { TestGroup } from '../../internal/test_group.js';
import { assert } from '../../util/util.js';
import { setupWorkerEnvironment, WorkerTestRunRequest } from './utils_worker.js';
/**
* Sets up the currently running Web Worker to wrap the TestGroup object `g`.
* `g` is the `g` exported from a `.spec.ts` file: a TestGroupBuilder<F> interface,
* which underneath is actually a TestGroup<F> object.
*
* This is used in the generated `.worker.js` files that are generated to use as service workers.
*/
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 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}`);
ev.source?.postMessage({
query,
result: {
status: 'fail',
timems: 0,
logs: [LogMessageWithStack.wrapError('INTERNAL', ex)],
},
});
}
};
}
|
