U
    7sgo                     @   sT   d dl Z d dlZddlmZ d dlmZ d dlmZ ddlm	Z	m
Z
mZ dd	 ZdS )
    N   )Var)Client)TokenParser   )multi_clients
work_loads	StreamBotc                     s   t td< dtd< t    s*td d S  fddtjfdd  D  I d H } t	t
|  ttdkrdt_td	 ntd
 d S )Nr   z1No additional clients found, using default clientc              
      s   zt |dkr(|}d }td|  d nd }|}td|  d | t  krdtdI d H  td tdtjtj|tjd|dd		 I d H }d
t
| < | |fW S  tk
r   tjd|  ddd Y nX d S )Nd   zStarting Client - z Using Session Stringz Using Bot Tokenr   z(This will take some time, please wait...z:memory:T)nameapi_idapi_hash	bot_tokensleep_threshold
no_updatessession_string	in_memoryr   zFailed starting Client - z Error:)exc_info)lenprintasynciosleepr   r   API_IDAPI_HASHSLEEP_THRESHOLDstartr   	Exceptionloggingerror)	client_idtokenr   r   client)
all_tokens 6/opt/bot/vods_filmes/script/WebStreamer/bot/clients.pystart_client   s2    

z(initialize_clients.<locals>.start_clientc                    s   g | ]\}} ||qS r#   r#   ).0ir    )r%   r#   r$   
<listcomp>/   s     z&initialize_clients.<locals>.<listcomp>r   TzMulti-Client Mode Enabledz<No additional clients were initialized, using default client)r	   r   r   r   Zparse_from_envr   r   gatheritemsupdatedictr   r   MULTI_CLIENT)clientsr#   )r"   r%   r$   initialize_clients   s    
"
r/   )r   r   varsr   pyrogramr   ZWebStreamer.utilsr    r   r   r	   r/   r#   r#   r#   r$   <module>   s   