X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=avahi-daemon%2Fdbus-test.py;h=a5adc0f7af8d8a23a07af71cb641c6aa015aea3e;hb=1d6cecfe69fa2faea1c81ccd899bac24aad64273;hp=bdfae0cca4f9dd52772949027781cf7420182442;hpb=978cbe80eb8437fd013dc6cff0088590884e7148;p=catta diff --git a/avahi-daemon/dbus-test.py b/avahi-daemon/dbus-test.py index bdfae0c..a5adc0f 100755 --- a/avahi-daemon/dbus-test.py +++ b/avahi-daemon/dbus-test.py @@ -1,28 +1,34 @@ #!/usr/bin/python2.4 -import dbus -import dbus.glib -import gtk - -from time import sleep +import dbus, gobject +try: + import dbus.glib +except ImportError, e: + pass bus = dbus.SystemBus() - -server = dbus.Interface(bus.get_object("org.freedesktop.Avahi", '/org/freedesktop/Avahi/Server'), 'org.freedesktop.Avahi.Server') +server = dbus.Interface(bus.get_object("org.freedesktop.Avahi", '/'), 'org.freedesktop.Avahi.Server') def server_state_changed_callback(t): print "Server::StateChanged: ", t server.connect_to_signal("StateChanged", server_state_changed_callback) +print "Version String: ", server.GetVersionString() + print server.ResolveHostName(0, 0, "ecstasy.local", 0) print server.ResolveAddress(0, 0, "192.168.50.4") print "Host name: %s" % server.GetHostName() print "Domain name: %s" % server.GetDomainName() print "FQDN: %s" % server.GetHostNameFqdn() +print "State: %i" % server.GetState() -g = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.EntryGroupNew()), 'org.freedesktop.Avahi.EntryGroup') +n = server.GetNetworkInterfaceNameByIndex(2) +print "network: 2 -> %s -> %i" % (n, server.GetNetworkInterfaceIndexByName(n)) + +print server.GetAlternativeHostName("gurkiman10") +print server.GetAlternativeServiceName("Ahuga Service") def entry_group_state_changed_callback(t): print "EntryGroup::StateChanged: ", t @@ -30,18 +36,43 @@ def entry_group_state_changed_callback(t): if t == 1: print server.ResolveHostName(0, 0, "foo.local", 0) - +g = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.EntryGroupNew()), 'org.freedesktop.Avahi.EntryGroup') g.connect_to_signal('StateChanged', entry_group_state_changed_callback) - -g.AddService(0, 0, "_http._tcp", "foo", "", "", dbus.UInt16(4712), ["fuck=hallo", "gurke=mega"]) +g.AddService(0, 0, "Test Web Site", "_http._tcp", "", "", dbus.UInt16(4712), ["fuck=hallo", "gurke=mega"]) g.AddAddress(0, 0, "foo.local", "47.11.8.15") g.Commit() +def domain_browser_callback(a, interface, protocol, domain): + print "DOMAIN_BROWSER: %s %i %i %s" % (a, interface, protocol, domain) + +db = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.DomainBrowserNew(0, 0, "", 2)), 'org.freedesktop.Avahi.DomainBrowser') +db.connect_to_signal('ItemNew', lambda interface, protocol, domain: domain_browser_callback("NEW", interface, protocol, domain)) +db.connect_to_signal('ItemRemove', lambda interface, protocol, domain: domain_browser_callback("REMOVE", interface, protocol, domain)) + +def service_type_browser_callback(a, interface, protocol, type, domain): + print "SERVICE_TYPE_BROWSER: %s %i %i %s %s" % (a, interface, protocol, type, domain) + +stb = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.ServiceTypeBrowserNew(0, 0, "")), 'org.freedesktop.Avahi.ServiceTypeBrowser') +stb.connect_to_signal('ItemNew', lambda interface, protocol, type, domain: service_type_browser_callback("NEW", interface, protocol, type, domain)) +stb.connect_to_signal('ItemRemove', lambda interface, protocol, type, domain: service_type_browser_callback("REMOVE", interface, protocol, type, domain)) + +def service_browser_callback(a, interface, protocol, name, type, domain): + print "SERVICE_BROWSER: %s %i %i %s %s %s" % (a, interface, protocol, name, type, domain) + + if a == "NEW": + print server.ResolveService(interface, protocol, name, type, domain, 0) + +sb = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.ServiceBrowserNew(0, 0, "_http._tcp", "")), 'org.freedesktop.Avahi.ServiceBrowser') +sb.connect_to_signal('ItemNew', lambda interface, protocol, name, type, domain: service_browser_callback("NEW", interface, protocol, name, type, domain)) +sb.connect_to_signal('ItemRemove', lambda interface, protocol, name, type, domain: service_browser_callback("REMOVE", interface, protocol, name, type, domain)) + try: - gtk.main() + gobject.MainLoop().run() except KeyboardInterrupt, k: pass g.Free() +db.Free() +stb.Free() print "Quit"