g'4ddlZddlZddlZddlZddlZddlZddlZddlmZddlmZddlm Z ddlm Z ddlm Z dZ ejjejjfZdadadad Zd Zd Zd Zd ZdZdZdZdZdZdZdZdZ dZ!y)N)activity_handler)activity_pinger)activity_processor)database)logger websocketFcB tjdtjt}d|_ |jy#t$rK}tjd|ztj dt jYd}~d}~wwxYw)NT) ws_requestz>Tautulli WebSocket :: Failed to check for active sessions: %s.zFTautulli WebSocket :: Attempt to fix by flushing temporary sessions...)target) rcheck_active_sessions Exceptionrerrorwarnrdelete_sessions threadingThreadrundaemonstart)ethreads "/opt/Tautulli/plexpy/web_socket.py start_threadr+sx#-->  S )FFM LLN # UXYYZ \]  ""#sA BABBctj dt_tjsvtjddt_tj j dr-tjdt jddn ttjtjjr tyy)NTz7Tautulli WebSocket :: The Plex Media Server is back up. on_intdownzETautulli WebSocket :: Cancelling scheduled Plex server down callback.) remove_job)plexpyPLEX_SERVER_UPrinforACTIVITY_SCHEDget_jobdebugschedule_callbackon_intupinitialize_schedulerCONFIGWEBSOCKET_MONITOR_PING_PONG send_pingr on_connectr+:s $ $   MN $  * * 2 2< @ LL` a  . .| M J ! }}00 1r*ctj dt_tjrtjddt_tjdtj j tjdttj j tjjtjy)NFzTTautulli WebSocket :: Unable to get a response from the server, Plex server is down.zITautulli WebSocket :: Scheduling Plex server down callback in %d seconds.r)funcseconds)rrrrr"r&"NOTIFY_SERVER_CONNECTION_THRESHOLDrr#rrActivityProcessorset_temp_stoppedr%r)r*r on_disconnectr2Ms $ %  jk % `]]EE G**ls K Gr*ctjdtjj dt_y)Nz0Tautulli WebSocket :: Disconnecting websocket...F)rrr WEBSOCKETr: WS_CONNECTEDr)r*rr:r:rs) KKBC Fr*ctjrYtjjdt j dt adt_tjyy)NzHi?g@T) rrAr@pingrTimer wait_pong pong_timerrrr)r*rr(r(xsJ e$__S)4  r*ctdz atjdttzttj j k\r datyy)NzMTautulli WebSocket :: Failed to receive pong from websocket, ping attempt %s.r) pong_countrrstrrr&WEBSOCKET_CONNECTION_ATTEMPTSr:r)r*rrErEsF!OJ KK_befpbqqrV]]@@@  Ar*c>trtjadayy)Nr)rFcancelrIr)r*r receive_pongrNs&&(  r*cddlm}tjjrtjj dddk(rstjj j dddz}d}tjjrd tji}nPd tji}n=d tjjd tjjd}d }d}tjjrdtjji}nd}tjj}dad}t#j$d|z |||||t_t#j$ddt_tj(r t3tj(r3 t5t7tj&d}tj(r3tj(st s tKt#jLdy#tj*t,t.f$r }t#j0d|Yd}~d}~wwxYw#tj8$r:t rY|dk(rt#j:dtjj<s|tjj>kr|dz }|dkDr-tAjBtjjDt#j:dtG|z |||||t_t#j$ddt_nN#tj*t,t.f$r }t#j0d|Yd}~nd}~wwxYwtIYYtj*t.f$r7}t rYd}~t#j0d|tIYd}~d}~wwxYw)Nr)create_connectionhttpszhttps://zwss://z/:/websockets/notificationszsecure ca_certs cert_reqszws://:z X-Plex-TokenFz*Tautulli WebSocket :: Opening %swebsocket.)timeoutheaderssloptzTautulli WebSocket :: ReadyTzTautulli WebSocket :: %s.z,Tautulli WebSocket :: Connection has closed.rHz.Tautulli WebSocket :: Reconnection attempt %s.z%Tautulli WebSocket :: Leaving thread.)'rrPrr&PMS_SSLPMS_URLreplaceVERIFY_SSL_CERTcertifiwheressl CERT_NONEPMS_IPPMS_PORT PMS_TOKEN PMS_TIMEOUTr=rrr@rAWebSocketExceptionIOErrorr rr+processreceive"WebSocketConnectionClosedExceptionr PMS_IS_CLOUDrKtimesleepWEBSOCKET_CONNECTION_TIMEOUTrJr:r2r")rPurisecurerYrXrW reconnectsrs rrrs+ }}!6!6r!:g!Emm##++JADaa == ( ( '--/2F!3==1F MM MM " " }} &--"9"9:mm''GKJ KKJJv}}IIJ LsS]^_A'8gV\ek'lF$KK =>*.F'!44gyIALL!d}~wwxYw#t $r#}tjd|zYd}~d}~wwxYw#t $r"}tjd|zYd}~yd}~wwxYw)NFzutf-8z?Tautulli WebSocket :: Error decoding message from websocket: %sNotificationContainertypeplayingPlaySessionStateNotification _childrenzKTautulli WebSocket :: Session event found but unable to get websocket data.r)timelinez9Tautulli WebSocket :: Failed to process session data: %s.r TimelineEntryzLTautulli WebSocket :: Timeline event found but unable to get websocket data.z:Tautulli WebSocket :: Failed to process timeline data: %s. reachabilityReachabilityNotificationzPTautulli WebSocket :: Reachability event found but unable to get websocket data.)rvz>Tautulli WebSocket :: Failed to process reachability data: %s.T)rudecoderwebsocket_debugjsonloadsr rwebsocket_errorgetr"rActivityHandlerrh exceptionTimelineHandlerReachabilityHandler)rtrveventr event_type event_dataactivitys rrhrhs? [ {{7#t$ 4  II-u 5E6"J YYY=uyyVX?YZ  LLf g ^'77AOH    ZYY +r0JK  LLg h _'77AOH    ^#YY9599[RT;UV  LLk l c';;AOH     e  UXYYZt$* ^   X[\\ ] ] ^ _   Y\]] ^ ^ _ c   ]`aa b b  cs_;F),)G,)H>)I ) G)2-G$$G), H5HH I$II I5I00I5)"rr`rrlr^rrrrrrrnamerw OPCODE_TEXT OPCODE_BINARYrur=rFrIrr+r2rr$r;r>r:r(rErNrrirhr)r*rrs(   #"%~~))9>>+G+GH     &""=;   W:t&:r*