+ G.jyRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RIt^RIHt^RIt]P$!]P&P(4]P*!R4tRsRtRtRtRtR tR tR R R RRRRRRRRRRRRRRRRRRRRR R!R"R#R$/tR%t] !R&4;_uu_4t!]!FCt"]"PGR'4'gK]"PI4PKR(^4^,tKE RRR4R)t'R*R+lt(R,R-lt)RR.R/llt*RR0R1llt+RR2R3llt,RR4R5llt-RR6R7llt.RR8R9llt/RR:R;llt0^R?llt3RR@RAllt4RRBRCllt5RRDREllt6RRFRGllt7RRHRIllt8RRJRKllt9RRLRMllt:RRNROllt;RRPRQlltRRVRWllt?RXRYlt@RZR[ltAR\R]ltBRR^R_lltCRR`RalltDRRbRclltE.ROtFRdReltGRftHRgtIRhtJRitKRjtL^RIMtN^RIOHPuHQtRRkRlltSRmRnltTRRoRplltURqRrltVRsRtltW\.Ru3RvRwlltXRu\.3RxRylltYRRzR{lltZRR|R}llt[R~Rlt\!RR4t]!RR]&4t^!RR]&4t_RRlt`!RR4taRRRlltbRRu\.3RRlltcR# +'giEL;i ]&dELi;i)u3Shared TV control module — JointSpace, UPnP, ADB, Home Assistant, throttle. Consolidates all TV/ADB/HA control functions used by sandman.py, sandman_bot.py, and devices_server.py. Import and call directly: import tvmod as tv_control tv_control.js_key("Pause") vol = tv_control.get_volume() NHTTPDigestAuth tv_controlz 192.168.1.50 a1b2c3d4e5f6@8f075a1826341135dcd3a9dd2ed30a49c327d7e002399fbaefae28d8e1f9936fiz/urn:schemas-upnp-org:service:RenderingControl:1z{body}com.google.android.youtube.tvYouTubecom.netflix.ninjaNetflix!com.amazon.amazonvideo.livingroomz Prime Videozorg.droidtv.channelszLive TVorg.droidtv.playtvzorg.droidtv.contentexplorerz Media Browser com.apple.atve.androidtv.appletvz Apple TV+z$com.google.android.apps.tv.launcherxHomezcom.google.android.tvlauncherzcom.google.android.katnissz Google TVzorg.droidtv.settingsSettingscom.disney.disneypluszDisney+z tv.mewatchmewatchzcom.spotify.tv.androidSpotifyz/data/.ssh/environmentzSUPERVISOR_TOKEN==z/share/.ha_cache/.ha_wd_tv_ipc$V^8dQhR\/#returnstr)formats"/share/.ha_cache/tvmod.py __annotate__rRs  C c\\4P4P4pV'dVs\# \ d \#i;i)zOReturn the current TV IP, checking cache file if module-level TV_IP is default.)open TV_IP_CACHEreadstripTV_IP Exception)cacheds r _get_tv_ipr(RsK k"'')//1 E L   L s5= AAc$V^8dQhR\/#rr)rs"rrras55.5rc*\\\4#N)r JS_DEVICE_ID JS_AUTH_KEYrr_js_authr/as , 44rc0V^8dQhR\R\/#riprr)rs"rrres""""rc6T;'g \4pRV R2#)https://z:1926/6)r(r2s&r_js_baser6es  z|B bT !!rc0V^8dQhR\R\/#r1r)rs"rrrjs%%C%3%rc@T;'g \4pV R\ 2#):)r(ADB_TARGET_PORTr5s&r _adb_targetr;js#  z|BT?# $$rc0V^8dQhR\R\/#r1r)rs"rrrosEE#EErcDT;'g \4pRV R\ R2#)http://r9z/upnp/control/RenderingControl1)r( UPNP_PORTr5s&r _upnp_urlr@os'  z|B RD)$C DDrc VV^8dQhR\R\R\R\R,/#)rpathtimeoutr2rN)rfloatdict)rs"rrrvs,   u c TD[ rcLT;'g \4p\V4 RVPR4 2p\P!V\ 4RVR7pVP 4VP4# \d"p\PRY4Rp?R#Rp?ii;i)z8GET a JointSpace endpoint. Returns parsed JSON or None./F)authverifyrCzjs_get /%s failed: %sN) r(r6lstriprequestsgetr/raise_for_statusjsonr&logdebug)rBrCr2urlres&&& rjs_getrTvs  z|B"a C 012 LL8:eW M vvx  )43sA A77 B#BB#c TV^8dQhR\R\R\R\R\/#)rrBdatarCr2rrrErDbool)rs"rrrs/  # T E 3 $ rc*T;'g \4p\V4 RVPR4 2p\P!WA\ 4RVR7pVP R8# \d"p\PRY4Rp?R#Rp?ii;i)z8POST to a JointSpace endpoint. Returns True on success.rGF)rNrHrIrCzjs_post /%s failed: %sN) r(r6rJrKpostr/ status_coder&rOrP)rBrVrCr2rQrRrSs&&&& rjs_postr]s|  z|B"a C 012 MM#xz%QX Y}}s""  *D4sAA&& B1B  Bc<V^8dQhR\R\R\/#)rkeyr2rrrX)rs"rrrs!55555rc"\RRV/VR7#)z Send a key press via JointSpace.z input/keyr_r5)r])r_r2s&&rjs_keyrbs ;  44rc VV^8dQhR\R\R\R\R,/#)raction body_innerr2rNr)rs"rrrs,#3C3:rcT;'g \4p\V4p\PVR7pRRRR\ RV R2/p\ P PW4P4VRR7p\ P PV^R 7;_uu_4pVP4P4uuR R R 4# +'giR #;i \d"p\PR Y4R p?R #R p?ii;i) zMSend a UPnP SOAP request to RenderingControl. Returns response body or None.)body Content-Typeztext/xml; charset="utf-8" SOAPAction"#POSTrVheadersmethodrCNzUPnP %s failed: %s)r(r@ UPNP_ENVELOPErUPNP_SVCurllibrequestRequestencodeurlopenr#decoder&rOrP) rdrer2rQrgrnreqresprSs &&& r _upnp_requestr{s  z|B B-C   Z  0D3(1VHA.Gnn$$S{{}gV\$] ^^ # #C # 3 3t99;%%'4 3 3 3  &2s7AC!C ? C C CC D )DD c>V^8dQhR\R\R,/#rr2rN)rint)rs"rrrs 5 53 5#* 5rcR\ R2p\RWR7pVfR#\P!RV4pV'gR#\ \ VP ^44\,^d, 4#)zGet current volume on the TV's native 0-VOLUME_MAX scale (matches the OSD). Reads UPnP RenderingControl (0-100) and rescales. Returns int or None.z0Master GetVolumer5Nz$(\d+))rrr{researchroundr~group VOLUME_MAXr2rgrzms& r get_volumers_$H:-p qD d 2D | 94@A  QWWQZ:-3 44rc<V^8dQhR\R\R\/#)rvolr2r)r~rrX)rs"rrrs!??C?S?D?rc\^\\V44p\V^d,\, 4pR\ RV R2p\ RW1R7RJ#)zfSet volume on the TV's native 0-VOLUME_MAX scale (matches the OSD). Rescales to UPnP 0-100 internally.z0Masterz SetVolumer5N)maxminrrrrr{)rr2upnprgs&& r set_volumersZ aZ% &C sZ' (D$XJ/"V#A CD d 2$ >>rc>V^8dQhR\R\R,/#r}r`)rs"rrrs...t .rcR\ R2p\RWR7pVfR#\P!RV4pV'dVP ^4R8H#R#)z/Get mute state via UPnP. Returns bool or None.z0MasterGetMuter5Nz (\d+)1)rrr{rrrrs& rget_mutersP !(+l mD D 0D | 5t0MasterzSetMuter5N)rrr{)rr2valrgs&& rset_muters:#CC"8*-5 : V^8dQhR\R\R,/#)rrCrNrDr)rs"rrrs555t5rc R\V4 R2p\P!\P\P\P4pVP \P \P^4VP\V^44VPVP4R4VPR4wr4VPRR7pRV9gRV9gRVP49gKKVP4\ P#R V^,4V^,VP4# \$d#i;i \P&dMi;iTP4MI \$dM.probese 002C NN " "&&(>'JK3 # O  sAA A+*A+z 192.168.1.) max_workerszProbe discovered TV at %sNz239.255.255.250il)r~socketAF_INET SOCK_DGRAM IPPROTO_UDP setsockopt IPPROTO_IPIP_MULTICAST_TTL settimeoutrsendtorvrecvfromrxlowercloserOinfor&rCrange concurrentfuturesThreadPoolExecutorsubmit as_completedresult)rCssdp_msgsockrVaddrtextri candidatespoolr2futsfrs& r discover_tvrsI  w<.!# # }}V^^V->->@R@RS ))6+B+BAF GQ( HOO%'@A !]]40 {{){4$(9T(AYRVR\R\R^E^JJLHH7aA7     ~~                -2!RL9LqJqc"L9J9    . .2 . > >$5?@Zr E&*Z@@##006AXXZFv4f= ? >6 ?  ? > sB;G>AE! 5E!?E EGEG!E96F8E99F=F FGFGG!F21G2 G=G?GGG GG(G7&J9+I?J9 J9-J99 K c$V^8dQhR\/#)rr2r)rs"rrr(s666rc,T;'g \4p\P!4p\4VnRVn\ V4 R2pVPVRR/^R7\P!R4\^4FpVPVRR/^R7K \P!R4VPVRR /^R7VPVRR /^R7R # \d"p\PR T4R p?R #R p?ii;i) zSToggle ambilight via menu navigation (AmbilightOnOff -> up 15x -> Confirm -> Back).Fz /input/keyr_AmbilightOnOff)rNrCg333333?CursorUpg?ConfirmBackzAmbilight toggle failed: %sN)r(rKSessionr/rHrIr6r[timesleeprr&rOwarning)r2srQ_rSs& rambilight_toggler(s  z|B 6    "j) s%!12A> 4rA FF3eZ0!F < 4 s%+Q7 s%!4 6 11556sCC'' D2DDc0V^8dQhR\R\/#)r off_durationr2r)rs"rrr;s5Crcb\VR7\P!V4\VR7R#)z+Toggle ambilight off, wait, toggle back on.r5N)rrr)rr2s&&rambilight_glitchr;sJJ|rc0V^8dQhR\R\/#r1r`)rs"rrrDs  C 4 rc6\V4p\P!RRV.RR^ R7pRVPP 49;'gRVPP 49# \ d"p\ PRT4Rp?R #Rp?ii;i) z0Connect to TV via ADB. Returns True on success.adbconnectTcapture_outputrrC connectedalreadyzadb_connect failed: %sNF)r; subprocessrunstdoutrr&rOrP)r2targetrRrSs& r adb_connectrDs _F NNE9f5*.T2 Gahhnn..OO)qxx~~?O2OO  *A.sAA,A,, B7BBcJV^8dQhR\R\R\R,/#)r output_pathr2rNr)rs"rrrPs&sUYzrc \V4p\V4\P!RRVRRRR.R^RR7\P!RRVR RV.R^RR7V# \d"p\ P R T4R p?R #R p?ii;i) zKTake a screenshot via ADB. Returns local path on success, None on failure.r-sshell screencapz-pz/sdcard/screen.pngT)rrCcheckpullzadb_screenshot failed: %sN)r;rrrr&rOr)rr2rrSs&& radb_screenshotrPs _F B D&';>R S4   D&&*> L4   /3sA A B&BBc0V^8dQhR\R\/#r1)rtuple)rs"rrrcsG G CG 5G rc &\V4p/p\P!RRVRRRR.RR^R7pR pVPP 4FQpR V9gK \ P !R V4pV'd'VP^4P4R!,pM R p\P!RRVRRR .RR^R7pR p VPP 4EFQpRV9dRp V 'EdaRV9EdYRV9dRpM RV9dRpV'Ed=\ P !RV4p \ P !RV4p \ P !RV4p V 'dV 'd\V P^44p \V P^44pV 'd\V P^44MRp\P!RRVRR.RR^R7p\\VPP4^,4R,4pVV, V,pV V,pV^8d\VR,4VR&V 'gEKRV9gEKRV9gEK\ P !RV4pV'dVP^4P4PR4PR4pVPR4Uu.uFpVP4NK ppV'd V^,VR&\V4^8d V^,VR&R p EKT WGV3# \dT ^8d T R,TR&ELi;iuupi \d#p\P!R T4R"uR p?#R p?ii;i)#zGet current foreground app, playback state, and extras via ADB. Returns (package_name, playback_state, extras_dict) where extras may contain 'title', 'artist', 'position_s'. Any element may be None on failure. rrrdumpsysactivity activitiesTrNtopResumedActivityz (\S+)/\S+ media_sessionFz active=truezstate=PlaybackStatePLAYINGPAUSEDzposition=(\d+)z updated=(\d+)zspeed=([\d.]+)?zcat /proc/uptimei position_sz metadata:zsize=zdescription=(.+?)(?:,\s*null)?$z, null,titleartistzadb_get_current_app failed: %s)NNN)r;rrr splitlinesrrrsplitr~rDr&r$rstriplenrOr)r2rextrasrRpkglinerstater2 found_activepos_mupd_mspd_mpos_msupdatedspeedup_r uptime_ms elapsed_ms real_pos_msdescppartsrSs& radb_get_current_appr(cs"_F?  NNE4%z<A*.T1 FHH'')D#t+IIlD1''!***,R0C * ^^UD&'&9+/dAG II((*D$# | 5 =$%E%$E5II&7>EII&6=EII&7>E!$U[[^!4"%ekk!n"59>ekk!n 5C F#->>!&fg?Q R/3$$KD),E$++2C2C2Ea2H,ID,P(QI*3g*=)FJ*0:*=K*Q7:;$;N7O| 4| t 34II@$G771:++-44X>EEcJD04 3@1QWWYE@*/(w5zA~+08x($ K+N6!! )F%z7=~| 4FA   4a8 sAM#M#7A=M#5#M#A M#&M#.AM#BL9M# M#*M#4M#AM##M<'*C*,\!R+-uB NB"&&w/  NNE4G {Rghj*. <tVW",WI5d e g.2B@A||q tVW",WI5[ \ ^.2B@  /3sAB:#AB:: C&C!!C&c VV^8dQhR\R\R\R\R,/#rrorBrVrNr)rs"rrrs,3crcRV 2pV'd%\P!V4P4MRp\PP W4RR\ 2RR/VR7p\PPV^ R7p\P!VP44# \d#p\PR YT4Rp?R#Rp?ii;i) z5Call HA Supervisor API. Returns parsed JSON or None.http://supervisor/core/apiN AuthorizationBearer rhapplication/jsonrmrpzha_api %s %s failed: %s rNdumpsrvrsrtruSUPERVISOR_TOKENrwloadsr#r&rOrProrBrVrQrgryrzrSs&&& rha_apir<s*4&1,0tzz$&&(dnn$$ 7+;*"2$ 79'+$ 8 huc8T:fc5usmz3 & * '+$  8 !D NND(E5#xz &#u#T5UG3-#T:sF#T7CIx$f . +/d  <! huc8T:fc5'4 ' x9'+$ 8  /3s%E"D!E"" F-F  Fc<V^8dQhR\R\R\/#)r sound_filerrrrDrX)rs"rrras!3rc \RRRRRV/4\RRRRRRR R V 2/4R # \d"p\PR T4R p?R#R p?ii;i)zFPlay a sound file on the Xiaomi Sound Pro speaker via HA media_player.rlz!/services/media_player/volume_setrDzmedia_player.sound_pro_1264 volume_levelz!/services/media_player/play_mediamedia_content_typemusicmedia_content_idz!http://192.168.1.187:8888/sounds/Tzspeaker_play_sound failed: %sNF)r<r&rOr)rrrSs&& rspeaker_play_soundrasw v: 6 F=   v: 6 ' "CJ< P=    3Q7s'+ AAAc$V^8dQhR\/#rrX)rs"rrr~s   rcRp\P!RRRRVR.RR7R# \d"p\P R T4R p?R #R p?ii;i) z7Remove all tc throttle rules. Returns True on success.rgrhrirjrkrlTrmzthrottle_remove failed: %sNF)rrr&rOr)rkrSs rthrottle_remover~sO CgueS&A&* ,  0!4s$ AA  Az$/share/.ha_cache/.lounge_tokens.jsonYongWahzAhttps://www.youtube.com/api/lounge/pairing/get_lounge_token_batchz*https://www.youtube.com/api/lounge/bc/bindz'urn:dial-multiscreen-org:service:dial:1c$V^8dQhR\/#rrE)rs"rrrsTrc\\4;_uu_4p\P!V4uuRRR4# +'giR#;i \\P 3d/u#i;ir+)r!LOUNGE_TOKENS_PATHrNloadFileNotFoundErrorJSONDecodeError)rs r_lounge_load_tokensrsM $ % %99Q<& % % % t33 4 s+A: A A A AA.-A.c(V^8dQhR\RR/#)rtokensrNr)rs"rrrs((((rcX\P!\PP\4RR7\R,p\ VR4;_uu_4p\ P!W^R7RRR4\P!V\4R# +'giL-;i)T)exist_okz.tmpw)indentN) osmakedirsrBdirnamerr!rNdumpr)rtmprs& r_lounge_save_tokensrs_KK 23dC v %C c31 &A& JJs&' s B B) chV^8dQhR\R\\\\3,,/#rrCr)rDrArr)rs"rrrs'UT%S/-BrcR\ R2P4p\P!\P\P4pVP \P \P^4VPV4.pVPVR 4\P!4V,p\P!4V8dVPR4wrVRpTPRR7P4FQpTP4P!R4'gK*TP#R^4^,P%4pM T'gKTP'T^,T34KVP)4V# \PdK*i;i TP)4i;i) zJSSDP M-SEARCH for DIAL services on LAN. Returns [(ip, location_url), ...].zRM-SEARCH * HTTP/1.1 HOST: 239.255.255.250:1900 MAN: "ssdp:discover" MX: 3 ST: z rNignorerz location:r9r) DIAL_SSDP_STrvrrrr SOL_SOCKET SO_BROADCASTrrrrrCrxrr startswithrr$rGr) rCmsgrfounddeadlinerVrlocrs & r_ssdp_find_dialrsa n    fh ==):): ;DOOF%%v':':A>OOG E C2399;(iikH$ !]]40 C 8 4??A::<**;77**S!,Q/557CBs d1gs^, L>>   s>AF6F+AF670F6,F6F3/F62F33F66Gc>V^8dQhR\R\R,/#)r location_urlrNr)rs"rrrsSS4Zrc\P!V^R7pVP4VPPR4# \d"p\ P RY4Rp?R#Rp?ii;i)zDFetch DIAL device description and return the Application-URL header.rpzApplication-URLz!DIAL desc fetch failed for %s: %sN)rKrLrMrnr&rOr)rrRrSs& r_dial_get_apps_urlrsY LLq 1 yy}}.//  7IsAA A1A,,A1c>V^8dQhR\R\R,/#)rapps_urlrNr)rs"rrrs##*rcVPR4R,p\P!V^R7pVP^8wdR#\P !RRVP ^R7p\P!V4pVPR4pVe-VP 'dVP P4#R# \d"p\PR T4Rp?R#Rp?ii;i) zGET /YouTube and parse from the response. YouTube must be running in the foreground for screen_id to be exposed. Returns None if YouTube isn't running or DIAL doesn't expose YouTube.rGz/YouTuberpNz\sxmlns="[^"]+"r)countz .//screenIdzDIAL YouTube probe failed: %s)rrKrLr\rsubr_ET fromstringfindr$r&rOr)rrQrRrgrlsid_elrSs& r_dial_get_youtube_screen_idrs //#  +C 8 LLa ( ==C vv("affA>~~d#=)  &+++;;$$& &  8 3Q77 8s$)CA C&C C. C))C.philipscJV^8dQhR\R\R\R,/#)rrd screen_namerNr)rs"rrrs&---#-dUYk-rc Rp\RR7F"wr4W08XgK \V4pV'gK"M V'gRV R2p\V4pV'g\P RV4R#\ P !\RV/^ R7pVP4VP4PR .4pV'gR#V^,PR 4pV'gR#R TR TRTR\\P!44/p \4p YT&\T 4\P!RYTR,4T # \d"p \P R T 4Rp ? R#Rp ? ii;i)uDiscover the TV's DIAL service, fetch the YouTube screen_id while the YouTube app is foreground, and exchange it for a long-lived lounge_token. Persists the result to LOUNGE_TOKENS_PATH under `screen_name`. Silent on TV — no code displayed, no popup. Returns the token entry dict, or None if pairing failed (e.g. YouTube not running). Must be called when YouTube is actually visible on the TV, otherwise DIAL returns 404 for /apps/YouTube.N@rpr>z :8008/appszElounge_pair_via_dial: no screen_id (YouTube must be foreground on %s) screen_ids)rVrCscreens loungeTokenz"lounge pairing exchange failed: %s screen_id lounge_tokenrd paired_atz*lounge paired: screen=%s tv=%s token=%s...NN)rrrrOrrKr[LOUNGE_PAIRING_URLrMrNrLr&r~rrrr) rdrrr2rrrRrrrSentryrs && rlounge_pair_via_dialrsNH"3/ ;)#.Hx 0 UG:.+H5I  []bc  MM, ,i8"$ & &&(,,y"-qz~~m4  Y S%  E ! "F;HH 9;|\^O_` L  8!<s/AE E E6E11E6c VV^8dQhR\R\R\R\R,/#)r pairing_coderrdrNr)rs"rrrs....#.!$.15.rc \P!RRT;'gR4p\V4^ 8wd"\P R\V44R#\ P !RRV/RRR R /^ R 7pVP^8wd5\P R VPVPR ,4R#VP4pTPR4;'g/pTPR4pTPR4p T'd T 'g0\P R\TP444R#RTRT RTR\\P!44RR/p \!4p YT&\#T 4\P%RYR,4T # \d"p\P RT4Rp?R#Rp?ii;i)uExchange a 12-digit YouTube TV pairing code for a long-lived lounge_token. Used when DIAL discovery doesn't expose YouTube (modern Google TVs / Cast V2 devices). User reads the code from TV → Settings → Watch on TV → "Link with TV code", then passes it here. Code is single-use and expires in ~5 minutes, but the resulting lounge_token is good for months/years. Accepts code with or without dashes (e.g. "123-456-789-012" or "123456789012"). Returns the persisted token entry, or None on failure.z[^0-9]rz>lounge_pair_with_code: bad code length %d (expected 12 digits)Nz5https://www.youtube.com/api/lounge/pairing/get_screenrzX-YouTube-Client-NamerzX-YouTube-Client-Versionz2.0)rVrnrCz!lounge get_screen returned %d: %s:NNz(lounge_pair_with_code request failed: %sscreenscreenIdrz$lounge get_screen missing fields: %srrrdrrocodez-lounge paired via code: screen=%s token=%s...r)rrrrOrrKr[r\rrNr&rLrAkeysr~rrrr) rrrdrrRrVrSrrrrrs &&& rlounge_pair_with_coders 66)R!3!3 4D 4yB TVYZ^V_`  MM C $',c3MuU   ==C  KK;Q]]AFFSWL YvvxXXh  % %2F :&I::m,L , :DBsA#F&:F&& G1G  Gc>V^8dQhR\R\R,/#rrrNr)rs"rrrMs22#2dTk2rc4\4PV4#)z"Return cached token entry or None.)rrLrs&rlounge_get_tokenrMs  $ $[ 11rc(V^8dQhR\RR/#rr)rs"rrrRs  C  rcT\4pVPVR4\V4R#r+)rpopr)rrs& rlounge_clear_tokenrRs "F JJ{D!rchV^8dQhR\R\\\\3,,/#)rrr)rrArobject)rs"rrrXs("""U3;-?(@"rc.p^pV\V48EdVPRV4pV^8dV#\WVP44pY^,T^,T,pT^,T,p\ P !T4pTFp\T\4'd.\T4^8d\T^,\4'gKHT^,pT'gK[T^,p \T4^8Xd T^,MTR,p TPY34K EK*V# \dT^,pEKDi;i \ PdEKai;i)aZParse YouTube Lounge /bind chunked response. Format: lines alternate between length count and JSON payload. Payload is an array of [event_id, [event_type, ...event_data]] entries. We flatten those to (event_type, event_data) tuples, where event_data is whatever follows event_type in the inner array (single value if one item, list if multiple). :NN) rrr~r$ ValueErrorrNr:r isinstancerArG) routrnlnchunkarrrinneretypeedatas & r_lounge_parse_chunkedrXsB C A c$i- YYtQ  6 * J) D2J$$&'A!VR!VaZ( FQJ **U#CEud++E aJuUVxY]D^D^!HE!HE #E aE!HU2YE JJ~ & J% QA  ##   s#D18E 1E  E  E'&E'c*a]tRtRtoRtRV3RlRlltV3RlRltV3RlRltR V3R lR lltR V3R lR llt R!V3RlRllt R"V3RlRllt V3RlRlt R#V3RlRllt V3RlRltV3RlRltV3RlRltR$V3RlRlltRtVtR #)% LoungeSessioni}u%Minimal sync YouTube Lounge client. Connect → send commands → optionally poll for state. Not async — designed to run inside a sandman action thread. Does NOT keep a long-poll open continuously; we sip state on demand around each setPlaylist call (enough for cycle-on-failure detection).c <V^8dQhRS[/#rrr)r __classdict__s"rrLoungeSession.__annotate__s&'&'C&'rcBWn\V4pV'g\RV R24hVR,VnVR,VnVP R4pV'g;R\ P!^4,pW2R&\4pW$V&\V4W0n \P!4Vn RVnRVnRVn/Vn\ P$!RR 4VnR VnRVnR Vn\.P0!4VnR#) zno lounge token for screen 'z!'; run lounge_pair_via_dial firstrr device_idz%032xNri'iF)rr RuntimeErrorrrrL_random getrandbitsrrrrKrsessionsid gsessionidaid now_playingrandint_rid last_event_atcontent_video_id ad_active threadingRLock_lock)selfrrrrs&& r__init__LoungeSession.__init__s& -!=k]Jklm m{+!.1IIk* '"5"5c"::I!*+ (*F"';   '"'') OOE51 ! $ __& rc <V^8dQhRS[/#rr)rrs"rrrs3rc^V;P^, un\VP4#)r)r rrs&r _next_ridLoungeSession._next_rids Q 499~rc$<V^8dQhRS[RR/#)reventsrNr@)rrs"rrrs--d-t-rcV'd\P!4VnVEF-wr#VR8Xd1\V\4'dV'd V^,MRVnK=VR8Xd W0nKLVR8Xd|\V\ 4'dfRF pWC9gK W4,VPV&K" VP'd,VPR4VP8Xd RVn KKKVR8Xd@\V\ 4'd*RF pWC9gK W4,VPV&K" EKVR8Xd\V\ 4'dVPR4pV'dVPPRV4VPR4pV'd=RVP9d)VPR 4^,VPR&EKEKEKVR 8Xd_\V\ 4'dIVPR 4pV'd-WpnR Vn VPPRV4EK EK#VR 8XgEK-EK0 R#)cNS nowPlayingvideoIdF onStateChangeplaylistModifiedvideoIdsr onAdStateChangecontentVideoIdTnoop)r currentTimerr[listId)r%rr[) rr rrArrrErr rLr  setdefaultr)rrrrkvidvidscvids&& r_absorbLoungeSession._absorbs !%D "LE| 5$ 7 7',58$#"',&:eT+B+BRAz.3h((+S )))!IIi0D4I4II%*DNJ*/)j.E.E=Az.3h((+>,,E41H1Hii *$$// 3?yy,IT-=-==26**S/!2DD$$Y/>4++ 5$0G0G yy!12,0)%)DN$$// 4@  &U#rc&<V^8dQhRS[RS[/#rrDrX)rrs"rrrs111$1rc PVP;_uu_4VPP4\P !4VnRVnRVnRVnRVn VPVR7uuRRR4# \dL_i;i +'giR#;i)aTear down a dead session and re-bind on the same lounge_token. Used to recover from `LoungeSessionDead` without re-pairing via DIAL. Issues a fresh SID/gsessionid; existing long-polls on the old SID will return 400 once and unwind cleanly. Returns True on success.Nrrrp) rrrr&rKrrrrr rrrCs&&r reconnectLoungeSession.reconnects ZZZ  ""$$++-DLDH"DODH!$D <<<0Z  ZZs.BBAB BBBB B% c&<V^8dQhRS[RS[/#rr/)rrs"rrrsDDuDDrc RVP4RRRRRRR\R R R VPR VP/pR VPRRRR/pVPP \ VRW1R7pVPR8Xd \R4hVP4VP\VP44VPRJ;'dVPRJ#)zDOpen a session. Returns True on success. Captures now-playing state.RIDVER8CVERrdeviceREMOTE_CONTROLrJappzyoutube-desktop loungeIdTokenidX-YouTube-LoungeId-Tokenrh!application/x-www-form-urlencodedOriginhttps://www.youtube.comzcount=0paramsrVrnrClounge token rejected (401)N)rLOUNGE_DEVICE_NAMErrrr[LOUNGE_BIND_URLr\LoungeAuthErrorrMr,rrrrrrCrDrnrRs&& rrLoungeSession.connects 4>># 3 C & & $ T.. $..   '(9(9 ? /  LL  of#,g  P ==C !"?@ @  *16623xxt#CCt(CCrNc@<V^8dQhRS[RS[R,RS[RS[/#)rcommandrDNrCrrW)rrs"rrr s.TD[%Z^rc T;'g/pRVP4RRRRRVPRVPRVP/pRRR R R V/pVP 4Fwrg\ V4VR V 2&K R VPRRRR/pVP ;_uu_4VPP\VWXVR7p V PR8Xd \R4h\V 4V P4V P'd&VP\!V P44RRR4R# \"dLi;i +'giR#;i)r6r7r8r9rSIDrr=rofsrreq0__screq0_r?rhr@rArBrCrErFNT)rrrritemsrrrr[rHr\rI_lounge_check_deadrMrr,rr&) rrMrDrC url_paramsformr(vrnrRs &&&& r_commandLoungeSession._command sJ2 4>># 3 C 488 $// T..  eS*g>LLNDA #AD5 # '(9(9 ? /  ZZZ !!/*'+g"OA}}#%&CDD q !   vvvLL!6qvv!>?!Zs+A-E  $D;; E E E  E  E c,<V^8dQhRS[RS[RS[/#)rvideo_id current_timerr)rrs"rrr*s"  S   rcPVPRRVR\V4RRRRRRR R/4#) setPlaylistrr% currentIndexz-1 audioOnlyfalserDr playerParamsrXr)rr[r\s&&&r set_playlistLoungeSession.set_playlist*s=}}] x 3|, D  b B -   rc <V^8dQhRS[/#rr)rrs"rrr4s&&T&rc <VPpVPR4\^4F)pTPRR7TPT8gK)M \TP4# \dp\P RT4TP 4TPpRp?L \ d;p\P RT4\TP4uRp?uRp?#Rp?ii;iRp?i\ dLi;i \dKi;i)umBest-effort current-state read. Asks the receiver to broadcast and polls briefly, but this TV's YouTube often doesn't echo state to getNowPlaying — so we fall back to whatever connect() captured (the receiver's snapshot at session-start, which is usually the most-recent real video and our best resume target). Returns {} only if connect() also captured nothing. getNowPlayingu(request_now_playing: %s — reconnectingz!request_now_playing reconnect: %sN@rp) r rXLoungeSessionDeadrOrr2r&rErr poll_state)rprerSe2rs& rrequest_now_playing!LoungeSession.request_now_playing4s    MM/ *qA ,!!C' D$$%%%! . KKBA F . (( . ?DD,,--- .    %  sdA,D , D7C7B// C4:*C/$C4%C7)D/C44C77 DDD DDc2<V^8dQhRS[RS[RS[RS[/#)rr[r\verify_timeoutrr)rrs"rrrSs1BBcBB.3B>BBrc  VPpVPW4\P!4T,p\P!4T8dWTP\R\RT\P!4, 44R7TPT8gKnR#TPY4\P!4T,p\P!4T8dWTP\R\RT\P!4, 44R7TPT8gKnR#R # \dh\dp\P RT4TP 4TPY4TPpRp?EL \dh\d&p\P RT4Rp?Rp?ELRp?ii;iRp?i\d"p\P RT4Rp?ELRp?ii;i \dEKi;i \dh\dp\P R T4TP 4TPY4TPpRp?EL \dh\d&p\P R T4Rp?Rp?ELRp?ii;iRp?i\d"p\P R T4Rp?EL9Rp?ii;i \dR #i;i) usetPlaylist with belt-and-suspenders delivery. We can't reliably "verify" the command because this TV's YouTube receiver accepts and renders setPlaylist but does NOT always echo state back through the Lounge channel — so a successful command still looks "silent" to us. Strategy: send once, poll briefly for any fresh receiver event. If we got fresh activity, assume warm and return True. If silent, the link MIGHT be cold (or just non-echoing); send a second time as a warmup — empirically the second command often sticks when the first didn't. Returns True if at least one attempt produced fresh events (link confirmed warm), False if both attempts were silent. Callers should treat False as "link probably cold, but the command may still have landed" — log it but don't abort.u1set_playlist_verified send 1: %s — reconnectingz,set_playlist_verified reconnect+resend 1: %sNz set_playlist_verified send 1: %sr g?rpTu1set_playlist_verified send 2: %s — reconnectingz,set_playlist_verified reconnect+resend 2: %sz set_playlist_verified send 2: %sF) r rdrIrjrOrr2r&rrkrr)rr[r\rqrlrSrmrs&&&& rset_playlist_verified#LoungeSession.set_playlist_verifiedSs_    ?   h 599;/iikH$ CS(TYY[:P1Q(RS!!C' ?   h 599;/iikH$ CS(TYY[:P1Q(RS!!C'_   P KKKQ O P !!(9(("  P JBOO P ? KK:A > > ? %     P KKKQ O P !!(9(("  P JBOO P ? KK:A > > ? %   sE AH,H.4AK> H H!G)8-F++G&G&G!G)!G&&G)) H6H7HH H+*H+.K;K;K -JK #K $K:K K  K  K;K;K66K;> L  L c <V^8dQhRS[/#rr)rrs"rrrs%%d%rc$VPR4#)playrXrs&rrwLoungeSession.plays}}V$$rc <V^8dQhRS[/#rr)rrs"rrrs&&t&rc$VPR4#)pauserxrs&rr|LoungeSession.pauses}}W%%rc&<V^8dQhRS[RS[/#)rr\rr/)rrs"rrrsGGEGdGrc<VPRR\V4/4#)seekTonewTimerc)rr\s&&rseek_toLoungeSession.seek_tos}}X 3|3D'EFFrc&<V^8dQhRS[RS[/#r)rDrE)rrs"rrrs**%*$*rc HRRRVPRRRVPRRR VPR R R R RVP/ pRVPRR/pVP;_uu_4VP P \VW1R7p\V4VP'd%VP\VP44\TP 4uuRRR4# \P\P3dLFi;i +'giR#;i)zOne-shot long-poll for state events. Updates now_playing in place and returns a copy. Returns whatever's accumulated even on timeout.r6rpcrOCIrAIDTYPExmlhttprr7r8r9rr=r?rArB)rDrnrCN)rrrrrrrLrHrTrr,rrKTimeoutConnectionErrorrErrJs&& rrkLoungeSession.poll_states 5 488 # 488 I $// 3 C T..   '(9(9 / ZZZ LL$$_V-4%G"1%666LL!6qvv!>?(()Z$$h&>&>?  ZZs1!D#A#C%D%%D  D D  D D! )rr r rr rrr rrrrrrrg$@)Ng @)r)rg@r)__name__ __module__ __qualname____firstlineno____doc__rrr,r2rrXrdrnrsrwr|rrk__static_attributes____classdictcell__rs@rrr}sF &'&'P--^11"DD2B  &&>BBH%%&&GG***rrc]tRtRtRtRtR#)rIizN>N=O.PR  rc<V^8dQhRR/#rr.)rrs"rrrsdrc:VPP4R#r+)rsetrs&rstopLoungeKeeper.stops rc&<V^8dQhRS[RS[/#rr/)rrs"rrrs11%141rc:VPPVR7#)rp)rwaitr1s&&r wait_readyLoungeKeeper.wait_readys{{00rc<V^8dQhRR/#)rrzLoungeSession | Noner.)rrs"rrrsKK3Krc zVP'd)VPP'd VP#R#)zReturn the live session if connected, else None. Caller should check before sending and fall back to a fresh session if absent.N)rrrs&r get_sessionLoungeKeeper.get_sessions* $||| 0@0@0@t||JdJrc<V^8dQhRR/#rr.)rrs"rrrs#/#/d#/rcNRpVPP4'Eg \VP4'g3\P R4VPP ^<4Ko\VPR7pVP4W n VPP4\P RVP4RpVPP4'g0VPRR7VPP R4KOEK)R# \d=\PR4RTn TPP ^x4EKq\ dGp\P R T4RTn RpTPP ^4Rp?EKRp?i\"dXp\PR Y14RTn TPP T4\%T^,^<4pRp?EKRp?ii;i) riz'LoungeKeeper: no token cached; sleepingrz LoungeKeeper: connected (sid=%s)g>@rpg?u.LoungeKeeper: token rejected — needs re-pairNz(LoungeKeeper: %s; re-binding immediatelyz'LoungeKeeper: %s; reconnecting in %.0fs)ris_setrrrOrrrrrrrrrkrIrrjr&r)rbackoffsessrSs& rrLoungeKeeper._runs**##%% /'(8(899HHFGJJOOB'$1A1AB #  !;TXXF **++--OODO1JJOOC(.#&(# % LM#  $$$ #CQG#  "" / EqR#  (gk2.  /sEA D.2BD.:/D..AH$4H$=H$>:F?? H$ H$ A HH$c$<V^8dQh/R;R&#)rzLoungeKeeper | Nonerr.)rrs"rrrs%+r)rrrrrrr)rrrrrrr Lockrr classmethodrLrrrrr__annotate_func__rrrs@rrrs} B(,I^^%N((!!!11KK #/#/grrc0V^8dQhR\R\/#)rrr)rr)rs"rrr-s))S))rc,\PV4#)uStart (or return) the background keepalive that holds the TV's Lounge subscription warm. Idempotent — safe to call multiple times.)rrLrs&rlounge_keeper_startr-s   K ((rrc vV^8dQhR\R\R\R\R\\\3,/#)rr[r\rrdr)rrDrrXrE)rs"rrr3s;c14+.;@t;Lrc\VR7pVP4'gR/3#VPW4RVPRR73# \d\ P RT4\Y2R7'd\TR7pTP4'gR/3u#TPY4RTPRR73u# \d!p\ P RT4R p?MR p?ii;iR/3u#\\P3d%p\ P R T4R/3uR p?#R p?ii;i) aConvenience wrapper: connect, send setPlaylist, return (ok, now_playing). On 401 (rotated token), re-pair via DIAL once and retry. Used by the sandman ad-break action; logs to standard tv_control logger so the Telegram bot's /lounge command can surface activity.rFTrrpu3lounge token rotated for %s — re-pairing via DIAL)rdrz%lounge retry after re-pair failed: %sNzlounge_set_playlist failed: %s) rrrdrkrIrOrrr&rrKRequestException)r[r\rrdrrSs&&&& rlounge_set_playlist_with_repairr3s5||~~"9  (1T__S_111   I;W e E E H$=||~~ "9$!!(9T__S_999 H CQGG Hby (33 4 4a8bysd%A $A 3E%C&E)$C E C;C61E6C;;EEED=7E=Er+)N)g@)g@N)z/tmp/tv_screen.pngN)Ni)g333333?)z knock_2.mp3zcough_single.mp3zthroat_final2.mp3ztongue_click.mp3zcustom_20to22.mp3zexhale_loud.mp3zexhale_soft.mp3rr)drconcurrent.futuresrrNloggingrrrrrr rurllib.requestrsrK requests.authrurllib3disable_warnings exceptionsInsecureRequestWarning getLoggerrOr%r,r-r?rrrqr: APP_NAMESr9r!_f_linerr$rr&r"r(r/r6r;r@rTr]rbr{rrrrrrrrrrrrr(r/r<rKrYr`r]rrSPEAKER_SOUNDSrrrGrrHrrandomrxml.etree.ElementTreeetree ElementTreerrrrrrrrrrrrrIrjrTrrrr.rrrs   (++BBC  %  P  <+$Y'I)!?& *F#V +JY)i  & & ' '2E 344#(;;=#6#6sA#>q#A  (.  5" % E  5,  5?.=K5t6& &G TD(   74,-`$ &<X>8 ##(D*', -`AJ',.b2  "J~*~*B  i   LV/V/r) JM7@16[' ( ' '  s6$J84J$+J$>J8$ J5 /J85J88KK