
    9Pi&                         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mZmZmZ d dlmZ d dlmZmZ d d	lmZmZmZmZmZ  ej        d
          dedej        fd            ZdS )    N)Celery)Client)callback_query)InlineKeyboardButton)BotDOWNLOAD_DIRSUBTITLE_DIRDEFAULT_QUALITIES)Database)auto_inline_panelcancel_task_2)SOFTSUB_DIRHARDSUB_DIR
DUBBED_DIRMOVIEO_ENCODES_DIRr
      )group_updatec                   K   |j         j        }|j         j        }|j        }|j        j        }|                    d          d         }|                    d          d         }|dk    rt                      5 }|                    t          |          d          }	d d d            n# 1 swxY w Y   |	d         d         }
| 	                    |t           d|
            d {V  d S |dk    rt                      5 }|                    |dd	           |                    t          |          d
d            |                    t          |          dd          }|d         d         }|d         d         }
|                    |d|           d d d            n# 1 swxY w Y   |                     ||           d {V  |                     |d|
 d           d {V  d S |dk    rt                      5 }|                    |dd	           |                    t          |          d
d            |                    t          |          dd          }|d         d         }|d         d         }
|                    |d|           d d d            n# 1 swxY w Y   |                     ||           d {V  |                     |d|
 d           d {V  d S |dk    rt                      5 }|                    |dd           |                    t          |          dd          }|                    t          |          dd            |d         d         }|d         d         }
|                    |d|           d d d            n# 1 swxY w Y   |                     ||           d {V  |                     |d|
 d           d {V  d S |t           v r$g }|                    t%          ddt          |                     g           t           D ]y}||k    r:|                    t%          d| | dt          |                     g           B|                    t%          | | dt          |                     g           z|                    t%          ddt          |           d|           g           |                    |j        j        t+          |                     d {V  d S |dk    rt                      5 }|                    t          |          dd          }d d d            n# 1 swxY w Y   |d         d         }|d         d         }|d         d	         }
|d         d         }t                      5 }|                    |dd          }d d d            n# 1 swxY w Y   |d         d         }|                    d           d {V  t/          dd           }|d!v r>d"}d }t1          j        t           | d#| |d$d                      | |d$d           }nz|d%v r>d&}d }t1          j        t           | d#| |d$d                      | |d$d           }n8|dk    rd'}d }n-t           D ]#}t5          j        d(|z   d(z   |
          r|} nd }$d)}|                    d*|dg|d+| ||
||d,d-.           d S |d/k    rt          |          }t                      5 }|                    |dd0          }d d d            n# 1 swxY w Y   |d         d         }
|d         d         }|d         d	         }|d         d         }t                      5 }|                    |dd          }d d d            n# 1 swxY w Y   |d         d         }t                      5 }|                    |d           d d d            n# 1 swxY w Y   |                    d1           d {V  |dk    r6|d!v rt=          j        t@           |!                    dd2                      t=          j        t           d3|!                    dd2                      t=          j        t           |            d S |d%v rt=          j        t@           |!                    dd2          !                    d4d5                      t=          j        t           d3|!                    dd2          !                    d4d5                      t=          j        t           |            d S d S |dk    rSt=          j        t@           |
            |d!v rt=          j        t@           |!                    dd2                      t=          j        t           |            t=          j        t           d3|!                    dd2                      d S |d%v rt=          j        t@           |!                    dd2          !                    d4d5                      t=          j        t           |            t=          j        t           d3|!                    dd2          !                    d4d5                      d S d S |d6k    r!t=          j        t@           |
            |d!v rt=          j        t@           |!                    dd2                      t=          j        t           |            t=          j        t           d3|!                    dd2                      t=          j        tD           |
            d S |d%v rt=          j        t@           |!                    dd2          !                    d4d5                      t=          j        t           |            t=          j        t           d3|!                    dd2          !                    d4d5                      t=          j        tF           |
            d S |dk    r`|                    d7          d8         }t=          j        tH           |            	 t=          j        tH           |
            d S #  Y d S xY w|d6k    r(	 t=          j        tJ           |
            d S #  Y d S xY wd S |d9v rt=          j        t@           |
            |d!v rt=          j        t@           |!                    dd2                      t=          j        tD           |
            t=          j        t           |            t=          j        t           d3|!                    dd2                      d S |d%v rt=          j        t@           |!                    dd2                      t=          j        tF           |
            t=          j        t           |            t=          j        t           d3|!                    dd2                      d S |dk    rUt=          j        tH           |
            t=          j        tH           |                    d7          d8                     d S |d6k    r#t=          j        tJ           |
            d S d S d S d S ):N,r   r   receive_sub	file_namemvo_change_subtitlestate   sub_or_audioidzpackage_id,file_name
package_idu3   لطفا زیرنویس جدید برای فایل u    را ارسال کنید:change_dubbed_audiochange_file_name   u+   لطفا نام جدید برای فایل u   تغییر نام فایلzchange_file_name,u   ✅ u   آغاز عملیاتzstart_task,)reply_markup
start_taskz&package_id,file,file_name,sub_or_audiotypeu*   ⏳ در حال انجام عملیات...requestszredis://localhost:6379/0)broker)r      isolate_softsub_converterz%/var/www/html/auto_sub_bot/subtitles/)r      isolate_hardsub_converterisolate_dubbed_converterz\bisolate_quality_converterz)celery_tasks.tasks.task_router.route_task@)admin_user_idusernamefile_idr   r   qualityrouter)argskwargsqueuecancelz(file_name,sub_or_audio,status,package_idu)   ❗️ تسک موردنظر لغو شد. deleted_asssrt   /)r)   r,   )&	from_userr   r2   datamessagesplitr   get_subtitleintsend_documentr	   update_userupdate_media_taskget_media_taskdelete_messagessend_messager
   appendr   edit_message_texttextr   get_packager   shutilmoveresearch	send_taskdelete_media_taskosremover   replacer   r   r   r   )r   r   user_idr2   callback_data
message_idcommandparamdbsubtitles_dbr   media_task_dbr    buttonsr4   r3   r   
package_db	task_type
celery_apprequest_typetask_idstatus
audio_names                           G/var/www/html/movieo_spanner_bot/base/plugins/cq_tasks_and_subtitles.pytasks_and_subtitlesrk      s     !G(HKM"J!!#&&q)G$$Q'E-ZZ 	C2??3u::kBBL	C 	C 	C 	C 	C 	C 	C 	C 	C 	C 	C 	C 	C 	C 	C OA&	oog&F&F9&F&FGGGGGGGGGGG	%	%	%ZZ 	<2NN771---  UN4@@@--c%jj>TUUM&q)!,J%a(+INN7<
;;;	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 
333333333nnW  &A[d  &A  &A  &A  B  B  	B  	B  	B  	B  	B  	B  	B  	B  	B	)	)	)ZZ 	<2NN771---  UN4@@@--c%jj>TUUM&q)!,J%a(+INN7<
;;;	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 
333333333nnW  &A[d  &A  &A  &A  B  B  	B  	B  	B  	B  	B  	B  	B  	B  	B	&	&	&ZZ 	<2NN771-----c%jj$@VWWM  UK===&q)!,J%a(+INN7<
;;;	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 
333333333nnW%xS\%x%x%xyyyyyyyyyyy	%	%	%,-IKk_bch_i_iKkKkllmnnn( 	` 	`G'!! 45EG5E5E'G`G`TWX]T^T^G`G` a abcccc 4\gC\C\PSTYPZPZC\C\ ] ]^____,-DFjTWX]T^T^FjFjahFjFjkklmmm&&v~':IZ[bIcIc&ddddddddddd	L	 	 ZZ 	h2--c%jj>fggM	h 	h 	h 	h 	h 	h 	h 	h 	h 	h 	h 	h 	h 	h 	h"1%a(
"1%!!$Q'	$Q'*ZZ 	@2
4??J	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@qM!$	&&'STTTTTTTTT-
 
 

 6LGK<7778|`g8|iuvxvyvyiz8|8|}}}%:|BCC'8::LL%6LGK<7778|`g8|iuvxvyvyiz8|8|}}}%:|BCC'8::LL!^^5LGG, # #9UW_u4i@@ #%GE"GG6L7"!(*NN"& ,"   	 	
 	
 	
 	
 	
 
