:jSdZddlmZddlmZddlmZddlZddlZddl m Z m Z m Z ddl mZdd lmZmZdd lmZd d lmZd d lmZmZd dlmZd dlmZe rddlmZddlm Z ddl!m"Z"ddl#m$Z$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0d Z1d!Z2d"Z3d#Z4d$Z5ddddd%d%d&d&d%d'd%d%d(d%de&d)d*ddd%ddddd+fdZdQZ6GdRdSeZ7e8d[dUZ9GdVdWeZ:GdXdYe:Z;dS)\z, Controller to interface with the Plex-app. ) annotations)deepcopy)partialN) TYPE_CHECKINGAnycast)urlparse) CallbackTypeBaseController) MediaStatus) MESSAGE_TYPE)ControllerNotRegistered RequestFailed) CastMessage)chain_on_success)Playable)Media) PlayQueue) PlexServerUNKNOWNBUFFEREDLIVE currentTimePLAYPAUSESTOP STEPFORWARDSTEPBACKPREVIOUSNEXTLOAD SHOWDETAILSSEEK MEDIA_STATUS GET_STATUSEDIT_TRACKS_INFOTdFvideoi~httpz 1.10.1.4602mediaPlayable | Nonetypestr requestIdintoffset directPlaybool directStream subtitleSize audioBoosttranscoderVideotranscoderVideoRemuxOnlytranscoderAudioisVerifiedHostname contentTypemyPlexSubscription contentId str | None streamTypeportprotocoladdressusernameautoplay playQueuePlayQueue | None playQueueID int | None startItem Media | Noneversionkwargsrreturndict[str, Any]c Fd}d}|t|tr |djn|j}t|j}|j}|j}|j}|j}|j }|j }|j } t|dddkr |r|j }n|}||||}|j}|jj}|j dj} |j}|dkr|}||||| |||||||| | || | ||||d|id d|d d ||dd d }|||S) aCreate the message that chromecast requires. Use pass of plexapi media object or set all the needed kwargs manually. See the code for what to set. Args: media (None, optional): a :class:`~plexapi.base.Playable type (str): Default LOAD, SHOWDETAILS. requestId (int): The requestId, Chromecasts may use this. offset (int): Offset of the playback in seconds. directPlay (bool): Default True directStream (bool): Default True subtitleSize (int): Set the subtitle size, possibly only 100 & 200. audioBoost (int): Default 100 transcoderVideo (bool): Default True transcoderVideoRemuxOnly (bool): Default False transcoderAudio (bool): Default True isVerifiedHostname (bool): Default True contentType (str): Default 'video', 'audio' myPlexSubscription (bool): True if user has a PlexPass. contentId (str): The key Chromecasts use to start playback. streamType (str): Default BUFFERED, LIVE port (int): PMS port address (str): PMS host, without scheme. username (None): Username of the user that started playback. autoplay (bool): Auto play after the video is done. currentTime (int): Set playback from this time. default 0 version (str): PMS version. Default 1.10.1.4602 startItem (:class:`~plexapi.media.Media`, optional): Media item in list/playlist/playqueue where playback should start. Overrides existing startItem for playqueues if set. **kwargs: To allow overrides, this will be merged with the rest of the msg. Returns: dict: Returs a dict formatted correctly to start playback on a Chromecast. NrTYPE playqueue)rJrD) machineIdentifierr8r9r:rLr=r;rBrCrA accessTokenuserz /playQueues/z?own=1&window=200)r2r3r5r6r7server containerKey)r>r@r< customDatarEractiveTrackIds)r.r0r,) isinstancelist_serverr _baseurlschemehostnamerArS_tokenmyPlexUsernamer=getattritemscreatePlayQueuerH selectedItemkeylistTyperLupdate) r,r.r0r2r3r5r6r7r8r9r:r;r<r=r>r@rArBrCrDrErrFrHrJrLrMrStokenrV server_urlmsgs S/home/user/adhan/venv/lib/python3.11/site-packages/pychromecast/controllers/plex.pymedia_to_chromecast_commandrm0s~ E !+5$ 7 7 JE!H  U] fo.. $%"4 (#6 5&$ ' '; 6 6 " !  ..u .JJI+ *. oa(1 .{{ "$& ( , ,():'60H'6&*<*< (& #('2  !N{ M M M),!&"9  ! ! CHJJv Jc*eZdZdZeddZdS)PlexMediaStatuszClass to hold the media status.rNr?c6|jdSzReturn episode title.subtitlemedia_metadatagetselfs rl episode_titlezPlexMediaStatus.episode_titles"&&z222rnN)rNr?)__name__ __module__ __qualname____doc__propertyryrnrlrprps8)) 333X333rnrprxc6|jdSrrrtrws rlryrys   " ": . ..rnc$eZdZdZdAfd Z dBdCdZdDdZdAdZdEdZdddFdZ dAdZ dAdZ dAdZ dAdZ dAdZdGdHd$ZdAd%ZdId(ZdJdKd+ZdJdKd,ZdLdMd/ZdLdNd4ZdAd5ZedOd7ZdLdPd:ZdLdNd;Z dQdRd=ZdLdNd>ZdLdSd?ZdLdSd@ZxZS)TPlexControllerz+Controller to interact with Plex namespace.rNNonectddd|_d|_d|_t j|_i|_dS)Nzurn:x-cast:plex9AC194DCr) super__init__app_id namespace request_id threadingEventplay_media_event_last_play_msg)rx __class__s rlrzPlexController.__init__sQ *J777  * ) 1 1.0rnNFTrkdictrr?inc_session_idr4callback_functionCallbackType | Noneincc|jd||||||r||r<|j} ||_||||||_dS#||_wxYw||||dS)aWrapper for the commands. Args: msg (dict): The actual command that will be sent. namespace (None, optional): What namespace should be used to send this. inc_session_id (bool, optional): Include session ID. callback_function (None, optional): If callback is provided it is executed after the command. inc (bool, optional): Increase the requestsId. zSending msg %r %s %s %s %s.)rrN)loggerdebug _inc_requestr send_message)rxrkrrrrolds rl _send_cmdzPlexController._send_cmds$  )                  .C %!*!!#1&7" "%$$$$   NFW      s A(( A1r1c0|xjdz c_|jS)Nr )rrws rlrzPlexController._inc_requests 1rnc.|dS)z1Updates status when a media channel is connected.N) update_statusrws rlchannel_connectedz PlexController.channel_connected s rn_messagerdatacl|ttkr|jd|dSdS)azCalled when a message from Plex to our controller is received. I haven't seen any message for it, but lets keep for for now. I have done minimal testing. Args: message (dict): Description data (dict): message.payload_utf8 interpreted as a JSON dict. Returns: bool: True if the message is handled. z&(PlexController) MESSAGE RECEIVED: %r.TF)rTYPE_MEDIA_STATUSrr)rxrrs rlreceive_messagezPlexController.receive_message s8  !2 2 2 K  F M M M4urnrcL|tti|dS)zSend message to update status.rN)rrTYPE_GET_STATUS)rxrs rlrzPlexController.update_status"s4  ? +?P      rncH|ttidS)zSend stop command.N)rr TYPE_STOPrws rlstopzPlexController.stop(  i011111rncH|ttidS)zSend pause command.N)rr TYPE_PAUSErws rlpausezPlexController.pause,s  j122222rncH|ttidS)zSend play command.N)rr TYPE_PLAYrws rlplayzPlexController.play0rrncH|ttidS)zSend previous command.N)rr TYPE_PREVIOUSrws rlpreviouszPlexController.previous4s  m455555rncH|ttidS)zSend next command.N)rr TYPE_NEXTrws rlnextzPlexController.next8rrnPLAYBACK_STARTposition resume_stater/cZ|ttt|d|idS)zSend seek command. Args: position (int): Offset in seconds. resume_state (str, default): PLAYBACK_START resumeStateN)rr TYPE_SEEKSEEK_KEY)rxrrs rlseekzPlexController.seek<s4  9h- V     rnc0|ddS)zRewind back to the start.rN)rrws rlrewindzPlexController.rewindGs ! rnpercentfloatcb|jt|jj|dz S)zrSet the volume in percent (1-100). Args: percent (int): Percent of volume to be set. Nr))_socket_clientrreceiver_controller set_volume)rxrs rlrzPlexController.set_volumeKs1   &) )"6AA'C-PPPrn皙?deltacv|dkrtd|||jj|zS)zZIncrement volume by 0.1 (or delta) unless at max. Returns the new volume. r,volume delta must be greater than zero, not  ValueErrorrstatus volume_levelrxrs rl volume_upzPlexController.volume_upV@ A::SESSTT Tt{7%?@@@rncv|dkrtd|||jj|z S)z\Decrement the volume by 0.1 (or delta) unless at 0. Returns the new volume. rrrrs rl volume_downzPlexController.volume_down^rrnr bool | Nonec~|jt| |jj }|jj|dS)ziToggle muting of audio. Args: status (None, optional): Override for on/off. N)rrr volume_mutedrset_volume_mutedrxrs rlmutezPlexController.mutefsE   &) ) >11F /@@HHHHHrnr,r-rMrc t|ft|d|}dd}|t t |j|d d | d S)z!Show media item's info on screen.)r.r0msg_sentr4 _response dict | NonerNrc(|stddS)NzPlexController.show_media)r)rrs rlcallbackz+PlexController.show_media..callbackzs& A#$?@@@ A ArnTF)rrrNrr4rrrNr)rm TYPE_DETAILSrlaunchrrr)rxr,rMrkrs rl show_mediazPlexController.show_mediats)  $0A0A0C0C  GM   A A A A .DeLLLh      rnc^|jt|jjdS)zQuit the Plex app.N)rrrstop_apprws rlquit_appzPlexController.quit_apps/   &) ) /88:::::rnrpc|jt|jjj}t|_t t |S)zGet the Chromecast's playing status. Returns: pychromecast.controllers.media.MediaStatus: Slightly modified status with patched method for episode_title. )rrmedia_controllerrryrrprs rlrzPlexController.statuss9   &) )$5<,OV,,,rnr2 float | Nonec|jrU|jj}t|j}||n||ddd<||d<||ddd dS|jd dS) zReset playback. Args: offset (None, optional): Start playback from this offset in seconds, otherwise playback will start from current time. Nr,rXr2 current_time urn:x-cast:com.google.cast.mediaTFrrrzKCan not reset the stream, _last_play_msg was not set with _send_start_play.)rradjusted_current_timerrrr)rxr2 offset_nowrks rl_reset_playbackzPlexController._reset_playbacks   :J4.//C%n & L &x 0#-C  NN<#       K  5     rnc t|fd|i|}|jdt j|d||_||dddd S) zHelper to send a playback command. Args: media (None, optional): :class:`~plexapi.base.Playable **kwargs: media_to_chromecast_command docs string. requestiIdzCreate command: %r )indentrTFrN)rmrrrjsondumpsrr)rxr,rMrks rl_send_start_playzPlexController._send_start_plays*   "//11 5;   2DJs14M4M4MNNN!  8      rntimeoutc |j|j|fi||j||jdS)aBlock until media is playing, typically useful in a script. Another way to do the same is to check if the controller is_active or by using self.status.player_state. Args: media (None, optional): Can also be :class:`~plexapi.base.Playable if not, you need to fill out all the kwargs. timeout (None, int): default None **kwargs: See media_to_chromecast_command docs string. N)rclear play_mediawait)rxr,rrMs rlblock_until_playingz"PlexController.block_until_playingse ##%%%((((( ""7+++ ##%%%%%rnc zjd fd }|d S) aStart playback on the Chromecast. Args: media (None, optional): Can also be :class:`~plexapi.base.Playable if not, you need to fill out all the kwargs. **kwargs: See media_to_chromecast_command docs string. rr4rrrNrc|std jfijdS#jwxYw)NzPlexController.play_media)rrrset)rrrMr,rxs rlapp_launched_callbackz8PlexController.play_media..app_launched_callbacksq A#$?@@@ ,%%e66v666%))+++++%))++++s =ArNr)rrr)rxr,rMrs``` rlrzPlexController.play_mediasa ##%%% , , , , , , , , &; <<<<>rBCCX'',,3355 K155lAFF ;044[!DD +{8$5$&&rnrsTtrackrtype_r/reset_playbackr4c|\}}}|dkr|}|j}n1|dkr|}|j}nt d|D]A} || j| j| jfvr)|j d|||| nB| |r| dSdS)amSets a new default audio/subtitle track. Args: track (None): The chosen track. type_ (str): The type of track. reset_playback (bool, optional): Reset playback after the track has been changed. Raises: ValueError: If type isn't subtitle or audio. rsaudioz(Set type parameter as subtitle or audio.zChange %s to %s.N) r"subtitleStreamssetDefaultSubtitleStream audioStreamssetDefaultAudioStreamrindexlanguage languageCoderrrr) rxr#r$r%item_r!methoddefaulttrack_s rl _change_trackzPlexApiController._change_tracks //11 a J  ))++F3GG g  &&((F0GGGHH H  Fv8KLLL !!"4eUCCCM  #  " " " " " # #rnr'c2||ddS)znEnable an audiotrack. Args: audio (str): Can be index, language or languageCode. r'Nr4)rxr's rlenable_audiotrackz#PlexApiController.enable_audiotrack@s 5'*****rnc|\}}}||dS)zDisable a subtitle track.N)r"resetDefaultSubtitleStreamr)rxr0__r!s rldisable_subtitlez"PlexApiController.disable_subtitleHsK  # # % %    ''))) rnc0||dS)ztEnable a subtitle track. Args: subtitle (str): Can be index, language or languageCode. Nr6)rxrss rlenable_subtitlez!PlexApiController.enable_subtitleRs 8$$$$$rnNr,r-rMc d|jji}||tj|fi|dS)a}Start playback on the Chromecast. Args: media (None, optional): Can also be :class:`~plexapi.base.Playable if not, you need to fill out all the kwargs. **kwargs: See media_to_chromecast_command docs string. `version` is set to the version of the PMS reported by the API by default. rLN)rrLrhrr)rxr,rMargsrs rlrzPlexApiController.play_mediaZsK48+, F5))D)))))rn)rrrNr)rNr)rsT)r#rr$r/r%r4rNr)r'r/rNrr )rsr/rNrr r ) rzr{r|r}rr"r4r7r;r=rr r s@rlrr s,, ' ' ' 'KO!#!#!#!#!#F++++%%%% * * * * * * * * * * *rnr)8r,r-r.r/r0r1r2r1r3r4r5r4r6r1r7r1r8r4r9r4r:r4r;r4r<r/r=r4r>r?r@r/rAr1rBr/rCr?rDr?rEr4rr1rFrGrHrIrJrKrLr/rMrrNrO)rxrprNr?)rUs#""""" ++++++++++!!!!!!******** ::::::::0/////*%%%%%%######++++++))))))!           "*" %* ## *"&"" 5GGGGGT33333k333 /// / {#{#{#{#{#^{#{#{#~ \*\*\*\*\*\*\*\*\*\*rn