From: Michael Tremer <michael.tremer@ipfire.org>
Date: Fri, 10 May 2024 15:32:07 +0000 (+0100)
Subject: unbound-dhcp-leases-bridge: Store all messages in a queue
X-Git-Tag: v2.29-core188~10^2~86^2~16
X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=d9348a16f14181e351990617a6d79ad40bab35d8;p=ipfire-2.x.git

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 aff82ec99d..1f46ea3f96 100644
--- 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")