diff options
author | Sebastien Estienne <sebastien.estienne@gmail.com> | 2005-10-09 16:21:52 +0000 |
---|---|---|
committer | Sebastien Estienne <sebastien.estienne@gmail.com> | 2005-10-09 16:21:52 +0000 |
commit | 14493d4e41890251fbb24ebbdd1c36e8f2fc6a4b (patch) | |
tree | 0299ff09d8585d660611dac5d4d8b828006e3993 /avahi-utils/avahi/SimpleAvahiApp.py.in | |
parent | 4cb11c30b9794d20ca7613ca7ea3d919a0a87f09 (diff) |
* some progress on the browsing part
git-svn-id: file:///home/lennart/svn/public/avahi/branches/py-simple-api@707 941a03a8-eaeb-0310-b9a0-b1bbd8fe43fe
Diffstat (limited to 'avahi-utils/avahi/SimpleAvahiApp.py.in')
-rwxr-xr-x | avahi-utils/avahi/SimpleAvahiApp.py.in | 112 |
1 files changed, 112 insertions, 0 deletions
diff --git a/avahi-utils/avahi/SimpleAvahiApp.py.in b/avahi-utils/avahi/SimpleAvahiApp.py.in new file mode 100755 index 0000000..07bd9bb --- /dev/null +++ b/avahi-utils/avahi/SimpleAvahiApp.py.in @@ -0,0 +1,112 @@ +#!@PYTHON@ +# -*-python-*- +# $Id$ + +# This file is part of avahi. +# +# avahi is free software; you can redistribute it and/or modify it +# under the terms of the GNU Lesser General Public License as +# published by the Free Software Foundation; either version 2 of the +# License, or (at your option) any later version. +# +# avahi is distributed in the hope that it will be useful, but WITHOUT +# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY +# or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public +# License for more details. +# +# You should have received a copy of the GNU Lesser General Public +# License along with avahi; if not, write to the Free Software +# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 +# USA. + +import sys, getopt +import avahi, gobject, dbus + +try: + import dbus.glib +except ImportError, e: + pass + +class SimpleAvahiApp: + def __init__(self): + self.domain = None + self.service_type_browsers = {} + self.service_browsers = {} + self.bus = dbus.SystemBus() + self.server = dbus.Interface(self.bus.get_object(avahi.DBUS_NAME, avahi.DBUS_PATH_SERVER), avahi.DBUS_INTERFACE_SERVER) + + def siocgifname(self, interface): + if interface <= 0: + return "any" + else: + return self.server.GetNetworkInterfaceNameByIndex(interface) + + def BrowseDomain(self, domain, new_cb = None, remove_cb = None, interface=avahi.IF_UNSPEC, protocol=avahi.PROTO_UNSPEC): + db = dbus.Interface(self.bus.get_object(avahi.DBUS_NAME, self.server.DomainBrowserNew(avahi.IF_UNSPEC, avahi.PROTO_UNSPEC, domain, avahi.DOMAIN_BROWSER_BROWSE)), avahi.DBUS_INTERFACE_DOMAIN_BROWSER) + if new_cb != None: + db.connect_to_signal('ItemNew', cb_new_domain) + if remove_cb != None: + db.connect_to_signal('ItemRemove', cb_remove_domain) + + def BrowseService(self, stype, new_cb = None, remove_cb = None, domain="local", interface=avahi.IF_UNSPEC, protocol=avahi.PROTO_UNSPEC): + # Are we already browsing this domain for this type? + if self.service_browsers.has_key((interface, protocol, stype, domain)): + return + + b = dbus.Interface(self.bus.get_object(avahi.DBUS_NAME, self.server.ServiceBrowserNew(interface, protocol, stype, domain)), avahi.DBUS_INTERFACE_SERVICE_BROWSER) + self.service_browsers[(interface, protocol, stype, domain)] = b + if new_cb != None: + b.connect_to_signal('ItemNew', new_cb) + if remove_cb != None: + b.connect_to_signal('ItemRemove', remove_cb) + + def ResolveService(self, name, stype, resolved_cb, error_cb = None, domain="local", interface=avahi.IF_UNSPEC, protocol=avahi.PROTO_UNSPEC): + self.server.ResolveService(interface, protocol, name, stype, domain, avahi.PROTO_UNSPEC, reply_handler=resolved_cb, error_handler=error_cb) + + def BrowseServiceType(self, new_cb = None, remove_cb = None, domain="local", interface=avahi.IF_UNSPEC, protocol=avahi.PROTO_UNSPEC): + if self.service_type_browsers.has_key((interface, protocol, domain)): + return + + b = dbus.Interface(self.bus.get_object(avahi.DBUS_NAME, self.server.ServiceTypeBrowserNew(interface, protocol, domain)), avahi.DBUS_INTERFACE_SERVICE_TYPE_BROWSER) + b.connect_to_signal('ItemNew', self.new_service_type) + if new_cb != None: + b.connect_to_signal('ItemNew', new_cb) + if remove_cb != None: + b.connect_to_signal('ItemRemove', remove_cb) + + self.service_type_browsers[(interface, protocol, domain)] = b + + +if __name__ == "__main__": + print "__main__" + + class AvahiBrowse: + def new_domain(self, interface, protocol, domain): + print "%i %i %s" % (interface, protocol, domain) + + def service_resolved(self, interface, protocol, name, stype, domain, host, aprotocol, address, port, txt): + print "Service data for service '%s' of type '%s' (%s) in domain '%s' on %i.%i:" % (name, stype, stype, domain, interface, protocol) + print "\tHost %s (%s), port %i, TXT data: %s" % (host, address, port, avahi.txt_array_to_string_array(txt)) + + def print_error(self, err): + print "Error:", str(err) + + def new_service(self, interface, protocol, name, stype, domain): + print "Found service '%s' of type '%s' (%s) in domain '%s' on %i.%i." % (name, stype, stype, domain, interface, protocol) + self.sb.ResolveService(name, stype, self.service_resolved, self.print_error) + + def remove_service(self, interface, protocol, name, stype, domain): + print "Service '%s' of type '%s' (%s) in domain '%s' on %i.%i disappeared." % (name, stype, stype, domain, interface, protocol) + + def __init__(self): + self.sb = SimpleAvahiApp() +# self.sb.BrowseService("_ssh._tcp", self.new_service) + self.sb.BrowseService("_workstation._tcp", self.new_service, self.remove_service) + + ab = AvahiBrowse() + + try: + gobject.MainLoop().run() + except KeyboardInterrupt, k: + pass + |