Mirror/iSponsorBlockTV
1
0
Fork 0
mirror of https://github.com/dmunozv04/iSponsorBlockTV.git synced 2025-12-09 05:16:47 +03:00
Code Issues Packages Projects Releases Wiki Activity

New reconnect logic

Browse Source
This commit is contained in:
dmunozv04
2022-03-16 19:57:08 +01:00
parent 12328a6cdc
commit 446811f33c
1 changed files with 22 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
main.py
View File

@@ -40,7 +40,7 @@ class MyPushListener(pyatv.interface.PushListener):
def playstatus_error(self, updater, exception): def playstatus_error(self, updater, exception):
print(exception) print(exception)
print("stopped") print("stopped")
# Error in exception
async def process_playstatus(playstatus, apikey, rc, web_session, categories, atv): async def process_playstatus(playstatus, apikey, rc, web_session, categories, atv):
@@ -103,7 +103,7 @@ async def connect_atv(loop, identifier, airplay_credentials):
atvs = await pyatv.scan(loop, identifier = identifier) atvs = await pyatv.scan(loop, identifier = identifier)
if not atvs: if not atvs:
print("No device found") print("No device found, will retry")
return return
config = atvs[0] config = atvs[0]
@@ -117,21 +117,30 @@ async def loop_atv(event_loop, atv_config, apikey, categories):
identifier = atv_config["identifier"] identifier = atv_config["identifier"]
airplay_credentials = atv_config["airplay_credentials"] airplay_credentials = atv_config["airplay_credentials"]
atv = await connect_atv(event_loop, identifier, airplay_credentials) atv = await connect_atv(event_loop, identifier, airplay_credentials)
if atv:
listener = MyPushListener(apikey, atv, categories)
listener = MyPushListener(apikey, atv, categories)
try:
atv.push_updater.listener = listener atv.push_updater.listener = listener
atv.push_updater.start() atv.push_updater.start()
print("Push updater started") print("Push updater started")
while True: while True:
await asyncio.sleep(1000) await asyncio.sleep(20)
#await event_loop.run_in_executor(None, sys.stdin.readline) try:
except: atv.metadata.app
atv.close() except:
print("Finished connection with ATV") print("Reconnecting to Apple TV")
asyncio.sleep(5) #reconnect to apple tv
loop_atv(event_loop, atv_config, apikey, categories) atv = await connect_atv(event_loop, identifier, airplay_credentials)
if atv:
listener = MyPushListener(apikey, atv, categories)
atv.push_updater.listener = listener
atv.push_updater.start()
print("Push updater started")
def load_config(config_file="config.json"): def load_config(config_file="config.json"):
with open(config_file) as f: with open(config_file) as f: