From 9e26b71e8e6d2dd1c08d29972c96d3114b1bd24a Mon Sep 17 00:00:00 2001
From: Wojtek Kosior <koszko@koszko.org>
Date: Tue, 20 Jul 2021 11:19:37 +0200
Subject: fix page info server bugs

---
 background/message_server.js   | 37 -------------------------------------
 background/page_info_server.js |  9 +++------
 2 files changed, 3 insertions(+), 43 deletions(-)
 delete mode 100644 background/message_server.js

(limited to 'background')

diff --git a/background/message_server.js b/background/message_server.js
deleted file mode 100644
index a541a04..0000000
--- a/background/message_server.js
+++ /dev/null
@@ -1,37 +0,0 @@
-/**
- * Myext message server
- *
- * Copyright (C) 2021 Wojtek Kosior
- * Redistribution terms are gathered in the `copyright' file.
- */
-
-/*
- * IMPORTS_START
- * IMPORT browser
- * IMPORTS_END
- */
-
-var listeners = {};
-
-/* magic should be one of the constants from /common/connection_types.js */
-
-function listen_for_connection(magic, cb)
-{
-    listeners[magic] = cb;
-}
-
-function raw_listen(port)
-{
-    if (listeners[port.name] === undefined)
-	return;
-
-    listeners[port.name](port);
-}
-
-browser.runtime.onConnect.addListener(raw_listen);
-
-/*
- * EXPORTS_START
- * EXPORT listen_for_connection
- * EXPORTS_END
- */
diff --git a/background/page_info_server.js b/background/page_info_server.js
index 49919fd..6f02750 100644
--- a/background/page_info_server.js
+++ b/background/page_info_server.js
@@ -40,11 +40,6 @@ async function handle_subscription(connection_data, message)
     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!");
@@ -59,7 +54,9 @@ function new_connection(port)
     storage.add_change_listener(_handle_change);
 
     port.onMessage.addListener(m => handle_subscription(connection_data, m));
-    port.onDisconnect.addListener(() => remove_storage_listener(handle_change));
+    port.onDisconnect.addListener(
+	() => storage.remove_change_listener(_handle_change)
+    );
 }
 
 async function start_page_info_server()
-- 
cgit v1.2.3