ó
Ch-_c@s
dd
lm
Z
mZmZmZmZmZ
ddlmZm	Z	
ddl
mZ
ddlm
Z

ddlmZ
ddlmZ
ddlmZ
ddlZddlZy4yddlZWnek
rÞ


ddlZn
XWnek
rú


eƒ
n
Xd	ef
d
„ƒYZdS(iÿÿÿÿ(tprintDBGtprintExctiptv_systemteConnectCallbackt	E2PrioFixtrm(tenumtstrwithmeta(
tBaseDownloader(
tDMHelper(
t
boundFunction(
teConsoleAppContainer(
tsleepNtMergeDownloadercBsÑeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Z	id„
Z
d	„Zd
„Zd„Z
d„Zed
„
Zed„
Zd„Zd„Zd„Zed„
Zd„Zd„ZRS(c

Csbtd
ƒ

t
j|ƒ

d|_d|_igd6gd6gd6gd6gd6|_d|_dS(Ns;MergeDownloader.__init__ ----------------------------------turlstfilestremote_sizetremote_content_typet
local_sizei(RRt__init__tNonetconsoletiptv_systmultitcurrIdx(
tself((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyR&s



	
	,
c

Cstd
ƒ

dS(Ns:MergeDownloader.__del__ ----------------------------------(
R(
R((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyt__del__1s
c
Cs&x|jd
D]}
t
|
ƒ

qWdS(NR(RR(Rtitem((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyt_cleanUp4s

c


Csd
S(NR
((
R((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pytgetName8s
cCs0tt
jƒd
dt|j|
ƒƒ|_dS(Ns
 -version s 2>&1 (RR	tGET_FFMPEG_PATHR
t_checkWorkingCallBackR(RtcallBackFun((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pytisWorkingCorrectly;s
cCsNd
}t}|dkr=t
}|}d|_|
||ƒ
n
|j|
ƒ

dS(Nti(tTruetFalseRRt_isWgetWorkingCorrectly(RR tcodetdatatreasontsts((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyR>s





	
cCs,tt
jƒd
t|j|
ƒƒ|_dS(Ns	 -V 2>&1 (RR	t
GET_WGET_PATHR
t_checkWgetWorkingCallBackR(RR ((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyR%Js
cCsAd
}t}|dkr't
}|}nd|_|
||ƒ
dS(NR"i(R#R$RR(RR R&R'R(R)((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyR+Ms




	
	
cCs
||_d
|_
|
|_||_yÈ|jjdƒ
djdƒ
}d}xœ|D]”}|jdj|jj|ƒ

|jdj|ƒ
}|jdj|ƒ

|jd	jd
ƒ

|jdjd
ƒ

|jdjd
ƒ

|d7}qSWWnt	k
r



t
ƒ
n
X|jƒ
tj
S(
NR"smerge://i
t
|iRs.iptv.tmp.{0}.dashRRiÿÿÿÿRR(tdownloaderParamst
fileExtensionturltfilePathtsplitRtappendtmetatformatt	ExceptionR
tdoStartDownloadRtCODE_OK(RR/R0tparamsturlsKeystidxR((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pytstartVs&
	
	
	
	













c
Cs
d
|_d|_
|jd|j}
|jd|j}d
}d}tj|jƒ
d||fd|d|
d	}td
|ƒ

tƒ|_	t
|j	j|jƒ|_
t
|j	j|jƒ|_|j	jt|ƒ
ƒ

tjj|_|jƒ
tjS(NR"tunknownRRis
 %s -t %d t
"s" -O "s
" > /dev/nullsdoStartDownload cmd[%s](toutDatatcontentTypeRRR	tgetBaseWgetCmdR-RRRRt	appClosedt_cmdFinishedtconsole_appClosed_conntstderrAvailt
_dataAvailtconsole_stderrAvail_conntexecuteRtSTStDOWNLOADINGtstatustonStartRR7(RR0R/tinfotretriestcmd((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyR6os
	
	


4





c
Cs tj
ƒd
}
x(|jdD]}|
dj|ƒ
7}
qW|
dj|jƒ
7}
td|
ƒ

tƒ|_t|jj	|j
ƒ|_|jjt
|
ƒ
ƒ

dS(Nt
 Rs
 -i "{0}" sC -map 0:0 -map 1:0 -vcodec copy -acodec copy "{0}" >/dev/null 2>&1 sdoStartPostProcess cmd[%s](R	RRR4R0RRRRRARBRCRGR(RRNR((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pytdoStartPostProcess…s







cCs
d|
krdS|j
|
7_
d
|j
kr
d|_|j
jddƒjdƒ
}x«tt|ƒ
ƒ
D]—}d||krhtjd||ƒ}|rÀt	|j
dƒ
ƒ
|jd|j<ntjd||ƒ}|rÿ|j
dƒ
|jd	|j<qÿqhqhWd
|_
ndS(Ns
Saving to:s

s

sLength:s ([0-9]+?) i
Rs(\[[^]]+?\])RR"(
RR>RFtreplaceR1trangetlentretsearchtinttgroupRR(RR'tlinesR:tmatch((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyREs




	




&

'
c

CsŠtd
ƒ

d|jkr2|jjƒ
d|_n|jtjjtjjgkrƒ|j	rƒ|j	j
ƒ
|jdtƒ
t
jSnt
jS(NsMergeDownloader._terminateiÿÿÿÿ(RRRtkillRJR	RHRItPOSTPROCESSINGRt	sendCtrlCRBR#RR7tCODE_NOT_DOWNLOADING(
R((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyt
_terminatežs






!
	





cCsz
td
|
|fƒ

d|jkrAd|_d|_d|_n|rdtjj|_|j	ƒ
dS|jtjj
krðtj|jƒ
|_
td|j
|
fƒ

|j
dkrÞ|
dkrÞ|j
|_tjj|_qY
tjj|_ni|
dkrY
|jdt|jdƒ
kr9
|jd7_|jƒ
dStjj
|_|jƒ
dSn|sl
|jƒ
n|j	ƒ
dS(Ns4MergeDownloader._cmdFinished code[%r] terminated[%r]s5POSTPROCESSING_cmdFinished localFileSize[%r] code[%r]ii
R(RRRRCRFR	RHtINTERRUPTEDRJRR[tgetFileSizeR0t
localFileSizetremoteFileSizet
DOWNLOADEDRRSRR6RPtonFinish(RR&t
terminated((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyRBªs6

	
	











 










cCs­td
|j
|j|jdfƒ

|j
dkr:|j
S|
rntj|jd|jƒ
|jd|j<nd}x.|jdD]}|dkr‚||7}q‚q‚W|SdS(Ns=>>>>>>>>>>>>>>>>>>>>> _localFileSize [%r] loacalSize[%r] = %rRiR(RRaRRR	R`(RtupdateRaR((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyt_localFileSizeÍs
$


.





c
Cstd
|j
ƒ

|j
dkr'|j
Sd}
d}x8|jdD])}|dkrA|
|7}
|d7}qAqAW|t|jdƒ
kr‹|
SdS(Ns*>>>>>>>>>>>>>>>>>>>>> _remoteFileSize [%r]iRi
iÿÿÿÿ(RRbRRS(RRbtnumR((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyt_remoteFileSizeÛs











c
Cs‘|j}
t
j
jƒ}|
ru|jƒ}||j}||
j}|d
kr|||_||_||_qn||_|jƒ|_dS(Ni(tlastUpadateTimetdatetimetnowRgtprevLocalFileSizetsecondst
downloadSpeed(RtprevUpdateTimetnewTimeRat	deltaSizet	deltaTime((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pytupdateStatisticês
	









	
	
c


Cs
|jƒS(
N(
Ri(
R((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pytgetRemoteFileSizeús
cCs
|j|
ƒ
S(
N(
Rg(RRf((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pytgetLocalFileSizeýs
c


Cs|jS(
N(
Ro(
R((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pytgetDownloadSpeed
s
c


Cs|jƒ
|j
S(
N(RvRa(
R((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pytgetPlayableFileSize
s


(t__name__t
__module__RRRRR!RR%R+R;R6RPRER^R$RBR#RgRiRtRuRvRwRx(((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyR
$s*											
		#				(t-Plugins.Extensions.IPTVPlayer.tools.iptvtoolsRR
RRRRt-Plugins.Extensions.IPTVPlayer.tools.iptvtypesRRt3Plugins.Extensions.IPTVPlayer.iptvdm.basedownloaderRt+Plugins.Extensions.IPTVPlayer.iptvdm.iptvdhR	tTools.BoundFunctionR
tenigmaRttimeRRTRktjsonR5t
simplejsonR
(((sO/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/mergedownloader.pyt<module>s .