ó
Ch-_c@s·dd
lm
Z
mZmZ
ddlmZmZ
ddlmZ
ddl	m
Z

ddlmZ
ddl
mZ
ddlZddlZdef
d	„ƒYZd
dd„ƒYZdS(
iÿÿÿÿ(tprintDBGtprintExcteConnectCallback(tDMHelpert
DMItemBase(
tDownloaderCreator(
t
boundFunction(
teTimer(
tsleepNtDMItemc
BseZ
d„ZRS(
cCs)tj
||
|ƒ
t|_d
|_dS(Niÿÿÿÿ(Rt__init__tFalset	processedtdownloadIdx(tselfturltfileName((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR
s
	
(t__name__t
__module__R
(((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR	s
t	IPTVDMApicBs
eZ
dd
dd„Zd„Zed„
Zd„Zd„Zd„Z	d„Z
d	„Zd
„Zd„Z
d„Zd
„Zd„Zd„Zgd„
Zd„Zd„Zdd„
Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(ii
cCsŽt|_
d
|_t|_t|_|
|_g|_||_g|_g|_	g|_
tƒ|_t
|jj|jƒ|_||_dS(Ni(RtrunningR
tdownloadingtupdateProgresst
sleepDelaytqueueUDtMAX_DOWNLOAD_ITEMtqueueAAtqueueDQt
onlistChangedRt	mainTimerRttimeoutt	processDQtmainTimer_conntfinishNotifyCallback(RtrefreshDelaytparallelDownloadNumR!((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR
$s
	
	
		
		
				
	
c

CsRtd
ƒ

t
|jkr2t|_|jjƒ
n|jƒ
d|_d|_dS(Ns%IPTVDMApi.__del__ -------------------(	RtTrueRRRtstoptstopAllDownloadItemtNoneR (
R((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyt__del__>s



	



	
	
cCs
|
|_dS(
N(
R(Rtupdate((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytsetUpdateProgressHs
	
c


Cs|jS(
N(
R(
R((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyt	isRunningLs
cCsf|j|
ƒ
}d
|krbd|j|jkrb|j|jjƒ
tdƒ

|j|
d
ƒ
ndS(Niÿÿÿÿi
(tfindIdxInQueueUDR'Rt
downloadert	terminateRtcmdFinished(RR
t	listUDIdx((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytstopDownloadItemOs


"

c
CsTxMt|j
ƒ
d
krO|j
d
j}
|j
d
jjƒ
|j|
dƒ
qWdS(Niiÿÿÿÿ(tlenRR
R-R.R/(RR
((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR&Ys



cCsŽtd
|
ƒ

t
}|j|
ƒ
}d|krwdt|jƒ
krw|j|}|j|=|jjd|ƒ
t}n|rŠ|jƒ
ndS(Ns)moveToTopDownloadItem for downloadIdx[%d]iÿÿÿÿi
i(RRtfindIdxInQueueDQR2RtinsertR$tlistChanged(RR
tbRetR0titem((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytmoveToTopDownloadItem_s



!


	
cCsŸtd
|
ƒ

t
}|j|
ƒ
}d|krˆ|j|}ytj|jƒ

Wn"tk
rt


td|jƒ

n
X|j|=t}n|r›|j	ƒ
ndS(Ns&deleteDownloadItem for downloadIdx[%d]iÿÿÿÿs*deleteDownloadItem removing file[%s] error(
RRR3RtostremoveRt	ExceptionR$R5(RR
R6R0R7((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytdeleteDownloadItemos









	
cCsŸtd
|
ƒ

t
}|j|
ƒ
}d|krˆ|j|}ytj|jƒ

Wn"tk
rt


td|jƒ

n
X|j|=t}n|r›|j	ƒ
ndS(Ns&removeDownloadItem for downloadIdx[%d]iÿÿÿÿs*removeDownloadItem removing file[%s] error(
RRtfindIdxInQueueAARR9R:RR;R$R5(RR
R6R0R7((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytremoveDownloadItem‡s










	
cCs¦|j|
ƒ
}d
|kr¢|j
|}tjj|_d|_d
|_d
|_d
|_	d|_
d
|_t|_
tjj|_|jj|ƒ

|j
|=ndS(Niÿÿÿÿi(R=RRtSTStWAITINGtstatustdownloadedSizetdownloadedProcentttotalFileDurationtdownloadedFileDurationtdownloadedSpeedttimeToFinishRRt
DOWNLOAD_TYPEtCONTINUEttriesRtappend(RR
R0R7((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytcontinueDownloadItemœs


	
	
	
	
	
		

cCs¯|j|
ƒ
}d
|kr«|j
|}tjj|_d
|_d|_d
|_d
|_	d
|_
d|_d
|_t
|_tjj|_|jj|ƒ

|j
|=ndS(Niÿÿÿÿi(R=RRR?R@RAtfileSizeRBRCRDRERFRGRRRHtRETRYRJRRK(RR
R0R7((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytretryDownloadItem±s



	
	
	
	
	
	
		

c

Cs6t|j
kr(t|_
|jjƒ
n|jƒ
d
S(s$ Can be called only from main threadN(R$RRRR%R&(
R((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytstopWorkThreadÆs
	
c

Cs6t|j
kr2t|_
|jj|jd
ƒ

ndS(s$ Can be called only from main threadièN(RRR$RtstartR(
R((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyt
runWorkThreadÎs
	
cCs’t}t}x,|j
D]!}|j|
jkrt}qqWt|kr{|jd
7_|j|
_|j
j|
ƒ

t}n|rŽ|jƒ
n|S(Ni
(RRRR$R
RKR5(RtnewItemR6texistR7((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytaddToDQueueÔs









	



cCsƒ
|
jƒt
jjkrCt|jƒ
|jkrCttd
ƒ
fSntd}}xH|D]@}t
j	|ttƒ}|
j
|ƒ
\}}|rW|}PqWqWW|ry
t|
jƒ|
j
ƒƒ}|jd7_|j|_|
|_|
jƒ|_|j|ƒ

|
jƒt
jjkr\
t|j|jƒ|_|jj|jƒ

|jj|ƒ

|jƒ
n|jj|ƒ

|jƒ
n||fS(Ns2Max number of parallel downloads has been reached.ti
(t	getStatusRR?tDOWNLOADINGR2RRRt
_tmakeUnikalFileNametmoveFullFileNameR	tgetUrltgetFullFileNameR
R-RAt
updateItemSTSRR/tcallbacktsubscribeFor_FinishRKRRRR5(RR-tfullFilesPathsR6tmsgtnewFilePathRS((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyt
addBufferItemæs2













	








c
CsÞt|j
krdSt}
t|jƒ
|jkr~d
t|jƒ
kr~|jjd
ƒ
}|jj|ƒ

t}
|j	|ƒ

nd
t|jƒ
krŸt|_
n	t|_
|
r»|jƒ
n|j
rÚ|jrÚ|j
ƒ
ndS(Ni(RRR2RRRtpopRKR$trunCMDRR5RtupdateDownloadItemsStatus(RtdListChangedR7((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR	
s 







	


cCs1
td
|
j
ƒ

tjj|
jkrDtj|
jttƒ|
_ntd|
j
|
j|
j	fƒ

|j
|
j
ƒ
}tjj|j
|_|
j|j
|_tj|
j	ƒ
\}}t|ƒ
|j
|_t|j|
j
ƒ|j
|_|j
|jj|j
|jƒ

|j
|jj||
j|ƒ
dS(NsrunCMD for downloadIdx[%d]s4Downloading started downloadIdx[%s] File[%s] URL[%s](RR
RRHtINITIALRJRZRRRR,R?RXRRAtgetDownloaderParamFromUrlRR-RR/R_R`RQ(RR7R0RtdownloaderParams((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyRf 
s

 




!
cCsêtd
|
ƒ

|j
|
ƒ
}d|kr-dS|j|ƒ

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

d|j|_d|j|_|j|}td|
|j
|jfƒ

|j|}|jj
|ƒ

|j|=|jƒ
dS(NscmdFinished downloadIdx[%d]iÿÿÿÿs-Downloading finished idx[%s] File[%s] URL[%s](RR,tupdateDownloadedItemStatusR$RRR-tunsubscribeFor_FinishR_R'RRRRKR5(RR
tretvalR0R7((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR/2
s




!






cCs>x7tt
|jƒ
ƒ
D] }|j|j|
kr|SqWd
S(Niÿÿÿÿ(trangeR2RR
(RR
tlistIdx((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR3K
s


cCs>x7tt
|jƒ
ƒ
D] }|j|j|
kr|SqWd
S(Niÿÿÿÿ(RoR2RR
(RR
Rp((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR,R
s


cCs>x7tt
|jƒ
ƒ
D] }|j|j|
kr|SqWd
S(Niÿÿÿÿ(RoR2RR
(RR
Rp((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR=Y
s


cCsC
td
|
ƒ

|j
|j|
ƒ

|j|
}d}|jdkrctjj|j|
_d}nJ|jdkr‘tjj	|j|
_d}ntjj
|j|
_d}yw|j|
jjdƒ
d	}|d
 }t
|ƒ
t
|ƒ
krü|d7}n|d7}|jƒj|t|ƒ
ƒ

Wntk
r>



tƒ
n
XdS(
Ns(updateDownloadedItemStatus listUDIdx[%d]tUNKNOWNict
DOWNLOADEDitINTERRUPTEDtFAILEDt
/iÿÿÿÿis...t
 (RR^RRCRR?RrRARBRstERRORRtsplitR2R!t
showNotifyRYR;R
(RR0tdItemRARt	shortName((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyRl`
s*






	

	








!


cCsþtd
|
j
ƒ

|
jjƒ
|
jjƒ|
_|
jjƒ|
_|
jjƒ|
_	|
jj
ƒrŠ|
jjƒ|
_|
jj
ƒ|
_n|
jdkrÂ|
jdkrÂd|
j|
j|
_n8|
jdkrú|
jdkrúd|
j|
j|
_ntS(NsupdateItemSTS downloadIdx[%d]iid(RR
R-tupdateStatistictgetLocalFileSizeRBtgetRemoteFileSizeRMtgetDownloadSpeedRFthasDurationInfotgetTotalFileDurationRDtgetDownloadedFileDurationRERCR$(RtdownloadItem((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR^~
s











c
Csft}
t
d
ƒ

x<tt|jƒ
ƒ
D]%}|j|j|ƒ
r&t}
q&q&W|
rb|jƒ
ndS(NRg(RRRoR2RR^R$R5(Rt
stsChangedR0((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyRg
s








c
CsQg}
td
ƒ

g}|j
|jƒ

|j
|jƒ

|j
|jƒ

|}
|
S(NtgetList(RtextendRRR(RtlistttmpList((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR…š
s





cCs&|
|jkr"|jj
|
ƒ

ndS(
N(RRK(Rtfnc((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytconnectListChanged§
s

cCs&|
|jkr"|jj
|
ƒ

ndS(
N(RR:(RR‰((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pytdisconnectListChanged«
s

c
Cs)td
ƒ

x|j
D]
}
|
ƒ
qWdS(Ns
listChanged()(RR(Rt
x((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR5¯
s



N( RRR'R
R(R$R*R+R1R&R8R<R>RLRORPRRRURdRRfR/R3R,R=RlR^RgR…RŠR‹R5(((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyR"s8	
		
									#								
	
		((t-Plugins.Extensions.IPTVPlayer.tools.iptvtoolsRR
Rt+Plugins.Extensions.IPTVPlayer.iptvdm.iptvdhRRt:Plugins.Extensions.IPTVPlayer.iptvdm.iptvdownloadercreatorRtTools.BoundFunctionRtenigmaRttimeRtdatetimeR9R	R(((sI/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/iptvdmapi.pyt<module>s