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 befd2e06e7
10 changed files with 683 additions and 148 deletions
Download patch file Download diff file Expand all files Collapse all files

42
src/zeroconf.py
View file

@ -28,15 +28,44 @@ 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
@ -52,7 +81,12 @@ class ZeroconfProvider(client.Base):
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: