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

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

Browse source
This commit is contained in:
coderkun 2024-05-27 18:29:01 +02:00
commit ded9cf026b
11 changed files with 326 additions and 685 deletions
Download patch file Download diff file Expand all files Collapse all files

39
src/zeroconf.py
View file

@ -27,16 +27,8 @@ 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,
@ -52,22 +44,11 @@ class ZeroconfProvider(client.Base):
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):
@ -76,16 +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,
flags=0,
interface=-1,
protocol=Avahi.Protocol.GA_PROTOCOL_UNSPEC,
type=ZeroconfProvider.TYPE
)
type=ZeroconfProvider.TYPE)
self._service_browser.connect('new_service', self.on_new_service)
self._service_browser.attach(self._client)
except Exception as e: