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
|
import {makeSearchIndexes} from '../shared-util/searchSchema.js';
import {withEntries} from '../shared-util/sugar.js';
import FlexSearch from '../lib/flexsearch/flexsearch.bundle.module.min.js';
let status = null;
let indexes = null;
let searchData = null;
onmessage = handleWindowMessage;
postStatus('alive');
main().then(
() => {
postStatus('ready');
});
async function main() {
indexes =
makeSearchIndexes(FlexSearch);
searchData =
await fetch('/search-data/index.json')
.then(resp => resp.json());
// If this fails, it's because an outdated index was cached.
// TODO: If this fails, try again once with a cache busting url.
for (const [indexName, indexData] of Object.entries(searchData)) {
for (const [key, value] of Object.entries(indexData)) {
indexes[indexName].import(key, value);
}
}
}
function handleWindowMessage(message) {
switch (message.data.kind) {
case 'action':
handleWindowActionMessage(message);
break;
default:
console.warn(`Unknown message kind -> to search worker:`, message.data);
break;
}
}
async function handleWindowActionMessage(message) {
const {id} = message.data;
if (!id) {
console.warn(`Action without id -> to search worker:`, message.data);
return;
}
if (status !== 'ready') {
return postActionResult(id, 'reject', 'not ready');
}
let value;
switch (message.data.action) {
case 'search':
value = await performSearch(message.data.options);
break;
default:
console.warn(`Unknown action "${message.data.action}" -> to search worker:`, message.data);
return postActionResult(id, 'reject', 'unknown action');
}
await postActionResult(id, 'resolve', value);
}
function postStatus(newStatus) {
status = newStatus;
postMessage({
kind: 'status',
status: newStatus,
});
}
function postActionResult(id, status, value) {
postMessage({
kind: 'result',
id,
status,
value,
});
}
function performSearch({query, options}) {
return (
withEntries(indexes, entries => entries
.map(([indexName, index]) => [
indexName,
index.search(query, options),
])));
}
|
