git.meshlink.io Git - catta/blob - avahi-utils/avahi-dump-all

   1 #!/usr/bin/python2.4
   2 # -*-python-*-
   3 # $Id$
   4
   5 import avahi, dbus, gobject
   6
   7 try:
   8     import dbus.glib
   9 except ImportError, e:
  10     pass
  11
  12 service_type_browsers = {}
  13 service_browsers = {}
  14
  15 def service_resolved(interface, protocol, name, type, domain, host, aprotocol, address, port, txt):
  16     print "Service data for service '%s' of type '%s' in domain '%s' on %i.%i:" % (name, type, domain, interface, protocol)
  17     print "\tHost %s (%s), port %i, TXT data: %s" % (host, address, port, str(txt))
  18
  19 def print_error(err):
  20     print "Error:", str(err)
  21
  22 def new_service(interface, protocol, name, type, domain):
  23     print "Found service '%s' of type '%s' in domain '%s' on %i.%i." % (name, type, domain, interface, protocol)
  24
  25     # Asynchronous resolving
  26     server.ResolveService(interface, protocol, name, type, domain, avahi.PROTO_UNSPEC, reply_handler=service_resolved, error_handler=print_error)
  27
  28 def remove_service(interface, protocol, name, type, domain):
  29     print "Service '%s' of type '%s' in domain '%s' on %i.%i disappeared." % (name, type, domain, interface, protocol)
  30
  31 def new_service_type(interface, protocol, type, domain):
  32
  33     # Are we already browsing this domain for this type?
  34     if service_browsers.has_key((interface, protocol, type, domain)):
  35         return
  36
  37     print "Browsing for services of type '%s' in domain '%s' on %i.%i ..." % (type, domain, interface, protocol)
  38
  39     b = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.ServiceBrowserNew(interface, protocol, type, domain)), 'org.freedesktop.Avahi.ServiceBrowser')
  40     b.connect_to_signal('ItemNew', new_service)
  41     b.connect_to_signal('ItemRemove', remove_service)
  42
  43     service_browsers[(interface, protocol, type, domain)] = b
  44
  45 def browse_domain(interface, protocol, domain):
  46
  47     # Are we already browsing this domain?
  48     if service_type_browsers.has_key((interface, protocol, domain)):
  49         return
  50
  51     print "Browsing domain '%s' on %i.%i ..." % (domain, interface, protocol)
  52
  53     b = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.ServiceTypeBrowserNew(interface, protocol, domain)), 'org.freedesktop.Avahi.ServiceTypeBrowser')
  54     b.connect_to_signal('ItemNew', new_service_type)
  55
  56     service_type_browsers[(interface, protocol, domain)] = b
  57
  58 def new_domain(interface, protocol, domain):
  59
  60     # We browse for .local anyway...
  61     if domain != "local":
  62         browse_domain(interface, protocol, domain)
  63
  64 bus = dbus.SystemBus()
  65 server = dbus.Interface(bus.get_object("org.freedesktop.Avahi", '/org/freedesktop/Avahi/Server'), 'org.freedesktop.Avahi.Server')
  66
  67 # Explicitly browse .local
  68 browse_domain(avahi.IF_UNSPEC, avahi.PROTO_UNSPEC, "local")
  69
  70 # Browse for other browsable domains
  71 db = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.DomainBrowserNew(avahi.IF_UNSPEC, avahi.PROTO_UNSPEC, "", avahi.DOMAIN_BROWSER_BROWSE)), 'org.freedesktop.Avahi.DomainBrowser')
  72 db.connect_to_signal('ItemNew', new_domain)
  73
  74 try:
  75     gobject.MainLoop().run()
  76 except KeyboardInterrupt, k:
  77     pass