U Pj @s.ddlZddlZddlmZGdddZdS)N)Lockc@s>eZdZdddZddZddZd d Zd d Zd dZdS) HLSRegistryV2x'cCs$||_||_i|_i|_t|_dSN)ttl max_recursosrecursos identidadesrlock)selfrrr #hermes_hls_registry_v4_candidate.py__init__s zHLSRegistryV2.__init__csZtfdd|jD}|D]0}|j|}|d}|j||kr$|j|=q$dS)Ncs g|]\}}|dkr|qS)expr ).0 identificadorrecursoZahorar r s z*HLSRegistryV2._limpiar.. identidad)timer itemspopr get)r Z expiradosrrrr rr_limpiars  zHLSRegistryV2._limpiarc Cs|s td|j||j|}|rj||jkrj|j|}||d<t|j|d<|W5QRSt|j|j krt dt d}||t|jd|j|<||j|<|W5QRSQRXdS)NzIdentidad HLS requeridaurlrzLimite HLS alcanzado)rrr) ValueErrorr rr rr rrlenr RuntimeErrorsecretsZ token_urlsafe)r rrZ existenterrr r r registrars&     zHLSRegistryV2.registrarc CsV|jF|j|}|s tdt|dkr8td|dW5QRSQRXdS)NRecurso desconocidorRecurso expiradorr r rrr)r rrr r rresolver?s zHLSRegistryV2.resolverc Csf|jV|j|}|s tdddl}||dkr@td|d|dfW5QRSQRXdS)Nr#rrr$rrr%)r rrrr r rresolver_completoKs zHLSRegistryV2.resolver_completoc Cs|j|W5QRXdSr)r r)r r r rlimpiar\szHLSRegistryV2.limpiarN)rr) __name__ __module__ __qualname__rrr"r&r'r(r r r rrs    r)r!rZ threadingrrr r r rs