o
    Ye<                     @   sN  d dl Z d dlZd dlZd dlmZ d dlZd dlZd dlZd dlZd dl	m
Z
 d dlZe dkr<ee  dZndZ	 e jd e e jd d e jd d e jd d	 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 Ze Z e Z!e Z"e Z#ddl$m$Z$ e Z%G dd de&Z'dS )    N)abc)settingsWindowszVH:\colect\biblioteka\programs\LiClipse 10.0.0\LiClipse Workspace\Telegram_ESP32WebApp\z/opt/Telegram_ESP32/z../..z..*)clC)clMDB)clManTEMP_DB)clManTZone_DB)clManEmail_DB)clMLog)clMan_key_sec_DB   )cl_man_grafanac                   @   sf   e Zd ZdZi Zdd Zedd Zedd Zedd	d
Z	edd Z
edd Zedd ZdS )cl_man_registz    
 
    c                 C   s   d S N )selfr   r   N/opt/Telegram_ESP32/site2/telegram_esp32adv/flaskdir/handlers/cl_man_regist.py__init__K   s   zcl_man_regist.__init__c                 C   s"   t d| d | d t jt jf S )Nmess_registFinalnamepassword)r   gurl_server_grafana)new_userr   r   r   makeFinalMessO   s   "zcl_man_regist.makeFinalMessc                 C   s   t | d | d }|dkrtjS t| d }|d }|dkrDt| d |d |d |}|dkrAt	|}t
|d | dS tjS tjS )Nusername	useremailr   key_secidlogin_telegramid_telegram)r   reg_userr   v_errorv_clMan_key_sec_DBget_datasecv_clMDB
INSERTuserr   r   send_message)request_datar   oneid_user_grafanaid_userMessr   r   r   registration_reg_dataS   s"   

z#cl_man_regist.registration_reg_dataFc                 C   s   t | |}|S r   )r$   
is_key_sec)r   debansr   r   r   check_key_seci   s   zcl_man_regist.check_key_secc                 C   s   t | }|S r   )r   get_userByEmail)r   is_useremailr   r   r   check_reg_useremailn   s   
z!cl_man_regist.check_reg_useremailc                    s   ddl m} ddlm} tt  d}t dkr"|tjj	}n
td |tjj
}|j| || dI d H  |j I d H  td d S )Nr   BotReplyKeyboardRemover   z&Linux  Linux Linux Linux Linux Linux  )reply_markupz
main END  )aiogramr7   aiogram.typesr9   printplatformsystemr   botsbot_token_win	bot_tokenr(   sessionclose)r!   messager7   r9   botr   r   r   send_messageWs   s   zcl_man_regist.send_messageWc                    s0   t d dd tj fddd }d S )Nzsend_message c                 S   s2   t  }t | dd }||| ||| d S )Nc              
      s   zAddl m} ddlm} d}t dkrtd ||}ntd ||}|j| || ddI d H  |j	 I d H  td	 W d S  t
yh } ztd
 tt| t|j t| W Y d }~d S d }~ww )Nr   r6   r8   r   z1my_async_function WindowsWindows Windows Windows z2my_async_function  Linux Linux Linux Linux Linux  HTML)r:   
parse_modezmy_async_function END  zException my_async_function)r;   r7   r<   r9   r>   r?   r=   r(   rC   rD   	Exceptiontypeargs)r!   rE   rA   rB   r7   r9   rF   instr   r   r   my_async_function   s.   

zQcl_man_regist.send_message.<locals>.my_thread_function.<locals>.my_async_function)asyncionew_event_loopset_event_looprun_until_complete)r!   rE   rA   rB   looprN   r   r   r   my_thread_function   s   
z6cl_man_regist.send_message.<locals>.my_thread_functionc                      s    t jjt jjS r   )r   r@   rA   rB   r   r!   rE   rT   r   r   <lambda>   s    z,cl_man_regist.send_message.<locals>.<lambda>)target)r=   	threadingThreadstart)r!   rE   	my_threadr   rU   r   r(      s
   zcl_man_regist.send_messageN)F)__name__
__module____qualname____doc__dict_vr   staticmethodr   r.   r2   r5   rG   r(   r   r   r   r   r   D   s     



r   )(sysredatetimecollectionsr   requestsjsonr>   rO   core.settingsr   rX   r?   set_event_loop_policyWindowsSelectorEventLoopPolicyspathinsertutils.constsr   
man_db.MDBr   man_db.clManTEMP_DBr   man_db.clManTZone_DBr	   man_db.clManEmail_DBr
   r   man_db.clMan_key_sec_DBr   r$   v_clManTEMP_DBv_clManTZone_DBv_clManEmail_DBv_clMLogr   r&   objectr   r   r   r   r   <module>   sF   