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
110
111
112
113
114
|
/**
* This file is part of Haketilo.
*
* Function: Getting available content for site from remote repositories.
*
* Copyright (C) 2021 Wojtek Kosior
* Redistribution terms are gathered in the `copyright' file.
*/
/*
* IMPORTS_START
* IMPORT make_ajax_request
* IMPORT observables
* IMPORT TYPE_PREFIX
* IMPORT parse_json_with_schema
* IMPORT matchers
* IMPORTS_END
*/
const paths = {
[TYPE_PREFIX.PAGE]: "/pattern",
[TYPE_PREFIX.BAG]: "/bag",
[TYPE_PREFIX.SCRIPT]: "/script",
[TYPE_PREFIX.URL]: "/query"
};
const queried_items = new Map();
const observable = observables.make();
function repo_query(prefix, item, repo_urls)
{
const key = prefix + item;
const results = queried_items.get(key) || {};
queried_items.set(key, results);
for (const repo_url of repo_urls)
perform_query_against(key, repo_url, results);
}
const page_schema = {
pattern: matchers.nonempty_string,
payload: ["optional", matchers.component, "default", undefined]
};
const bag_schema = {
name: matchers.nonempty_string,
components: ["optional", [matchers.component, "repeat"], "default", []]
};
const script_schema = {
name: matchers.nonempty_string,
location: matchers.nonempty_string,
sha256: matchers.sha256,
};
const search_result_schema = [page_schema, "repeat"];
const schemas = {
[TYPE_PREFIX.PAGE]: page_schema,
[TYPE_PREFIX.BAG]: bag_schema,
[TYPE_PREFIX.SCRIPT]: script_schema,
[TYPE_PREFIX.URL]: search_result_schema
}
async function perform_query_against(key, repo_url, results)
{
if (results[repo_url] !== undefined)
return;
const prefix = key[0];
const item = key.substring(1);
const result = {state: "started"};
results[repo_url] = result;
const broadcast_msg = {prefix, item, results: {[repo_url]: result}};
observables.broadcast(observable, broadcast_msg);
let state = "connection_error";
const query_url =
`${repo_url}${paths[prefix]}?n=${encodeURIComponent(item)}`;
try {
let xhttp = await make_ajax_request("GET", query_url);
if (xhttp.status === 200) {
state = "parse_error";
result.response =
parse_json_with_schema(schemas[prefix], xhttp.responseText);
state = "completed";
}
} catch (e) {
console.log(e);
}
result.state = state;
observables.broadcast(observable, broadcast_msg);
}
function subscribe_repo_query_results(cb)
{
observables.subscribe(observable, cb);
for (const [key, results] of queried_items.entries())
cb({prefix: key[0], item: key.substring(1), results});
}
function unsubscribe_repo_query_results(cb)
{
observables.unsubscribe(observable, cb);
}
/*
* EXPORTS_START
* EXPORT repo_query
* EXPORT subscribe_repo_query_results
* EXPORT unsubscribe_repo_query_results
* EXPORTS_END
*/
|
