olli/mcg
Watch
1
0
Fork
You've already forked mcg
 0
Code Pull requests Activity

Adjust line length to match Code Style Guide (see #103)

Browse source
This commit is contained in:
coderkun 2024-05-27 12:46:46 +02:00
commit a1f8b73590
11 changed files with 436 additions and 258 deletions
Download patch file Download diff file Expand all files Collapse all files

29
src/zeroconf.py
View file

@ -27,18 +27,28 @@ class ZeroconfProvider(client.Base):
if use_avahi:
self._start_client()
def on_new_service(self, browser, interface, protocol, name, type, domain, flags):
def on_new_service(self, browser, interface, protocol, name, type, domain,
flags):
#if not (flags & Avahi.LookupResultFlags.GA_LOOKUP_RESULT_LOCAL):
service_resolver = Avahi.ServiceResolver(interface=interface, protocol=protocol, name=name, type=type, domain=domain, aprotocol=Avahi.Protocol.GA_PROTOCOL_UNSPEC, flags=0,)
service_resolver = Avahi.ServiceResolver(
interface=interface,
protocol=protocol,
name=name,
type=type,
domain=domain,
aprotocol=Avahi.Protocol.GA_PROTOCOL_UNSPEC,
flags=0,
)
service_resolver.connect('found', self.on_found)
service_resolver.connect('failure', self.on_failure)
service_resolver.attach(self._client)
self._service_resolvers.append(service_resolver)
def on_found(self, resolver, interface, protocol, name, type, domain, host, date, port, *args):
def on_found(self, resolver, interface, protocol, name, type, domain, host,
date, port, *args):
if (host, port) not in self._services.keys():
service = (name,host,port)
self._services[(host,port)] = service
service = (name, host, port)
self._services[(host, port)] = service
self._callback(ZeroconfProvider.SIGNAL_SERVICE_NEW, service)
def on_failure(self, resolver, date):
@ -47,11 +57,16 @@ class ZeroconfProvider(client.Base):
def _start_client(self):
self._logger.info("Starting Avahi client")
self._client = Avahi.Client(flags=0,)
self._client = Avahi.Client(flags=0, )
try:
self._client.start()
# Browser
self._service_browser = Avahi.ServiceBrowser(domain='local', flags=0, interface=-1, protocol=Avahi.Protocol.GA_PROTOCOL_UNSPEC, type=ZeroconfProvider.TYPE)
self._service_browser = Avahi.ServiceBrowser(
domain='local',
flags=0,
interface=-1,
protocol=Avahi.Protocol.GA_PROTOCOL_UNSPEC,
type=ZeroconfProvider.TYPE)
self._service_browser.connect('new_service', self.on_new_service)
self._service_browser.attach(self._client)
except Exception as e: