
    hv                     l   d dl Z d dlZd dlmZ d dlZddlmZ  e j        d          Zes e	d          de dZ
 e j        d	d
                                          Z ej        ed            ej        d          ZdZddedee         fdZdededefdZdee         dedefdZdedefdZdS )    N)Iterable   )
get_client	BOT_TOKENu%   BOT_TOKEN이 .env에 필요합니다.zhttps://api.telegram.org/botz/sendMessage	LOG_LEVELINFOz[%(levelname)s] %(message)s)levelformattelegram_sendersubscribers'  limitreturnc                     t                      }|                    t                                        d                              |                                           }d |j        pg D             S )Nchat_idc                     g | ]
}|d          S )r    ).0rows     1/var/www/html/bot/app/services/telegram_sender.py
<listcomp>z'get_all_subscribers.<locals>.<listcomp>   s    777sC	N777    )r   tableSUBSCRIBERS_TABLEselectr   executedata)r   sbress      r   get_all_subscribersr       s_    	B
(($
%
%
,
,Y
7
7
=
=e
D
D
L
L
N
NC77sx~27777r   r   htmlc                 V   	 t          j        t          | |dddd          }|j        o'|                                                    dd          }|s!t                              d| |j                   |S # t          $ r'}t                              d	| |           Y d }~dS d }~ww xY w)
NHTMLT)r   text
parse_modedisable_web_page_preview   )jsontimeoutokFzsend fail %s: %szsend exception %s: %s)
requestspostAPI_URLr*   r(   getloggerwarningr$   	Exception)r   r!   rr*   es        r   	_send_oner4      s    M"$,0	  	
 	
 	
 T/affhhll4// 	@NN-w???	   .;;;uuuuus   A4A7 7
B(B##B(chat_idsc                 >    d}| D ]}t          ||          r|dz  }|S )Nr   r   )r4   )r5   r!   sentcids       r   send_html_tor9   ,   s7    D  S$ 	AIDKr   c                 z    t                      }|st                              d           dS t          ||           S )Nzno subscribersr   )r    r/   infor9   )r!   subss     r   broadcast_htmlr=   3   s=      D $%%%qd###r   )r   )osloggingtypingr   r+   supabase_servicer   getenvr   RuntimeErrorr-   upperr   basicConfig	getLoggerr/   r   intlistr    strboolr4   r9   r=   r   r   r   <module>rK      s}   				         ( ( ( ( ( (BIk""	 @
,>
?
??
@
@
@
@BIk6**0022	  ),I J J J J		,	-	-! 8 8s 8tCy 8 8 8 8
s # $    (8C=      $ $ $ $ $ $ $ $r   