Mirrors/discord-rich-presence-plex
2
0
Fork 0
mirror of https://github.com/phin05/discord-rich-presence-plex synced 2024-11-25 02:50:17 +00:00
Code Issues Projects Releases Packages Wiki Activity

Added a slight delay before disconnecting from Discord IPC pipe

Browse source
This commit is contained in:
Phin 2024-08-31 16:44:53 +05:30
parent 9bcbe949ca
commit d4b2e3f32a
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
core/plex.py
View file

@ -54,6 +54,7 @@ class PlexAlertListener(threading.Thread):
productName = "Plex Media Server" productName = "Plex Media Server"
updateTimeoutTimerInterval = 30 updateTimeoutTimerInterval = 30
connectionCheckTimerInterval = 60 connectionCheckTimerInterval = 60
disconnectTimerInterval = 3
maximumIgnores = 2 maximumIgnores = 2
def __init__(self, token: str, serverConfig: models.config.Server): def __init__(self, token: str, serverConfig: models.config.Server):
@ -65,6 +66,7 @@ class PlexAlertListener(threading.Thread):
self.discordIpcService = DiscordIpcService(self.serverConfig.get("ipcPipeNumber")) self.discordIpcService = DiscordIpcService(self.serverConfig.get("ipcPipeNumber"))
self.updateTimeoutTimer: Optional[threading.Timer] = None self.updateTimeoutTimer: Optional[threading.Timer] = None
self.connectionCheckTimer: Optional[threading.Timer] = None self.connectionCheckTimer: Optional[threading.Timer] = None
self.disconnectTimer: Optional[threading.Timer] = None
self.account: Optional[MyPlexAccount] = None self.account: Optional[MyPlexAccount] = None
self.server: Optional[PlexServer] = None self.server: Optional[PlexServer] = None
self.alertListener: Optional[AlertListener] = None self.alertListener: Optional[AlertListener] = None
@ -200,7 +202,10 @@ class PlexAlertListener(threading.Thread):
else: else:
self.ignoreCount = 0 self.ignoreCount = 0
if isIgnorableState: if isIgnorableState:
self.disconnectRpc() if self.disconnectTimer:
self.disconnectTimer.cancel()
self.disconnectTimer = threading.Timer(self.disconnectTimerInterval, self.disconnectRpc)
self.disconnectTimer.start()
return return
elif isIgnorableState: elif isIgnorableState:
self.logger.debug("Received '%s' state alert from unknown session, ignoring", state) self.logger.debug("Received '%s' state alert from unknown session, ignoring", state)
@ -228,6 +233,9 @@ class PlexAlertListener(threading.Thread):
self.updateTimeoutTimer.cancel() self.updateTimeoutTimer.cancel()
self.updateTimeoutTimer = threading.Timer(self.updateTimeoutTimerInterval, self.updateTimeout) self.updateTimeoutTimer = threading.Timer(self.updateTimeoutTimerInterval, self.updateTimeout)
self.updateTimeoutTimer.start() self.updateTimeoutTimer.start()
if self.disconnectTimer:
self.disconnectTimer.cancel()
self.disconnectTimer = None
self.lastState, self.lastSessionKey, self.lastRatingKey = state, sessionKey, ratingKey self.lastState, self.lastSessionKey, self.lastRatingKey = state, sessionKey, ratingKey
stateStrings: list[str] = [] stateStrings: list[str] = []
if config["display"]["duration"] and item.duration and mediaType != "track": if config["display"]["duration"] and item.duration and mediaType != "track":