From b7e2870ff58ef85370781aa04e9e0126988e39fd Mon Sep 17 00:00:00 2001
From: Wojtek Kosior <koszko@koszko.org>
Date: Tue, 6 Jul 2021 18:25:34 +0200
Subject: show some settings of the current page in the popup

---
 background/page_info_server.js | 77 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 77 insertions(+)
 create mode 100644 background/page_info_server.js

(limited to 'background/page_info_server.js')

diff --git a/background/page_info_server.js b/background/page_info_server.js
new file mode 100644
index 0000000..49919fd
--- /dev/null
+++ b/background/page_info_server.js
@@ -0,0 +1,77 @@
+/**
+ * part of Hachette
+ * Serving of storage data corresponding to requested urls (server side).
+ *
+ * Copyright (C) 2021 Wojtek Kosior
+ * Redistribution terms are gathered in the `copyright' file.
+ */
+
+/*
+ * IMPORTS_START
+ * IMPORT listen_for_connection
+ * IMPORT get_storage
+ * IMPORT get_query_all
+ * IMPORT TYPE_PREFIX
+ * IMPORT CONNECTION_TYPE
+ * IMPORT url_matches
+ * IMPORTS_END
+ */
+
+var storage;
+var query_all;
+
+function handle_change(connection_data, change)
+{
+    if (change.prefix !== TYPE_PREFIX.PAGE)
+	return;
+
+    connection_data.port.postMessage(["change", change]);
+}
+
+async function handle_subscription(connection_data, message)
+{
+    const [action, url] = message;
+    if (action === "unsubscribe") {
+	connection_data.subscribed.delete(url);
+	return;
+    }
+
+    connection_data.subscribed.add(url);
+    connection_data.port.postMessage(["new_url", query_all(url)]);
+}
+
+function remove_storage_listener(cb)
+{
+    storage.remove_change_listener(cb);
+}
+
+function new_connection(port)
+{
+    console.log("new page info connection!");
+
+    const connection_data = {
+	subscribed : new Set(),
+	port
+    };
+
+    let _handle_change = change => handle_change(connection_data, change);
+
+    storage.add_change_listener(_handle_change);
+
+    port.onMessage.addListener(m => handle_subscription(connection_data, m));
+    port.onDisconnect.addListener(() => remove_storage_listener(handle_change));
+}
+
+async function start_page_info_server()
+{
+    storage = await get_storage();
+    query_all = await get_query_all();
+
+    listen_for_connection(CONNECTION_TYPE.PAGE_INFO, new_connection);
+}
+
+/*
+ * EXPORTS_START
+ * EXPORT start_page_info_server
+ * EXPORTS_END
+ */
-- 
cgit v1.2.3