H		e**ZZ 	g2--gd;effM	g 	g 	g 	g 	g 	g 	g 	g 	g 	g 	g 	g 	g 	g 	g!!$Q'	$Q'*q!!$"1%a(
ZZ 	@2
4??J	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@qM!$	ZZ 	02  $///	0 	0 	0 	0 	0 	0 	0 	0 	0 	0 	0 	0 	0 	0 	0&&'RSSSSSSSSSQ;;E!!	\M<+?+?+K+KMMNNN	\UU<3G3GPR3S3SUUVVV	\9<99:::::e##	\b<+?+?+K+K+S+STYZ_+`+`bbccc	\jj<3G3GPR3S3S3[3[\abg3h3hjjkkk	\9<99::::: $# q[[I2y22333E!!	\M<+?+?+K+KMMNNN	\9<99:::	\UU<3G3GPR3S3SUUVVVVVe##	\b<+?+?+K+K+S+STYZ_+`+`bbccc	\9<99:::	\jj<3G3GPR3S3S3[3[\abg3h3hjjkkkkk $# q[[I2y22333E!!	\M<+?+?+K+KMMNNN	\9<99:::	\UU<3G3GPR3S3SUUVVV	[5)5566666e##	\b<+?+?+K+K+S+STYZ_+`+`bbccc	\9<99:::	\jj<3G3GPR3S3S3[3[\abg3h3hjjkkk	[5)5566666a)//44R8
	Z555666I8Y8899999DDaI!3@Y@@AAAAADD	  
 u__I2y22333E!!	\M<+?+?+K+KMMNNN	[5)55666	\9<99:::	\UU<3G3GPR3S3SUUVVVVVe##	\M<+?+?+K+KMMNNN	[5)55666	\9<99:::	\UU<3G3GPR3S3SUUVVVVVa	Z444555	ZF););C)@)@)DFFGGGGGa	/<<<=====S 
	r _  s   8$B((B,/B,=BFF #F 9BJJJ5BNNN %UUU"WW
W
\66\:=\:^++^/2^/_55_9<_9r" "r'1s s)rW   rQ   rS   celeryr   pyrogramr   !pyrogram.types.bots_and_keyboardsr   pyrogram.typesr   baser   r   r	   r
   base.utils.databaser   base.utils.buttonsr   r   configr   r   r   r   on_callback_queryCallbackQueryrk        rj   <module>rx      s4   				  				             < < < < < < 1 1 1 1 1 1 C C C C C C C C C C C C ( ( ( ( ( ( ? ? ? ? ? ? ? ? ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ Qr> r>1M r> r> r>  r> r> r>rw   