git.meshlink.io Git - catta/blob - avahi-daemon/dbus-test.py

   1 #!/usr/bin/python2.4
   2
   3 import dbus
   4 import gobject
   5 try: import dbus.glib
   6 except ImportError, e: pass
   7
   8 bus = dbus.SystemBus()
   9
  10 server = dbus.Interface(bus.get_object("org.freedesktop.Avahi", '/org/freedesktop/Avahi/Server'), 'org.freedesktop.Avahi.Server')
  11
  12 def server_state_changed_callback(t):
  13     print "Server::StateChanged: ", t
  14
  15 server.connect_to_signal("StateChanged", server_state_changed_callback)
  16
  17 print "Version String: ", server.GetVersionString()
  18
  19 print server.ResolveHostName(0, 0, "ecstasy.local", 0)
  20 print server.ResolveAddress(0, 0, "192.168.50.4")
  21
  22 print "Host name: %s" % server.GetHostName()
  23 print "Domain name: %s" % server.GetDomainName()
  24 print "FQDN: %s" % server.GetHostNameFqdn()
  25 print "State: %i" % server.GetState()
  26
  27 print server.GetAlternativeHostName("gurkiman10")
  28 print server.GetAlternativeServiceName("Ahuga Service")
  29
  30 def entry_group_state_changed_callback(t):
  31     print "EntryGroup::StateChanged: ", t
  32
  33     if t == 1:
  34         print server.ResolveHostName(0, 0, "foo.local", 0)
  35
  36 g = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.EntryGroupNew()), 'org.freedesktop.Avahi.EntryGroup')
  37 g.connect_to_signal('StateChanged', entry_group_state_changed_callback)
  38 g.AddService(0, 0, "Test Web Site", "_http._tcp", "", "", dbus.UInt16(4712), ["fuck=hallo", "gurke=mega"])
  39 g.AddAddress(0, 0, "foo.local", "47.11.8.15")
  40 g.Commit()
  41
  42 def domain_browser_callback(a, interface, protocol, domain):
  43     print "DOMAIN_BROWSER: %s %i %i %s" % (a, interface, protocol, domain)
  44
  45 db = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.DomainBrowserNew(0, 0, "", 2)), 'org.freedesktop.Avahi.DomainBrowser')
  46 db.connect_to_signal('ItemNew', lambda interface, protocol, domain: domain_browser_callback("NEW", interface, protocol, domain))
  47 db.connect_to_signal('ItemRemove', lambda interface, protocol, domain: domain_browser_callback("REMOVE", interface, protocol, domain))
  48
  49 def service_type_browser_callback(a, interface, protocol, type, domain):
  50     print "SERVICE_TYPE_BROWSER: %s %i %i %s %s" % (a, interface, protocol, type, domain)
  51
  52 stb = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.ServiceTypeBrowserNew(0, 0, "")), 'org.freedesktop.Avahi.ServiceTypeBrowser')
  53 stb.connect_to_signal('ItemNew', lambda interface, protocol, type, domain: service_type_browser_callback("NEW", interface, protocol, type, domain))
  54 stb.connect_to_signal('ItemRemove', lambda interface, protocol, type, domain: service_type_browser_callback("REMOVE", interface, protocol, type, domain))
  55
  56 def service_browser_callback(a, interface, protocol, name, type, domain):
  57     print "SERVICE_BROWSER: %s %i %i %s %s %s" % (a, interface, protocol, name, type, domain)
  58
  59     if a == "NEW":
  60         print server.ResolveService(interface, protocol, name, type, domain, 0)
  61
  62 sb = dbus.Interface(bus.get_object("org.freedesktop.Avahi", server.ServiceBrowserNew(0, 0, "_http._tcp", "")), 'org.freedesktop.Avahi.ServiceBrowser')
  63 sb.connect_to_signal('ItemNew', lambda interface, protocol, name, type, domain: service_browser_callback("NEW", interface, protocol, name, type, domain))
  64 sb.connect_to_signal('ItemRemove', lambda interface, protocol, name, type, domain: service_browser_callback("REMOVE", interface, protocol, name, type, domain))
  65
  66 try:
  67     gobject.MainLoop().run()
  68 except KeyboardInterrupt, k:
  69     pass
  70
  71 g.Free()
  72 db.Free()
  73 stb.Free()
  74
  75 print "Quit"