U j@s.ddlZddlZddlmZGdddZdS)N)Lockc@s6eZdZdddZddZddZd d Zd d Zd S) HLSRegistryV2x'cCs$||_||_i|_i|_t|_dSN)ttl max_recursosrecursos identidadesrlock)selfrrr hermes_hls_registry_v2.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)NzRecurso desconocidorzRecurso expirador)r r rrr)r rrr r rresolver?s zHLSRegistryV2.resolverc Cs|j|W5QRXdSr)r r)r r r rlimpiarKszHLSRegistryV2.limpiarN)rr)__name__ __module__ __qualname__rrr"r#r$r r r rrs    r)r!rZ threadingrrr r r rs