gRrddlZddlmZddlmZddlmZddlmZddlmZddlmZd dZ d d Z dd Z d Z y)N)minidom)activity_processor)database)helpers)logger)userscTi}tj|} tj|}|j d}|st j dy|D]/}tj|d}tj|d}tj|d}tj|d} tj|d} tj|d} tj|d } tj|d } tj|d }tj|d }tj|d }tj|d}tj|d}tj|d}tj|d}tj|d}tj|d}tj|d}tj|d}tj|d}tj|d}tj|d}tj|d}g}|j dr=|j d}|D]'}|jtj|d)d} d}!d}"d}#d}$d}%d}&d}'d}(d})|j dr|j d}*|*D]}+tj|+d} tj|+d}!tj|+d }"tj|+d!}#tj|+d"}$tj|+d#}%tj|+d$}&tj|+d%}'tj|+d&}(tj|+d'})d},d}-d}.|j d(rp|j d(}/|/D]Z}0tj|0d)}1tj|0d*},tj|0d+}-tj|0d}.\d}2d}3d,}4d}5d}6d}7d}8d,}9d}:|j d-r|j d-};|;D]}|j d3r.|j d3}?|?D]}@tj|@d4}>g}A|j d5r=|j d5}B|BD]'}CAjtj|Cd)g}D|j d6r=|j d6}E|ED]'}FDjtj|Fd)g}G|j d7r=|j d7}H|HD]'}IGjtj|Id)g}J|j d8r=|j d8}K|KD]'}IJjtj|Id)id9|d|d|d:| d|d;|d<| d=| d|d | d>| d?|d@|dA|dB|dC|d|id|dD|dE|dF|d|dG|dH| dI|!dJ|"d!|#d"|$d#|%dK|&dL|'dM|(d'|)dN1idO|,d+|-dP|.dQ|2dR|3dS|4dT|5dU|6dV|7dW|8dX|9dY|:dZ|=d[|>d\Ad]Dd^G|Jd_}2|S#t j dYyxYw)`Nz>Tautulli Importer :: Error parsing XML for PlexWatch database.optaddedAtartdurationgrandparentThumbgrandparentTitle originalTitleguidlibrarySectionIDindexoriginallyAvailableAt lastViewedAt parentIndex parentThumbratingthumbtype updatedAt viewOffsetyear parentTitlestudiotitletaglineDirectortagMedia aspectRatio audioChannels audioCodecbitrate containerheight videoCodecvideoFrameRatevideoResolutionwidthPlayeraddressmachineIdentifierplatformz direct playTranscodeSession audioDecisionprotocol videoDecision transcodecopyUseridWriterRoleGenreLablesadded_atgrandparent_thumb parent_titlegrandparent_titleoriginal_title section_id media_indexoriginally_available_atlast_viewed_atparent_media_index parent_thumb media_type updated_at view_offset directors aspect_ratioaudio_channels audio_codec video_codecvideo_frameratevideo_resolution ip_address machine_idplayertranscode_audio_channelstranscode_audio_codecaudio_decisiontranscode_containertranscode_heighttranscode_protocoltranscode_video_codecvideo_decisiontranscode_widthtranscode_decisionuser_idwritersactorsgenres)rlabels) r latinToAsciir parseStringrwarngetElementsByTagName get_xml_attrappend)Lxmloutput clean_xml xml_parsexml_headar@r r rArCrDrrErFrGrHrIrJrrrKrLrMrrBrr r!rN director_elembrOrPrQr)r*r+rRrSrTr/ media_elemcrVr3rW player_elemdrUrXrYrZr[r\r]r^r_r`transcode_elemerarb user_elemfrc writer_elemgrd actor_elemhre genre_elemirf label_elemsL (/opt/Tautulli/plexpy/plexwatch_import.pyextract_plexwatch_xmlrsu F$$S)I'' 2 --e4H  TU w''95""1e,'':6#004FG#004FG --aA##Av.))!-?@ **1g6 ")"6"6q:Q"R --a@$11!]C++A}= %%a2$$Q0))!V4 ))![9 **1l; ##Av.++A}= %%a2$$Q0&&q)4 ! !* -22:>M" A  !5!5a!?@ A     ! !' *//8J 9&33A}E !(!5!5a!I%221lC !..q)<#00K@  --a:%221lC ")"6"6q:J"K#*#7#7;L#M ,,Q8 9  ! !( +00:K  :$11!Y? $11!5HI "//:> --a9  : $( "&  "& ! !"4 5334FGN# C+2+?+??+S((/(<( ? ! !& )//7J > g221e<= > ! !' *//8J > g221e<= > ! !( +//9J > g221e<= >5*h55h5&'855 5 !, 5 &'8 5#N5W5$5 5 5,-D5#N5'(:5!,5 F!5"5#5$ %5& '5( )5*$+5,y-5.!,/50#N152 354W556y758F95: ;5<$_=5>%&6?5@5A5B C5D E5FhG5HFI5J-.FK5L*+@M5N#NO5P()| d>d | d d?| d?d@| d@dA| dAidB| dBdC| dCdD|dDdE|dEdF| dFdG| dGd&| d&dH| dHd"| d"dI| dIdJ| dJdK| dKdL| dLdM| dMdN| dNd|dd'| d'| d(| d)| d*| d+| d,| d-| d.| d/| d0dO } | d j-r|j/| | d|Pt jdQ| d zt1t jdRtjdSy#tj$rt j dYyt$rt j dYywxYw#tj$rt j dYywxYw#t jdYyxYw)TNrrz&Tautulli Importer :: Invalid filename.rzMTautulli Importer :: Database specified does not contain the required fields.z9Tautulli Importer :: PlexWatch data import in progress...TzGTautulli Importer :: Unable to refresh the users list. Aborting import.aSELECT time AS started, stopped, cast(ratingKey as text) AS rating_key, null AS user_id, user, ip_address, paused_counter, platform AS player, null AS platform, null as machine_id, parentRatingKey as parent_rating_key, grandparentRatingKey as grandparent_rating_key, null AS media_type, null AS view_offset, xml, rating as content_rating,summary,title AS full_title,(case when orig_title_ep = '' then orig_title else orig_title_ep end) as title,(case when orig_title_ep != '' then orig_title else null end) as grandparent_title FROM z ORDER BY idrmzLTautulli Importer :: Skipping record with ratingKey %s due to malformed xml. rating_keyz;Tautulli Importer :: Skipping record due to null ratingKey.user)rrbstartedstoppedr rBrCrD full_titlerUpaused_counterrWr3rVparent_rating_keygrandparent_rating_keyrKrMrEr_rZrar r/r+r*rRrQr)rTrSrOrPr]r[r^rYrXr`r\)r]r[r^rYrXr`r\rFrIrrJrAr rrGr@rLrHcontent_ratingsummaryr!rrrNrcrdrerrf) r+r*rRrQr)rTrSrOrP)sessionimport_metadata is_importimport_ignore_intervalz0Tautulli Importer :: Item has bad rating_key: %sz4Tautulli Importer :: PlexWatch data import complete.F)rrRow row_factoryrrrrrdebugrset_is_importingrActivityProcessorrUsers refresh_usersrstr get_user_idrrgisdigitwrite_session_history import_users) rrrrap user_dataqueryresultrow extracted_xmlrbsession_historysession_history_metadatas rimport_from_plexwatchrs__]B? !( 5 BC  LLLM d#  - - /B I   ,!- !,$2- 2E0   &Fuv-c%j9  LLgs<012 3 < LLV W   c&k 2++V+=G#I.G)9c)n)$c)n)'\):)#CL)*=+H ) /4G0H ) ,];K-L )(\):)%g)"3v;)(c,>O\):UbcoUp),S1A-B)$S])&}Z'@)(|)D)/4G0H) 4S9Q5R!)"(|)D#)$)- *F%)&(|)D')(,];K-L))*,];K-L+),0?S1T-).&}Z'@/)0#M'$:1)2$]8%<3)4' k(B5)6)- *F7)8)- *F9):%mI&>;)<.}=O/P=)>-m[+$&%,S\+$&%3M.4Q +$& %8=P9Q +$& %5mDT6U +$&%2=3O+$&%9-H\:]+$&%,]7-C+$&%3M.4Q+$&%8GZ9[+$&%*=+?+$&%1- 2M+$&%+M&,A+$&%>}Mf?g+$& %/ j0I!+$&"%1- 2M#+$&$%5mDT6U%+$&&%5c:J6K'+$&(%.s9~)+$&*%.}Y/G++$&,%-mH.E-+$&.%/ j0I/+$&0%+M&,A1+$&2%1- 2M3+$&4%0{1K5+$&6%.}Y/G7+$&8%-mH.E9+$&:%-mH.E;+$&<%-mH.E=+$&>%-mH.E?+$&@%1#l2CA+$&B%,]7-CC+$&D/{1K3@3O3@3O/  =>  # # de ^_s4,OPQ(P0PP(P>=P>Qctjdtj}d} |j |tjdy#tjdYyxYw)Nz1Tautulli Importer :: Importing PlexWatch Users...z}INSERT OR IGNORE INTO users (user_id, username) SELECT user_id, user FROM session_history WHERE user_id != 1 GROUP BY user_idz$Tautulli Importer :: Users imported.z,Tautulli Importer :: Failed to import users.)rrrMonitorDatabaseaction) monitor_dbrs rrrs[ LLDE))+J GEE%  ;<E CDs &AA-)N)NN)NNr) rxml.domrplexpyrrrrrrrrrrrs5$%GT4s%l Er