g^ddlZddlZddlmZddlZddlmZGddejZy)N)Callable)logcNeZdZdZdZd dededeffd ZdZdZ d Z d Z xZ S) AlertListenera Creates a websocket connection to the PlexServer to optionally receive alert notifications. These often include messages from Plex about media scans as well as updates to currently running Transcode Sessions. This class implements threading.Thread, therefore to start monitoring alerts you must call .start() on the object once it's created. When calling `PlexServer.startAlertListener()`, the thread will be started for you. Known `state`-values for timeline entries, with identifier=`com.plexapp.plugins.library`: :0: The item was created :1: Reporting progress on item processing :2: Matching the item :3: Downloading the metadata :4: Processing downloaded metadata :5: The item processed :9: The item deleted When metadata agent is not set for the library processing ends with state=1. Parameters: server (:class:`~plexapi.server.PlexServer`): PlexServer this listener is connected to. callback (func): Callback function to call on received messages. The callback function will be sent a single argument 'data' which will contain a dictionary of data received from the server. :samp:`def my_callback(data): ...` callbackError (func): Callback function to call on errors. The callback function will be sent a single argument 'error' which will contain the Error object. :samp:`def my_callback(error): ...` ws_socket (socket): Socket to use for the connection. If not specified, a new socket will be created. z/:/websockets/notificationscallback callbackError ws_socketc~tt| d|_||_||_||_||_d|_y)NT) superr__init__daemon_server _callback_callbackError_socket_ws)selfserverrrr __class__s "/opt/Tautulli/lib/plexapi/alert.pyr zAlertListener.__init__)s; mT+-  !+  c ddl}|jj |j djdd}tjd||j||j|j|j|_ |jjy#t$rtjdYywxYw) Nrz-Can't use the AlertListener without websocketT) includeTokenhttpwszStarting AlertListener: %s) on_messageon_errorsocket) websocket ImportErrorrwarningrurlkeyreplaceinfo WebSocketApp _onMessage_onErrorrr run_forever)rrr"s rrunzAlertListener.run2s   lltxxd;CCFDQ -s3))#$//TXTaTajnjvjv)w   KKG H  sB&&CCcbtjd|jjy)z Stop the AlertListener thread. Once the notifier is stopped, it cannot be directly started again. You must call :func:`~plexapi.server.PlexServer.startAlertListener` from a PlexServer instance. zStopping AlertListener.N)rr%rclose)rs rstopzAlertListener.stop@s *+ rc|d} tj|d}tjdg||jr|j |yy#t $r }tj d|Yd}~yd}~wwxYw)z Called when websocket message is received. We are assuming the last argument in the tuple is the message. NotificationContainerzAlert: %s %s %szAlertListener Msg Error: %sN)jsonloadsrdebugr Exceptionerror)rargsmessagedataerrs rr'zAlertListener._onMessageHsr r( :::g&'>?D II' /$ /~~t$ : II3S 9 9 :sA A A=A88A=c|d} tjd||jr|j|yy#t$r }tjd|Yd}~yd}~wwxYw)z~ Called when websocket error is received. We are assuming the last argument in the tuple is the message. r/zAlertListener Error: %szAlertListener Error: Error: %sN)rr5rr4)rr6r9s rr(zAlertListener._onErrorVs_ 2h = II/ 5""##C(# = II6 < < =s3< A%A  A%)NNN) __name__ __module__ __qualname____doc__r#rrr r*r-r'r( __classcell__)rs@rrr s>8 (Cek  : =rr) r1rtypingr threadingplexapirThreadrrrrEs( W=I$$W=r