ljt zddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZddlmZmZddlmZddlmZddlmZmZddlmZddlmZdd lmZmZddlZdd lm Z!dd l"m#Z#m$Z$m%Z% dd l&m&Z&ejPd Z)iddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2Z*e*jWDcic]\}}|| c}}Z,id3dd4dd.dd5dd6dd7dd8dd9dd:dd;d!dd0d?d@dAdBdCdDdEdFidGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdidjdkdldmdndodpZ-e-jWDcic]\}}|| c}}Z.iZ/da0GdqdrejbZ2dsZ3dtZ4duZ5dvZ6dwZ7ddxZ8dyZ9dzZ:d{Z;d|ZdZ?ddZ@dZAddZBddZC ddZD ddZEddZFddZGddZHddZIdZJdZKdZLdeMdeNfdZOddZPddZQdZRdZSdZTgdZUejdk\reUjgdeUDcgc]\}}eX|deX|c}}ZYejddjeYdZ\dZ]deNfdZ^deNfdZ_y#e'$rdZ&Y!wxYwcc}}wcc}}wcc}}w)N)deque)datetime timedelta)getpass)sha1)EventThread)quote) ElementTree)ZoneInfoZoneInfoNotFoundError)_codes) BadRequestNotFound Unauthorized)tqdmplexapimovieshowseasonepisodetrailercomicpersonartistalbum track picture clip photo photoalbumplaylistplaylistFolder collection*i)optimizedVersionuserPlaylistItemtaggenredirectorwriterroleproducercountrychapterreviewlabelmarkermediaProcessingTargetmakemodelapertureexposureisolensdeviceautotagmoodi,stylei-formati. subformati/similari1concerti2banneri7posteri8arti9guidi: ratingImagei<themei=studioi>i?iBiCiDiEii)network showOrdering clearLogocommonSenseMedia squareArtplace sharedWidthc$eZdZdZddZdZdZy) SecretsFilterz! Logging filter to hide secrets. Nc*|xs t|_yN)setsecrets)selfrns :/DATA/.local/lib/python3.12/site-packages/plexapi/utils.py__init__zSecretsFilter.__init__rs'#% cJ| |dk7r|jj||SN)rnadd)rosecrets rp add_secretzSecretsFilter.add_secretus%  &B, LL  V $ rrct|j}tt|D]?}t ||t s|j D]}||j|d||<At||_y)NzT) listargsrangelen isinstancestrrnreplacetuple)rorecord cleanargsirws rpfilterzSecretsFilter.filterzsj% s9~&A)A,,"llF#,Q<#7#7 #KIaL+'I& rrrl)__name__ __module__ __qualname____doc__rqrxrrrrprjrjos+( rrrjc lt|dt|d|j}|r|jd|n |j}t|ddr|d}nt|ddr|d}|tvr? ?K Jrrctj|}||Sd|vr"|jddd}t||Stj|S)z Return the PlexObject class for the specified ehash. This recursively looks up the class with the highest specificity, falling back to the default class if not found. rrr)default)rgetrsplit getPlexObject)rrrs rprrsT //% C   e| S!$Q'UG44 ??7 ##rrc||S|tk(r|dvry|dvryt||ttfvr ||S||S#t$rtdcYSwxYw)aB Cast the specified value to the specified type (returned by func). Currently this only support str, int, float, bool. Should be extended if needed. Parameters: func (func): Callback function to used cast to type (int, bool, float). value (any): value to be cast and returned. )rT1trueT)rF0falseFnan)bool ValueErrorintfloat)funcvalues rpcastrsz }  t| * * , , U| ;  ; <  sAAAc |syg}t|dD]1}t||}|j|dt|d3ddj |S)z Returns a query string (uses for HTTP URLs) where only the value is URL encoded. Example return value: '?genre=action&type=1337'. Parameters: args (dict): Arguments to include in query string. ruc"|jSrllowerxs rpzjoinArgs..s !'')rr)key=)safe?&)sortedrappendr join)r{arglistrrs rpjoinArgsrsf Gd 34DI#ae" 56785sxx ! ""rrc4|dj|ddzS)Nrrrss rp lowerFirstrs Q4:: for each set of `*args` in listargs. Each call to is called concurrently in their own separate threads. Parameters: callback (func): Callback function to apply to each set of `*args`. listargs (list): List of lists; `*args` to pass each thread. N)job_is_done_event)targetr{kwargsTc3>K|]}|j ywrl)is_alive).0ts rp zthreaded..Fs1A1::<sg?) rr}rr rdaemonstartis_setalltimesleep)callbacklistargsthreadsresultsrr{rs rpthreadedr5s2WG #g,''tvXDXiAjkl!     &&( 11 1  4 &&(  0w!!-Aw 00 0s CCcZ||dur d}|atS|dus*t|jjdk(r4tjj j }|atSt|j} tt|j}|r,tjj j nd}|atS#t$r> t|}n'#t$rd}tjd|YnwxYwY|atSwxYw)a Sets the timezone to use when converting values with :func:`toDatetime`. Parameters: value (bool, str): - ``False`` or ``None`` to disable timezone (default). - ``True`` or ``"local"`` to use the local timezone. - A valid IANA timezone (e.g. ``UTC`` or ``America/New_York``). Returns: datetime.tzinfo: Resolved timezone object or ``None`` if disabled or invalid. NFTlocalz2Failed to set timezone to "%s", defaulting to None)rstriprrnow astimezonetzinforrrr r logwarningDATETIME_TIMEZONE)rrsetting is_enableds rpsetDatetimeTimezonerMs }& % $#e***,224?**,33  e*""$ YdGMMO4J;EX\\^..0774F  Y Y!'*( Y PRWX Y  Ys7 AC## D*- C98D*9!DD*DD*)D*c t|} |rt j ||St j |S#t$rtjd|YywxYw#t ttf$rt |r&t j d|t|zcYSt j dt|zcYS#t$rtjd|YYywxYwwxYw)zD Helper function to parse a timestamp value into a datetime object. zAFailed to parse "%s" to datetime as timestamp, defaulting to NoneN)tzr)secondszQFailed to parse "%s" to datetime as timestamp (out-of-bounds), defaulting to None) rrrinfor fromtimestampOSError OverflowErrorr)rrs rp_parseTimestamprtsE   ))%F; ;%%e,,  TV[\ ]J / --aF;iPU>VVV))!,y/GG G  HHhjo p  sO <A!A!AA!C)6%CC)!C?C)C%!C)$C%%C)c|bt}|rN tj||}|j|r|j |S|S|r|j |S|St||S|S#t $rtjd||YywxYw)z Returns a datetime object from the specified value. Parameters: value (str): value to return as a datetime format (str): Format to pass strftime (optional; if value is a str). N)rzCFailed to parse "%s" to datetime as format "%s", defaulting to None) rrstrptimerrrrrrr)rrWrdts rp toDatetimer s "  &&uf599(4:2==0BB8>2::V:4FBF #5&1 1 L  ^`egmn s#4A'A'A'A'' B  B c t|}|dkrdtt|zSt|d\}}t|d\}}t|d\}}t|d\}}|dk(rdn|d|dkDrd ndd |d d |d d |d d |dzS)z Returns human readable time duration [D day[s], ]HH:MM:SS.UUU from milliseconds. Parameters: milliseconds (str, int): time duration in milliseconds. r-i<ruz dayrr, 02d:r03d)rmillisecondToHumanstrabsdivmod) millisecondssecsmsminshoursdayss rprrs |$La*3|+<===lD)HD"b!JD$r"KE4#KD%!)BD6TAXc2-Fb!IPUVY{Z[\`ad[eefgklofppqrtuxqyMz zzrrc|xsd}|xst}|j|Dcgc]}|dk7s ||c}Scc}w)a$ Returns a list of strings from the specified value. Parameters: value (str): comma delimited string to convert to list. itemcast (func): Function to cast each list item to (default str). delim (str): string delimiter (optional; default ','). ru)rr)ritemcastritems rptoListr sC KRE3H',{{5'9 H'9tTRZHTN'9 HH Hs < <cdtjtjtjd|j ddj }djfd|D}|S)Nz-_.()[] NFKDASCIIignoreruc3.K|] }|vr|nywrlr)rcr whitelists rprz cleanFilename..sZIYAANq?IYs)string ascii_lettersdigits unicodedata normalizeencodedecoder)filenamercleaned_filenamer's ` @rp cleanFilenamer1sc6//0@I",,VX>EEgxX__awwZIYZZ rrc i}|jD]}d}|jD]^} |jr |j}| js(d| jd| jj d|j }`|sy|C|j} d|jdd| dttj}|j|||||}t||j|} | |d |d <|S) a Helper to download a bif image or thumb.url from plex.server.sessions. Parameters: filename (str): default to None, height (int): Height of the image. width (int): width of the image. opacity (int): Opacity of the resulting image (possibly deprecated). saturation (int): Saturating of the resulting image. Returns: {'hellowlol': {'filepath': '', 'url': 'http://'}, {'': {filepath, url}}, ... Nz/library/parts/z /indexes//session_transcode_r_)r/)filepathurlusername)sessions iterPartsthumbindexesidr viewOffset_prettyfilename usernamesrrtranscodeImagedownload_token) serverr/heightwidthopacity saturationrmediar7part prettynamer6s rpdownloadSessionImagesrLs D"OO%D{{kk||'y $,,:L:L:N9OqQVQaQaPbc & "224 /0B/C1ZLPQRUVZV_V_VaRbQcd''VUGZPCV]]XFH,4SAD # Krrc |xstj}d|i} |j|| d} | jdvrt j| jd} | j j dd} d| jd | d | jd| } | jd k(r t| | jd k(r t| t| |xstj}tj|d |sV| jjdr;tj d| jjd}|dr|dnd}tj"j%|}tj"j'||}tj"j)|d}|s8| jjd}|rd|vr||j+ddz }|rt,j/d||St,j1d||r:t2r4t5| jjdd}t3dd||}t7|d5}| j9|D]7}|j;||st2sj=t?|9 ddd|rt2rjA|jCdr4|r2tEjF|d5}|jI|ddd|S|S#1swYhxYw#1swY|SxYw)a Helper to download a thumb, videofile or other media item. Returns the local path to the downloaded file. Parameters: url (str): URL where the content be reached. token (str): Plex auth token to include in headers. filename (str): Filename of the downloaded file, default None. savepath (str): Defaults to current working dir. chunksize (int): What chunksize read/write at the time. mocked (bool): Helper to do everything except write the file. unpack (bool): Unpack the zip file. showstatus(bool): Display a progressbar. Example: >>> download(a_episode.getStreamURL(), a_episode.location) /path/to/file z X-Plex-TokenT)headersstream)rFrHrNr  (z) z; ii)exist_okzContent-Dispositionzfilename=\"(.+)\"Nrz content-typeimager3rzMocked download %szDownloading: %szcontent-lengthB)unit unit_scaletotaldescwb) chunk_sizezipr)%requestsSessionr status_codecodestextrr7rrrosgetcwdmakedirsrNrefindallpathbasenamersplitextrrdebugrrropen iter_contentwriteupdater}closeendswithzipfileZipFile extractall)r7tokenr/savepathsession chunksizeunpackmocked showstatusrNresponsecodenameerrtextmessagefullpath extension contenttyperXbarhandlechunks rprBrBs(+))+Gu%G{{3{=H?299X11215--''c2h**+2hZr(,,q R   3 &w' '  ! !S (7# #W% %&299;HKK4( ((,,-BC::2H4D4D4H4HI^4_`"*1+8A;4ww)Hww||Hh/H  *2.I &&**>: 7k1  ))#.q1 1H &1HH )dH$$(()91=>EI h **i*@E LL d 3u:&A  d F __Xs +v   h ', O8O  , Os$8)L-"L-)L-L9-L69Mcddlm}ddlm}|rN|jrB|j r6t d|jd||j|j S|jd}|jd}|r|rt d|d|||S|jd}|rt d || Std }td }t d|d|||S) aK Helper function tries to get a MyPlex Account instance by checking the the following locations for a username and password. This is useful to create user-friendly command line tools. 1. command-line options (opts). 2. environment variables and config.ini 3. Prompt on the command line. r)CONFIG) MyPlexAccountzAuthenticating with Plex.tv as z..zauth.myplex_usernamezauth.myplex_passwordzauth.server_tokenz&Authenticating with Plex.tv with tokenrtzWhat is your plex.tv username: zWhat is your plex.tv password: ) rrplexapi.myplexrr8passwordprintrinputr)optsrrconfig_usernameconfig_password config_tokenr8rs rpgetMyPlexAccountr6s,  $-- / bABT]]DMM::jj!78Ojj!78O? //@CD_o>>::12L 67<0067H89H +H:R 89 8 ,,rrc$ddlm}|st}d|i}td|nd|vr t d|d}||}|j ||j |j|j|j|S) a Helper function to create a new MyPlexDevice. Returns a new MyPlexDevice instance. Parameters: headers (dict): Provide the X-Plex- headers for the new device. A unique X-Plex-Client-Identifier is required or one will be generated if not provided. account (MyPlexAccount): The Plex account to create the device on. timeout (int): Timeout in seconds to wait for device login. r)MyPlexPinLoginX-Plex-Client-Identifier1No X-Plex-Client-Identifier provided, generated: 0The X-Plex-Client-Identifier header is required.)rNtimeout)clientId) rr generateUUIDrrrunlinkpin waitForLoginrQ)rNaccountrrclient_identifierclientIdentifierpinlogins rpcreateMyPlexDevicerUs. (N-/@A ABSATUV #7 2KLL9:g.H LLL! LL  >>#3> 44rrcnddlm}m}|st}d|i}t d|nd|vr t d||d}|j |t d |j| |j|jrt d ||j St d y)a Helper function for Plex OAuth login. Returns a new MyPlexAccount instance. Parameters: headers (dict): Provide the X-Plex- headers for the new device. A unique X-Plex-Client-Identifier is required or one will be generated if not provided. forwardUrl (str, optional): The url to redirect the client to after login. timeout (int, optional): Timeout in seconds to wait for user login. Default 120 seconds. r)rrrrrT)rNoauthr$Login to Plex at the following url:  forwardUrlzLogin successful!rz Login failed.N) rrrrrrroauthUrlrrt)rNrrrrrrs rp plexOAuthrqs= (N-/@A ABSATUV #7 2KLLgT:H LLL! 1(2C2Cz2C2Z1[ \] ~~ !"8>>22 orrcddlm}m}|st}d|i}t d|nd|vr t d||d||}|dr|ds|j d t d |j| t d |j||j|jrt d||jSt dy)a( Helper function for Plex JWT authentication using Plex OAuth. Returns a new MyPlexAccount instance. Parameters: headers (dict, optional): Provide the X-Plex- headers for the new device. A unique X-Plex-Client-Identifier is required or one will be generated if not provided. forwardUrl (str, optional): The url to redirect the client to after login. timeout (int, optional): Timeout in seconds to wait for user login. Default 120 seconds. keypair (tuple, optional): A tuple of the ED25519 (privateKey, publicKey) to use for signing the JWT. If not provided, a new keypair will be generated and saved to 'private.key' and 'public.key'. scopes (list[str], optional): List of scopes to request in the JWT. r)rMyPlexJWTLoginrrrT)rNrkeypairscopesr)z private.keyz public.key)keyfileszJGenerated new ED25519 keypair and saved to "private.key" and "public.key".rrrzJWT authentication successful!rzJWT authentication failed.N) rrrrrrgenerateKeypairrrrjwtToken) rNrrrrrrrjwtlogins rp plexJWTAuthrs= (N-/@A ABSATUV #7 2KLLgT7SYZH 1:WQZ  *G H Z[ LLL! 1(2C2Cz2C2Z1[ \]  ./8#4#455 *+rrct|dk(r|dStt|D]5\}}t|r||n t ||}td|d|7t t |dt fddDr'ttdjd}||S|tS#ttf$rYnwxYwn) zm Command line helper to display a list of choices, asking the user to choose one of the options. rrz z: c3&K|]}|v ywrlr)rrinps rprzchoose..s6%518%5s)rz::r cX|jrt|jSdSrl)rrrs rprzchoose..sQWWY3qwwy>+PD+Prrr) r}r enumeratecallablerranyslicemaprrr IndexError)msgitemsrindexrnameidxrs @rpchoosers  5zQQx Ge$q"4.tAwga.> 5'D6"#% G  3%r #C6%566S!PRUR[R[\_R`abSz!SX&J'    s.AC7 CCCcg}|jD]<}|j|j|jg}||vr|jcS||z }>t d|ddj |d)z] Return the full agent identifier from a short identifier, name, or confirm full identifier. zCould not find "z" in agents list (r))agents identifiershortIdentifierrrr)sectionagentrag identifierss rpgetAgentIdentifierrsw Fnn}}b&8&8"''B K == +  &ug-@6AR@SSTU VVrrchtj|jdjdS)Nutf-8)base64 b64encoder-r.)ras rp base64strrs'   DKK0 1 8 8 AArrdatareturnchtj|jdjdS)N=r)rurlsafe_b64encoderstripr.)rs rpbase64urlEncoders)  # #D ) 0 0 6 = =g FFrrcfd}|S)NcHtjfd}|S)zThis is a decorator which can be used to mark functions as deprecated. It will result in a warning being emitted when the function is used.cdjdd}tj|ttj ||i|S)Nz'Call to deprecated function or method "z", r)category stacklevel)rwarningswarnDeprecationWarningrr)r{rrrr~rs rpwrapperz.deprecated..decorator..wrappersI;DMM?#gYVWXC MM#(:z R KK (( (rr) functoolswraps)rrr~rs` rp decoratorzdeprecated..decorators'   )  ) rrr)r~rrs`` rp deprecatedrs  rrc#Kt|g}|rC|j}||j|k(r||jt ||rByyw)z} Iterate through an XML tree using a breadth-first search. If tag is specified, only return nodes with that tag. N)rpopleftr9extendrz)rootr9queuenodes rp iterXMLBFSrsJ 4&ME }} ;$((c/J T$Z s AAAc 8d}tj|fd|i|S)z Convert an object to a JSON string. Parameters: obj (object): The object to convert. **kwargs (dict): Keyword arguments to pass to ``json.dumps()``. ct|tr|jS|jj Dcic]\}}|j dr||c}}Scc}}w)Nr5)r~r isoformat__dict__r startswith)rrvs rp serializeztoJson..serializesR c8 $==? "!$!3!3!5O!5AQ\\#=N1!5OOOs A!A!r)jsondumps)rrrs rptoJsonrs#P ::c 79 7 77rrct|tr|St|dr|jSt |d5}|jcdddS#1swYyxYw)Nreadrb)r~byteshasattrrrk)filefs rp openOrReadr sH$ tVyy{ dD Qvvx   s AAcRt|jdjS)z! Return the SHA1 hash of a guid. r)rr- hexdigest)r^s rpsha1hashrs  G$ % / / 11rr))rr#)r)r+)r/)))ii)iii))ii)ii)ii)ii)ii)ii)ii)ii)i i )i i )i i )i i )i i )ii)ii)iir [ru]c.tjd|Srt)_illegal_XML_resubrs rpcleanXMLStringr @s   r1 %%rrrc&|jsy tj|jdS#tj$rFt |jd}|jrtj|cYSdcYSwxYw)z7 Parse an XML string and return an ElementTree object. Nr)rr fromstringr- ParseErrorr )r cleaned_ss rpparseXMLStringrDsy 779P%%ahhw&788  ! !P"1%,,W5 4=OO4E{%%i0O4OPs#7AB BBc<ttjSrl)ruuiduuid4rrrrprrOs tzz| rr)Nrrl)N,)r5)Nrdr)NNNiFFF)NNr')Nx)NNr)NNN)r)`rrrloggingrbrer(sysrr+rrrq collectionsrrrrhashlibr threadingrr urllib.parser xml.etreer zoneinfor r r]requests.status_codesrr`plexapi.exceptionsrrrr ImportError getLoggerrrrrrrrrFilterrjrrrrrrrrrrrrrr rr r1rLrBrrrrrrrrrrrrrrr_illegal_XML_characters maxunicoderchr_illegal_XML_rangescompilerr r rr)rrlowhighs0000rpr.s    (#!41AAg " Q A aq  q   Q  a a Q Rr B R" b!""#$' *(3'8'8':;':tq!ad':;*  1*  Q* !*  *   a *   A * * q* q*  b*  R*  b* R*  C*  S*  !* "#* $ 3%* & C'* ( c)* *s+* , C-* . S/* 0 c1* 23* 4s5* 6s7* 8 c9* : c;* < 3=* > C?* @3A* B SC* D cE* F S* V%-NN$45$4DAq1a4$45 GNN*$ $2 #  >@$@"8$8"10$N*2 { IDG25BPT49L^->58<#,L6WBG%GCG  ! 82 >>W"" ,/. d Cz3t9+."**"''*=">!?qAB&PcPce D6<\6fs$J% J+= J1J7J('J(