o
    7sg                  
   @   s  d dl Z 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
 d dl	mZ d dlmZ d d	lmZ ejejd
deje jdejddddgd edej edej edej ee Ze Zdd Zdd Zedkrz^zee  W n" e y   Y n+ e!y Z" ze#e"$d W Y dZ"["n'dZ"["ww W ee  e%  e&d dS W ee  e%  e&d dS W ee  e%  e&d dS ee  e%  e&d w dS )    N   )Var)web)idle)utils)	StreamBot)
web_server)initialize_clientsz%d/%m/%Y %H:%M:%SzC[%(asctime)s] {%(pathname)s:%(lineno)d} %(levelname)s - %(message)s)streamzstreambot.logazutf-8)modeencoding)leveldatefmtformathandlersaiohttppyrogramzaiohttp.webc                     s@  t   t d t I d H  t I d H } | jt_t d t   t d t I d H  t d tjr@t d t   t	t
  t d t I d H  tjrPdntj}tt|tj I d H  t d t   t d t d| j | jrt d	t| j t d
|tj tjrt dtj t d t I d H  d S )NzC-------------------- Initializing Telegram Bot --------------------zB------------------------------ DONE ------------------------------zB---------------------- Initializing Clients ----------------------zA------------------ Starting Keep Alive Service ------------------zB--------------------- Initalizing Web Server ---------------------z0.0.0.0zC------------------------- Service Started -------------------------z"                        bot =>> {}z$                        DC ID =>> {}z(                        server ip =>> {}z-                        app running on =>> {}zB------------------------------------------------------------------)printr   startget_meusernamer	   r   	ON_HEROKUasynciocreate_taskr   ping_serverserversetupBIND_ADDRESSr   TCPSitePORTr   
first_namedc_idstrFQDNr   )bot_infobind_address r'   ,/opt/bot_tvplus_vods/WebStreamer/__main__.pystart_services"   s@   r)   c                      s"   t  I d H  t I d H  d S )N)r   cleanupr   stopr'   r'   r'   r(   r*   C   s   r*   __main__zB------------------------ Stopped Services ------------------------)'sysr   loggingvarsr   r   r   r   r   WebStreamerr   r   WebStreamer.serverr   WebStreamer.bot.clientsr	   basicConfigINFOStreamHandlerstdoutFileHandler	getLoggersetLevelERROR	AppRunnerr   get_event_looploopr)   r*   __name__run_until_completeKeyboardInterrupt	Exceptionerrerrorwith_tracebackr+   r   r'   r'   r'   r(   <module>   sd   !
