unbound-dhcp-leases-bridge: Store all messages in a queue

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>

diff --git a/config/unbound/unbound-dhcp-leases-bridge b/config/unbound/unbound-dhcp-leases-bridge
index aff82ec99d7fa57677c1e82a94979dce38277354..1f46ea3f96ed9c5a427cd2a9c6a8a37850818c65 100644 (file)
--- a/config/unbound/unbound-dhcp-leases-bridge
+++ b/config/unbound/unbound-dhcp-leases-bridge
@@ -28,6 +28,7 @@ import ipaddress
 import logging
 import logging.handlers
 import os
+import queue
 import re
 import signal
 import socket
@@ -87,6 +88,9 @@ class UnboundDHCPLeasesBridge(object):
 
                self.socket = None
 
+               # Create a queue for all received events
+               self.queue = queue.Queue()
+
                self.unbound = UnboundConfigWriter(unbound_leases_file)
 
                # Load all required data
@@ -120,7 +124,8 @@ class UnboundDHCPLeasesBridge(object):
                                for key in message:
                                        log.debug("  %-20s = %s" % (key, message[key]))
 
-                               # TODO
+                               # Add the message to the queue
+                               self.queue.put(message)
 
                                conn.send(b"OK\n")