U ‹pÙjÙ<ã@s0dZddlZddlZddlZddlmZmZddlmZddlm Z ddl Z ddl Z ddl m Z mZddlmZddlmZdd lmZdd lmZdd lmZe  d ¡Zeeeeƒ d ¡ƒƒZej  d¡dkZ!dd„Z"dd„Z#dd„Z$dd„Z%dd„Z&dd„Z'dd„Z(dd„Z)e*d œd!d"„Z+dd#œd$d%„Z,dS)&zsHermes LMP V5 runtime. Python 3.8+. No credentials stored here. Safe by default: dry-run unless HERMES_LMP_LIVE=1. éN)ÚdatetimeÚ timedelta)ÚPath)Úurlsplit)ÚasociarÚ identificar)Úvalidar_asociaciones)Úobtener_inventario)Úextraer_playlist)Ú planificar)Ú StateStorezAmerica/Tijuanazhermes_lmp_v5_live_state.jsonZHERMES_LMP_LIVEÚ1cCsL| d¡}|stdƒ‚t t|ƒ dd¡¡}|jdkrBtj  |¡}|  t ¡S)zRUTC oficial del EPG -> hora con zona; no reinterpretar localFullDate como Tijuana.Z utcFullDatez?Partido sin utcFullDate; no se autoriza inicio por hora ambiguaÚZz+00:00N) ÚgetÚ ValueErrorrÚ fromisoformatÚstrÚreplaceÚtzinfoÚpytzZUTCZlocalizeZ astimezoneÚTZ)ÚgameZutcZdt©rúhermes_lmp_v5_runtime.pyÚ _inicio_epgs   rc s¬tj|d|d||ddœdddd ˆ¡igd œd d }| ¡| ¡}d d „| dg¡Dƒ}t|ƒdkrrtdƒ‚‡fdd„|d dg¡Dƒ}t|ƒtˆƒkr¨tdƒ‚|S)Nú /api/actionúapplication/jsonz /config/lmp©Ú Authorizationz Content-TypeZOriginZRefererZ getstatusÚlmpÚIdú,)ÚActionÚ ProviderIdÚStreamsé©ÚheadersÚjsonÚtimeoutcSsg|]}| d¡dkr|‘qS)r r©r)Ú.0ÚprrrÚ +sz_getstatus..Z ProvidersézProveedor LMP ambiguocs$i|]}| d¡ˆkr|d|“qS)r r*©r+Úc©ÚidsrrÚ .sz_getstatus..rr$z#Inventario y getstatus no coinciden) ÚhttpxÚpostÚjoinÚraise_for_statusr(rÚlenÚ RuntimeErrorÚset)ÚhostÚauthr2ÚresponseÚdataZ providersÚfoundrr1rÚ _getstatus#s( þÿü r@c sÊtj|dd|idd}| ¡dd„t|jƒDƒ}i}| ¡D]d\}}t|ƒ‰‡fdd„|Dƒ}t|ƒdkrztd |ƒ‚|d d } t | ƒj d krœtd ƒ‚| ||<q@tt |  ¡ƒƒt|ƒkrÆtdƒ‚|S)Nz /playlist.m3uré)r'r)cSs&g|]}|d ¡ ¡ d¡r|‘qS)Únamez[lmp])ÚstripÚlowerÚ startswithr/rrrr-7sÿz'_validated_playlist..cs,g|]$}tˆƒdkrt|dƒˆkr|‘qS)érB)r8rr/©Zteamsrrr-<s r.zM3U ambigua para rÚurl)ZhttpZhttpsz URL invalidazURLs duplicadas) r4rr7r ÚtextÚitemsrr8r9rZschemer:Úvalues) r;r<Ú inventoryr=ZchannelsÚresultÚcidrBÚmatchesrHrrGrÚ_validated_playlist4s     rPcCs`|d||ddœ}dD]:}tj|d||ddœdd }| ¡|d krt d ¡qt d ¡dS) Nrz/config/lmp?type=liver)ÚchannelsupdaterequestZchannelsupdateapplyrr)r"r#r%r&rQé)r4r5r7ÚtimeÚsleep)r;r<r'Úactionr=rrrÚ_refresh_providerHsÿ ÿ rVcCstt| dd¡ƒt| dd¡ƒ}}t|ƒdksJt|ƒdksJt||BƒdkrNdSt| dd¡ƒdd t||Bƒ¡S)NZ awayTeamShortÚZ homeTeamShortr.rFZ localFullDateú|)rrr8rr6Úsorted)rZawayÚhomerrrÚ_keyTs"(r[c Cs|d}|D]î}|d}| d¡}| |ddddgdddœ¡}|d|d <| ¡|d <t|ƒ ¡|d <|d krº| d ¡dkr| ¡|d<d|d<d|d <| dd¡d|d<| ¡|d<q |dkrÜd|d <d|d<d|d<q |dkr | d ¡dkr d|d <q dS)NÚgamesÚ _hermes_keyÚ gameStatusÚunknownrF)ÚstatusÚfirst_final_seenÚfinal_confirmationsÚlast_final_seenÚstart_attemptsÚpreparedÚstop_confirmedÚ_hermes_channelÚ channel_idÚ last_seenÚstart_atrFr`Úfinalrarbr.rcÚliveZ scheduledT)rÚ setdefaultÚ isoformatr) r>reZ status_mapÚnowr\rÚkeyÚcodeÚrecrrrÚ_apply_observation[s8  ý     rscCsLtj ¡sdiiSt tjjdd¡}t|tƒr@t| d¡tƒsHt dƒ‚|S)zDNever silently replace damaged persistent state with an empty state.r\zutf-8)ÚencodingzEstado V5 invalido) ÚSTATEÚpathÚexistsr(ÚloadsZ read_textÚ isinstanceÚdictrr)r>rrrÚ_strict_snapshotzs  r{c Csêtƒd}| ¡D]Ð\}}| d¡}| |¡} | dkr:q|  d¡} | dg¡} | r"| d d¡dkr"| d} z|t | d ¡ ¡} Wn&tttfk r²td |ƒ‚YnX| d kræ|| d fd d„}t   |¡|d|ƒn<| dkr"| dkr"|| d fdd„}t   |¡|d|ƒ| d¡p0i}| d¡dkrz|t |d ¡ ¡} Wn(tttfk r‚td|ƒ‚YnX| dkr²|fdd„}t   |¡|d|ƒq| d kr| dkr|fdd„}t   |¡|d|ƒqdS)zJResolve uncertain commands from observed O11 state, not from HTTP outcome.r\rhNÚRunningrdéÿÿÿÿr`©ÚreservedÚsentrSz$Intento pendiente sin fecha valida: TÚattemptcSs<|d|dd}| d¡|kr8| d¡dkr8d|d<dS)Nr\rdr}rr`r~Ú confirmedr*©ÚdÚkZnumberÚarrrÚconfirm•sz#_reconcile_pending..confirmzHERMES V5 RECUPERADO START FéZcSs<|d|dd}| d¡|kr8| d¡dkr8d|d<dS)Nr\rdr}rr`r~Ú unconfirmedr*rƒrrrÚfailsz _reconcile_pending..failzHERMES V5 START NO CONFIRMADO Ústop_operationz!STOP pendiente sin fecha valida: cSs<|d|}| d¡pi d¡dkr8d|dd<d|d<dS)Nr\r‹r`r~r‚Trfr*©r„r…ÚrrrrÚstop_okªs  z#_reconcile_pending..stop_okzHERMES V5 RECUPERADO STOP cSs4|d|}| d¡pi d¡dkr0d|dd<dS)Nr\r‹r`r~r‰r*rŒrrrÚ stop_fail²s z%_reconcile_pending..stop_failzHERMES V5 STOP NO CONFIRMADO ) r{rJrrrÚ total_secondsrÚ TypeErrorÚKeyErrorruÚ actualizar)r;r<ÚstatusesroÚlogÚsnapshotrprrrNÚchannelÚrunningÚattemptsÚlastZager‡rŠÚstoprŽrrrrÚ_reconcile_pending„sH             rœ)r•c$ snt t¡‰|d d¡|d}}|d dg¡|d dg¡}t||ƒ}t||t|ƒƒ‰t||ƒ}i} ˆ  ¡ˆt dd  ¡fD]} |   t ||||   ¡ƒ¡q„g‰|D]L} t| ƒ‰ˆ| krªt| ƒ} ˆ| ˆ| d <| d <t| ƒ  ¡| d <ˆ | ¡qªˆs |d ƒd St ‡‡‡fdd„¡t||ˆˆ|ƒtƒd} d}ˆD]¶} | d | d ‰}t| ƒ}|t ddˆkoŠ|t ddkn}|  d¡dkoÌ|t ddˆkoÈ|t ddkn}|sÞ|sÞqB| ˆ}| d¡sB| d¡dkrqBtr:|s:t||ƒt||ƒ}t||t|ƒƒ‰d}t|||ƒ}t||ƒ}| ˆ¡|krltdˆƒ‚|ˆ}tr°|d ¡D](\}}|t||ƒkr†|||d<q†trÞ|| ˆ<|| d <t ˆ|f‡fdd„ ¡|dˆtrðd nd!ƒqBtƒd} i}ˆD]P} | d ‰| ˆ}| d"| d ¡}ˆ |i¡}t|| d#¡| d$¡d%|ˆ<qtˆ| |ˆƒ}|D]ô}|d&|d'‰}| ˆ}|| d"¡ksr| d¡s²qr|d(d)krê| d*g¡}|rê|d+ d¡d,krêqr|d(d-kr| d.¡rqr|d(d-krX| d/d0¡d1kr,qr| d2¡}|rrˆt |¡ ¡d3krXqrtsz|d4|d(d5ˆƒqrd0d6lm }| d7¡‰ˆr¸‡‡‡fd8d9„}t |¡sÖqrn‡‡fd:d;„} t | ¡sÖqr|||dd< !|d(|¡t|||gƒ| d#¡}!|d(d)k}"|!|"k r6td=|d(d5|ƒ‚‡‡fd>d?„}#t |#¡|d@|d(d5ˆƒqrd S)AzBOne synchronous scheduler tick; does not start a second scheduler.r;ú/r<r=r\Z prevGamesr.)Zdaysr]rgZ_hermes_start_atz1HERMES V5: sin asociaciones validas; sin accionesNcst|ˆˆˆƒS)N)rs)r„)rorer”rrÚÐóztick..Fé ©ZminutesrAr^é©Zhoursrer`rkTz'Canal cambiado o ausente tras refresh: rZregionalcs|d| d|ˆ ¡dœ¡S)Nr\T)rerhZ prepared_at)Úupdatern)r„r…r0©rorrržós ÿz HERMES V5: preparacion validada z LIVEz DRYrhr|ZOnDemand)r˜Zondemandrr—rUÚstartrdr}r~r›rfrbrrFrcé,zHERMES V5 DRY ú )Ú O11ActionsrcsF|dˆ}t| dg¡ƒˆdkr(dS|d ˆdˆ ¡dœ¡dS)Nr\rdr.Fr)rr`rST)r8rÚappendrn)r„r)rrprorrÚreserves  ÿztick..reservecsP|dˆ}| d¡rdS| d¡p&i}| d¡dkr:dSdˆ ¡dœ|d<d S) Nr\rfFr‹r`)rr€r‚r)r`rST)rrn)r„rÚop)rprorrÚ reserve_stop s  ztick..reserve_stop)Zdry_runzO11 no confirmo csL|dˆ}ˆr4|dd}| d¡ˆkrHd|d<nd|dd<d|d <dS) Nr\rdr}rr‚r`r‹Trfr*)r„rr†)rrprrr‡1s    ztick..confirmzHERMES V5 CONFIRMADO )"rrorÚrstriprr r@ÚlistrÚdaterr¤rrnr[rzrrªrur“rœr{ÚLIVErVrPr9rJrr rrZhermes_lmp_actionsr©Zejecutar)$ZepgZpanelZstream_databaser•r;r<r\rLrOZvalidZdayrÚgr–Zrefreshed_this_tickrNr¦Z en_ventanaZrecuperacion_liverrZlinksZcurrentÚslugZdbZstatesr—ZactionsrUr™ršr©r«r­ZverifiedZdesiredr‡r)rrprorer”rÚtickºsÊ       .,ÿ         "          r´r¥c Cs2tsdS|pt t¡}zütƒ}|d ¡D]ä\}}|| d¡dd…krLq,| d¡s,| d¡sbq,| d¡}|srq,t |¡}|j dkrˆq,||t d d krœq,||t d d kr¶WdS| d ¡dkr,| d¡}|r,t |¡}|j dk r,d||  ¡krdkr,nq,WdSq,Wnt k r,YdSXdS)z3Fail closed for LMP only when live mode is enabled.Tr\rXr.Nrfrerjr r¡r¢r£r`rlrirr§F) r±rrorr{rJÚsplitrrrrrÚ Exception) r³ror>rprZ start_textr¦ÚseenZobservedrrrÚaccess_allowed>s:     ,r¸)-Ú__doc__Úosr(rSrrÚpathlibrZ urllib.parserr4rZhermes_lmp_matcherrrZhermes_lmp_guardrZhermes_lmp_inventoryr Zhermes_lmp_playlistr Zhermes_lmp_coordinatorr Zhermes_lmp_v5_stater ÚtimezonerrÚ__file__Z with_nameruÚenvironrr±rr@rPrVr[rsr{rœÚprintr´r¸rrrrÚs8           6