g6ddlmZddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z m Z dZdZdZdZd ZeZgaej,d Zej,d Zej,d ZdZd Zd$dZGddej:ZGddej:ZGddej:Z Gddej:Z!Gddej:Z"Gdde"Z#Gdde"Z$Gdde"Z%Gdd e"Z&d%d!Z'd&d"Z(d#Z)ejTZ*ejVZ,ejZZ-ej\Z.ejVZ+ej^Z/ejTZ0ejVZ1ejZZ2ej\Z3ejVZ4ej^Z5ejTZ6ejVZ7ejZZ8ej\Z9ejVZ:ej^Z;y)')handlersN)helpersusers)_BLACKLIST_KEYS_WHITELIST_KEYSz tautulli.logztautulli_api.logzplex_websocket.logi@KLtautulli tautulli_apiplex_websocketct}gd}|jD]\}t|tst |j dkDs4j tvsKj |vstfdtDsv|j|j tj|y)N)HOOKAPIKEYKEYPASSWORDTOKENrc3BK|]}|jvywN)upper).0bkkeys /opt/Tautulli/plexpy/logger.py z#blacklist_config..=s7dbciik8I7ds) setitems isinstancestrlenstriprranyradd_BLACKLIST_WORDSupdate)config blacklistblacklist_keysvaluers @rblacklist_configr(6sICNlln) U eS !c%++-&81&< IIK .CIIK>4Q477dTc7d4d MM%++- ( ) I&c4|4tjjdDcgc]}|d }}|D]B}|jdvst |dkDs%|t vs.t j |Dtt tdaycc}w)NT)include_deletedusername)localguest)rreverse)rUsers get_userslowerr_FILTER_USERNAMESappendsorted) new_usersuserr,s rfilter_usernamesr9Cs27++-2I2IZ^2I2_`$T*%` `/ >> #5 5#h-!:KPX`qPq  $ $X ./0c4H as Bc$eZdZfdZdZxZS)LogLevelFilterc8tt| ||_yr)superr;__init__ max_level)selfr? __class__s rr>zLogLevelFilter.__init__Qs nd,."r)c4|j|jkSr)levelnor?r@records rfilterzLogLevelFilter.filterVs~~//r))__name__ __module__ __qualname__r>rF __classcell__rAs@rr;r;Ps # 0r)r;c(eZdZdZfdZdZxZS)NoThreadFilterz+ Log filter for the current thread c8tt| ||_yr)r=rMr> threadName)r@rOrAs rr>zNoThreadFilter.__init__^s nd,.$r)c6|j|jk( Sr)rOrDs rrFzNoThreadFilter.filtercs$$777r))rGrHrI__doc__r>rFrJrKs@rrMrMZs% 8r)rMceZdZdZdZy)BlacklistFilterz9 Log filter for blacklisted tokens and passwords c|tjjsytD]} ||jvr!|jj |d|_g}|j D]7} t|}||vr|j |d}|}|j|9t||_y#Y*xYw#YxYw)NT****************) plexpyCONFIG LOG_BLACKLISTr"msgreplaceargsrr5tuple)r@rEitemr[argarg_strs rrFzBlacklistFilter.filterls}}**$ D 6::%!'!3!3D(!CFJ!;;%C"%c(7?&-oodH&EG")CKK$%$Dk  & s$AB7'#B0 #B70B42B77B;N)rGrHrIrQrFr)rrSrShs r)rSc&eZdZdZdZedZy)UsernameFilterz" Log filter for usernames cptjjsytjsytD]z} |j |j ||_g}|jD]5}t|tr|j ||}|j|7t||_|y#YxYwNT) rVrWLOG_BLACKLIST_USERNAMES _INITIALIZEDr4rZrYr[rrr5r\)r@rEr,r[r^s rrFzUsernameFilter.filters}}44"") H !\\&**h? !;;%C!#s+"ll39KK$%$Dk   s A7B11B5c|dddz|dz}tjtj|||tjS)N********)flags)resubescape IGNORECASE)textmatchmasks rrZzUsernameFilter.replaces=Ray7"U2Y.vvbii&d"--HHr)N)rGrHrIrQrF staticmethodrZr`r)rrbrbs",IIr)rbc@eZdZdZej dZdZdZy) RegexFilterz) Base class for regex log filter ctjjsy |jj |j }|D]#}|j |j ||_%g}|jD]W} t|}|jj |}|r|D]}|j ||}|}|j|Yt||_y#Y(xYw#YyxYwrd) rVrWrXREGEXfindallrYrZr[rr5r\)r@rEmatchesrqr[r^r_s rrFzRegexFilter.filters}}** jj((4G  =!\\&**e<  =D{{ !!#hG"jj009G%,CE&*ll7E&BGC% C  ! +FK  s%AC*QT[[||E4((r)N) rGrHrIrQrlr|rorxrZr`r)rrrs( BJJ;  E )r)rc:eZdZdZej dZdZy)PlexTokenFilterz% Log filter for X-Plex-Token z&X-Plex-Token(?:=|%3D)([a-zA-Z0-9\-_]+)c&|j|dS)NrU)rZ)r@rptokens rrZzPlexTokenFilter.replaces||E8,,r)Nrr`r)rrrs! BJJ1 E-r)rc tjddtjddztjddztj j jddz}|D]}t|tjr|jn*t|tjr|jtj|tj|tj|tj j j|dt_tj|rtj ntj"dt_tj|rtj ntj"dt_tj|rtj ntj"dtj j _|rtj$dd}t&j(j+|t,}tj|t.t0d}|jtj |j3|tj5|tj j j5|t&j(j+|t6}tj|t.t0d}|jtj |j3|tj5|t&j(j+|t8}tj|t.t0d}|jtj |j3|tj5||r`tj$dd}tjt:j<} | j3|| jtj | j?tAtj"tjt:jB} | j3|| jtjDtj5| tj5| tj j j5| tj j j5| tFjHstFjJrtjtjztjztj j jz}|D]}|j?tM|j?tO|j?tQ|j?tS|j?tU|j?tWtYy)a Setup logging for Tautulli. It uses the logger instance with the name 'tautulli'. Three log handlers are added: * RotatingFileHandler: for the file tautulli.log * LogListHandler: for Web UI * StreamHandler: for console (if console) Console logging is only enabled if console is set to True. This method can be invoked multiple times, during different stages of Tautulli. NFz=%(asctime)s - %(levelname)-7s :: %(threadName)s : %(message)sz%Y-%m-%d %H:%M:%Szutf-8)maxBytes backupCountencodingz;%(asctime)s - %(levelname)s :: %(threadName)s : %(message)s)-loggerr logger_apilogger_plex_websocketcherrypylog error_logrRotatingFileHandlercloselogging StreamHandlerflush removeHandler propagatesetLevelDEBUGINFO FormatterospathrFILENAMEMAX_SIZE MAX_FILES setFormatter addHandler FILENAME_APIFILENAME_PLEX_WEBSOCKETsysstdout addFilterr;stderrWARNINGrVDEVrWrSr~rrrbr initHooks) consolelog_dirverbose log_handlershandlerfile_formatterfilename file_handlerconsole_formatterstdout_handlerstderr_handlers r initLoggerrsX??1%&&q)*(11!45<<))22156L 6 gx;; < MMO !6!6 7 MMOW%  )++G4 ,,W5 6F OOWGMM',,? J gllC&+#""G7==N',HLL$ **+jlA77<<233Hx]fqxy gmm,!!.1,' )),777<<633Hx]fqxy gmm,!!.1l+77<<)@A33Hx]fqxy gmm,!!.1((6#--.knAB ..szz:##$56 .   !=> ..szz:##$560.).) )).9 )).9 ::&--!**+,556 ||--667 $ 1G   o/ 0   n. /   02 3   km ,   n. /   o/ 0  1Kr)cfd|r t_|r6tjjfd}|tj_yy)a This method installs exception catching mechanisms. Any exception caught will pass through the exception hook, and will be logged to the logger as an error. Additionally, a traceback is provided. This is very useful for crashing threads and any other bugs, that may not be exposed when running as daemon. The default exception hook is still considered, if pass_original is True. c djtj|}tj d|rt j |yy#YxYw)NrvzUncaught exception: %s)r tracebackformat_exceptionrerrorr__excepthook__)exception_infomessage pass_originals r excepthookzinitHooks..excepthook~sR ggi88.IJG LL17 ;     /    s 7AAcR|g|i||jfd}||_y)Ncr |i|y#ttf$rtjYyxYwr)KeyboardInterrupt SystemExitrexc_info)r[kwargsrold_runs rnew_runz,initHooks..new_init..new_runs:0T,V,):60 /s (6)run)r@r[rrrrold_inits @rnew_initzinitHooks..new_inits, T +D +F +hhG 0DHr)N)rr threadingThreadr>)global_exceptionsthread_exceptionsrrrrs ` @@rrrrsD 0###,, %- !#r)c,tjyr)rshutdownr`r)rrrs r)r)FFF)TTT)rs$  !: ! .  5   : & W  ~ . )))*:;  ' I0W^^0 8W^^ 8gnn<IW^^I@"'.."J [  " )+ ) -k -hV.-b {{ ~~   ..     ??            $$ '++&..'--'--)11+55r)