
    4sPiP	              	          d dl Z d dlZe j                            ej                            ej                            ej                            e          d                               d dlm	Z	 d dl
mZmZ d dlmZmZmZmZ d dlmZ  e	j        d          d	efd
            Z e	j        d          deded	edefd            ZdS )    Nz..)app)log_requestsend_request)YOUR_REQUEST_ADDEDSEND_TITLE_REQUEST_TO_ADMINfetch_title_metadataadd_title_to_elasticsearch)MOVIEO_TELEGRAM_APItitle_requests)queueimdb_idc                     | d         }|rG| d         }|rd}nd}t          ||          \  }}d| d<   || d<   || d<   || d<   d	| d
<   t          | d<   | S ddiS )Nstatus	is_series      Ten_nametitle_id
title_typeluser_idapi_urlF)r   r
   )title_primary_infor   r   r   r   r   r   s          F/var/www/html/auto_sub_bot/celery_tasks/tasks/title_request_handler.pyadd_title_to_databaser   	   s    )F !&{3	 	JJJ0*EE''+8$(/9%)1:&+5<((69%(;9%!!%      admin_user_id
request_id
title_namec                 l   | d         }| d         }| d         }| d         }|rQt          |||           t          |d          \  }	}
}|	t          |||
          d}t          t          d|           d S |t          |dd	|           d
dd| dgdd| dggid}t          t          d|           d S )Nr   r   r   r   r   )chat_idtextsendMessageztitle requestttinline_keyboardu   ✅ تایید درخواستzsubmit_request-)r!   callback_datau   ❌ بستن درخواست)r    r!   reply_markup)r	   r   r   r   r
   r   )title_final_infor   r   r   r   r   r   r   r   r    	movieo_iddatas               r   submit_title_requestr*       s   h'F
+Hy)G!,/J >"8WjAAA)4Z)C)C&J&z:yII
 
 	(===== %/
?>PW>>ZZ!=PnblPnPnoop;Nl`jNlNlmmn$	
 	
 	(=====r   )sysospathappendabspathjoindirname__file__celery_tasks.celeryr   base.utils.funcsr   r   
base.utilsr   r   r   r	   configr
   taskstrr   intr*    r   r   <module>r;      sF   



 				 RW__X-F-F M MNN O O O # # # # # # 6 6 6 6 6 6 6 6 x x x x x x x x x x x x & & & & & &	 !!!!s ! ! ! "!!, 
 !!!># >3 >Y\ >jm > > > "!> > >r   