upstream/knot-dns
1
0
Fork 0
mirror of https://gitlab.nic.cz/knot/knot-dns.git synced 2026-02-03 18:49:28 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

samples: fix working before start and upon knotd restart and extend dbus_client.py

Browse source
This commit is contained in:
Daniel Salzman 2023-02-07 12:59:24 +01:00
parent a9d42fdafa
commit 2edaec923e
1 changed files with 32 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
samples/dbus_client.py
View file

@ -3,6 +3,7 @@
import dbus
import dbus.mainloop.glib
import signal
import time
from gi.repository import GLib
def sigint_handler(sig, frame):
@ -11,17 +12,44 @@ def sigint_handler(sig, frame):
else:
raise ValueError("Undefined handler for '{}'".format(sig))
def updated(*args, **kwargs):
def sig_started(*args, **kwargs):
print("Server started")
def sig_stopped(*args, **kwargs):
print("Server stopped")
def sig_updated(*args, **kwargs):
(zone, serial) = args
print("Zone %s updated, SOA serial %d" % (zone, serial))
print("Updated zone=%s to serial=%d" % (zone, serial))
def sig_submission(*args, **kwargs):
(zone, key_tag, kasp_id) = args
print("Ready KSK for zone=%s keytag=%u keyid=%s" % (zone, key_tag, kasp_id))
def sig_invalid(*args, **kwargs):
(zone) = args
print("Invalid DNSSEC fo zone=%s" % (zone))
if __name__ == '__main__':
signal.signal(signal.SIGINT, sigint_handler)
loop = dbus.mainloop.glib.DBusGMainLoop(set_as_default=True)
bus = dbus.SystemBus()
knotd = bus.get_object('cz.nic.knotd', '/cz/nic/knotd', introspect=False)
while True: # Wait until the service (knotd) is ready.
try:
knotd = bus.get_object('cz.nic.knotd', '/cz/nic/knotd',
follow_name_owner_changes=True,
introspect=False)
break
except:
time.sleep(0.1)
events_iface = dbus.Interface(knotd, dbus_interface='cz.nic.knotd.events')
events_iface.connect_to_signal("zone_updated", updated)
events_iface.connect_to_signal("started", sig_started)
events_iface.connect_to_signal("stopped", sig_stopped)
events_iface.connect_to_signal("zone_updated", sig_updated)
events_iface.connect_to_signal("zone_ksk_submission", sig_submission)
events_iface.connect_to_signal("zone_dnssec_invalid", sig_invalid)
loop = GLib.MainLoop()
loop.run()