summaryrefslogtreecommitdiff
path: root/content
diff options
context:
space:
mode:
Diffstat (limited to 'content')
-rw-r--r--content/activity_info_server.js35
-rw-r--r--content/repo_query.js113
2 files changed, 148 insertions, 0 deletions
diff --git a/content/activity_info_server.js b/content/activity_info_server.js
index 8435377..81a25fb 100644
--- a/content/activity_info_server.js
+++ b/content/activity_info_server.js
@@ -11,12 +11,20 @@
* IMPORTS_START
* IMPORT listen_for_connection
* IMPORT CONNECTION_TYPE
+ * IMPORT repo_query
+ * IMPORT subscribe_repo_query_results
+ * IMPORT unsubscribe_repo_query_results
* IMPORTS_END
*/
var activities = [];
var ports = new Set();
+function report_activity_oneshot(name, data, port)
+{
+ port.postMessage([name, data]);
+}
+
function report_activity(name, data)
{
const activity = [name, data];
@@ -36,6 +44,22 @@ function report_settings(settings)
report_activity("settings", settings);
}
+function report_repo_query_action(update, port)
+{
+ report_activity_oneshot("repo_query_action", update, port);
+}
+
+function trigger_repo_query(query_specifier)
+{
+ repo_query(...query_specifier);
+}
+
+function handle_disconnect(port, report_action)
+{
+ ports.delete(port)
+ unsubscribe_repo_query_results(report_action);
+}
+
function new_connection(port)
{
console.log("new activity info connection!");
@@ -44,6 +68,17 @@ function new_connection(port)
for (const activity of activities)
port.postMessage(activity);
+
+ const report_action = u => report_repo_query_action(u, port);
+ subscribe_repo_query_results(report_action);
+
+ /*
+ * So far the only thing we expect to receive is repo query order. Once more
+ * possibilities arrive, we will need to complicate this listener.
+ */
+ port.onMessage.addListener(trigger_repo_query);
+
+ port.onDisconnect.addListener(() => handle_disconnect(port, report_action));
}
function start_activity_info_server()
diff --git a/content/repo_query.js b/content/repo_query.js
new file mode 100644
index 0000000..3708108
--- /dev/null
+++ b/content/repo_query.js
@@ -0,0 +1,113 @@
+/**
+ * part of Hachette
+ * 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
+ */