merge facility to install from Hydrilla

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
+ */