ó
Ch-_c@sâdd
lm
Z
mZmZmZmZ
ddlmZmZ
ddl	m
Z

ddlmZ
ddl
mZ
ddlmZ
ddlmZ
ddlmZmZ
dd	lZdd	lZd
d„
Zdef
d
„ƒYZd	S(iÿÿÿÿ(tprintDBGtprintExctiptv_systemteConnectCallbackt	E2PrioFix(tenumtstrwithmeta(
tm3u8(
tBaseDownloader(
tDMHelper(
t
boundFunction(
teConsoleAppContainer(tsleepttimeNs/home/sulge/tmp/m3u8.txtcCs-t|
d
ƒ}|j
|dƒ

WdQXdS(Nt
as

(topentwrite(tmessagetfiletmyfile((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pytDebugToFile!s

tM3U8Downloaderc	Bs7
eZ
dZd
ZdZdZedddddd	d
dƒZedd
ddddƒZd„Z	d„Z
d„Zd„Zd„Z
d„Zid„
Zd„Zd„Zdd„
Zd„Zdd„
Zdd „
Zdd!„
Zed"„
Zd#„Zd$„Zd%„Zed&„
Zd'„Zd(„Zd)„ZRS(*i
ii
ixtNONEt	WGET_NONEt
CONNECTINGtWGET_CONNECTINGtDOWNLOADINGtWGET_DOWNLOADINGtENDEDt
WGET_ENDEDtM3U8t	TYPE_M3U8tSEGMENTtTYPE_SEGMENTtWAITTINGt
TYPE_WAITTINGc

Csátd
ƒ

t
j|ƒ

|jj|_tƒ|_d|_	tƒ|_
t|j
j|j
ƒ|_t|j
j|jƒ|_d|_d|_tj|_tj|_d|_t|_d|_d|_g|_d|_dS(Ns:M3U8Downloader.__init__ ----------------------------------tiiÿÿÿÿ( RRt__init__tWGET_STSRt
wgetStatusRtconsoletNonetiptv_systM3U8UpdaterRt	appClosedt_updateM3U8FinishedtM3U8Updater_appClosed_conntstdoutAvailt_updateM3U8DataAvailtM3U8Updater_stdoutAvail_conntM3U8ListDatatM3U8UpdaterRefreshDelayRtMIN_REFRESH_DELAYtrefreshDelaytLIVE_START_OFFSETtstartLiveDurationtskipFirstSegFromListtFalset
addStampToUrlt
totalDurationtdownloadDurationtfragmentDurationListtmaxTriesAtStart(
tself((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyR%4s$




	

	
	
		
	
	
	c

Cstd
ƒ

dS(Ns9M3U8Downloader.__del__ ----------------------------------(
R(
R?((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyt__del__Ts
c


Csd
S(Ns	wget m3u8((
R?((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pytgetNameWs
cCs,tt
jƒd
t|j|
ƒƒ|_dS(Ns	 -V 2>&1 (RR	t
GET_WGET_PATHR
t_checkWorkingCallBackR*(R?tcallBackFun((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pytisWorkingCorrectlyZs
c


Cs|jS(
N(
t
liveStream(
R?((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pytisLiveStream]s
cCsAd
}t}|dkr't
}|}nd|_|
||ƒ
dS(NR$i(tTrueR9R)R*(R?RDtcodetdatatreasontsts((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyRC`s




	
	
cCs¢||_||_
d
|_tjj|_d|_g|_	d|_
d|_d|_t
|_t|
ƒ
jjddƒ|_|
|_|jƒ
|jƒ
tjS(s9
            Owervrite start from BaseDownloader
        R$iÿÿÿÿitiptv_m3u8_skip_segN(tfilePathtdownloaderParamst
fileExtensionR	tSTSRtstatusR)tupdateThreadtfragmentListtlastMediaSequencetcurrentFragmentttriesR9RFRtmetatgetR8tm3u8Urlt
_startM3U8tonStartRtCODE_OK(R?turlRNtparams((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pytstartis	
	
	
	
	
	
	
	
	

	



c

Cs|jr|j
Sd
|j
SdS(Ni(RFtWGET_TIMEOUT(
R?((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyt_getTimeouts
	
cCsD|jr@d
|
kr"|
d7}
n
|
d7}
|
dt
ƒ7}
n|
S(Nt
?s&iptv_stamp=s?iptv_stamp=s%s(R:R
(R?RZ((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyt_addTimeStampToUrl…s
	





icCs7td
|
ƒ

|j
r|jrdt|jƒ
kr;
d|
kr;
yÉtj|j|jƒ}|j
r	
|jr	
t	|j
ƒ
|_|jdkrœd|_ndt|jƒ
kr	
g|jD]}|j
|jƒ
^q»}|j||jt|jƒ
ƒ
tdƒ

q	
nWqE
tk
r7



td|j|jfƒ

qE
Xn
tdƒ

|jd7_|j|jksr
d|
krø
d|_d|_|j|jƒ
}td	|ƒ

tj|jƒ
d
|jƒd|d}td
|ƒ

|jjt|ƒ
ƒ

dS|jjtdƒ
ƒ

dSntdƒ

tdƒ

tdƒ

dS(Ns,m3u8 _updateM3U8Finished update code[%d]--- iis)m3u8 _updateM3U8Finished list updated ---s3m3u8 _updateM3U8Finished exception url[%s] data[%s]s$m3u8 _updateM3U8Finished no data ---i
R$sM>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> [%s]s --tries=0 --timeout=%d t
"s" -O - 2> /dev/nulls)m3u8 _updateM3U8Finished download cmd[%s]ssleep 1s=|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||s=||||||||||||| m3u8 _updateM3U8Finished FINISHED |||||||||||||(RRFR+tlenR2RtinitsRZt
is_varianttintttarget_durationR5tsegmentst_segUritabsolute_uritmergeFragmentsListWithCheckingtmedia_sequencet	ExceptionR3RdR	tgetBaseWgetCmdRORbtexecuteR(R?RItm3u8ObjtsegtnewFragmentsRZtcmd((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyR-Œs>


!







( 



!


	
	


,








cCs4d|
kr0d
t
|
ƒ
kr0|j|
7_ndS(Ni(R)RfR2(R?RJ((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyR0±s

iÿÿÿÿcCsûy(|
j|j
d
ƒ
}|
|d}
Wntk
rE


tdƒ

n
Xg}x7t|
ƒ
D])}||j
krrPn|jd|ƒ
qYWdt|ƒ
kr÷tdt|ƒ
ƒ

d|jkrä|jd}|j
||_
d|_n|j
j|ƒ

ndS(Niÿÿÿÿi
sLm3u8 update thread - last fragment from last list not available in new list!iss>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> DODANO[%d]ii(	tindexRTRpRtreversedtinsertRfRVtextend(R?RuRotidxttmpListtitem((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyt"mergeFragmentsListWithChecking_OLDµs"














c
CsÁ
g}|jd
krx|d
krx||jkrL
||j}|t
|
ƒ
kr^t
|
ƒ
}n|
|}||_qL
nÔy|g|jD]}||jdƒ
d^q…}g|
D]}||jdƒ
d^q¯}|j|dƒ
}|
|d}
Wntk
r



tdƒ

n
Xx7t|
ƒ
D])}	|	|jkr8
Pn|jd
|	ƒ
q
Wd
t
|ƒ
kr½
tdt
|ƒ
ƒ

d|j	krª
|j	d}|j||_d|_	n|jj
|ƒ

ndS(	Nit
/i
iÿÿÿÿsLm3u8 update thread - last fragment from last list not available in new list!ss>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> DODANO[%d]ii(RURfRTtrfindRwRpRRxRyRVRz(
R?RuRoR|ttoAddRtttmpCurrFragmentListttmpNewFragmentsR{R}((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyRnÊs4








-
*













cCsÑd
|_|j
j|_|j|jƒ
}tj|jƒ
d|j	ƒd|d}|
dkrsd|
|}nt
d|ƒ

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

dS(NR$s --tries=0 --timeout=%d Res" -O - 2> /dev/nullis
 sleep %s && sDownload cmd[%s](toutDatat
DOWNLOAD_TYPERtdownloadTypeRdRZR	RqRORbRRR(R,t_cmdFinishedtconsole_appClosed_connR/t
_dataAvailtconsole_stdoutAvail_connRrR(R?twaitRZRv((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyR[

s
	

,





cCs8td
|
ƒ

d|_
d|_d|_d|jkrDd|_n|j|_|jj|_d|j
krƒd|_d|_nt
|j
j|jƒ|_t
|j
j|jƒ|_|
rí|j|jkrí|jsätjjSt}
nd}t|
krI
d|_|jdt|jƒ
krh
|jd7_|j|j}qh
n|jd7_|j|j}d|krè
|jj|_tj|j ƒ
d|j!ƒd|d	|j"d}td
|ƒ

|j
j#t$|ƒ
ƒ

tjj%S|jr*tdƒ

|jj&|_|j
j#t$dƒ
ƒ

tjj%Stjj'SdS(
Ns_startFragment tryAgain[%r]R$iÿÿÿÿtunknownii
s --tries=1 --timeout=%d Res" -O - >> "sDownload cmd[%s]sim3u8 downloader - wait for new fragments ----------------------------------------------------------------ssleep 2((RR„tremoteFragmentSizetremoteFragmentTypet
localFileSizetm3u8_prevLocalFileSizeR…R R†R)R(Rˆtconsole_stderrAvail_connRR,R‡tstderrAvailR‰RWtMAX_RETRIESRFR	RQtINTERRUPTEDR9RVRfRTR&RR'RqRORbRNRrRRR"t
DOWNLOADED(R?ttryAgainRVRv((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyt_startFragment
sJ

	
	
	

	


	

	

	





7


	




cCs+
d|
kr'
|j
|
7_
|jj|jkr4dS|jj|jkr'
|j
|
7_
|j
jd
dƒj	dƒ
}x«t
t|ƒ
ƒ
D]”}||jdƒ
rît
jd||ƒ}|r
t|jdƒ
ƒ
|_|jdƒ
|_q
q‰||jdƒ
r‰d|_|jj|_Pq‰q‰Wq'
ndS(Ns

s

sLength:s)Length: ([0-9]+?) \([^)]+?\) (\[[^]]+?\])i
is
Saving to:(R)R„R…RR†R&RR'treplacetsplittrangeRft
startswithtretsearchRitgroupRRŽR‘R(R?RJtlinesR{tmatch((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyR‰U
s"













	

c

Cs~td
ƒ

d|jkr2|jjƒ
d|_ntjj|jkrw|jrw|jj	ƒ
|j
dtƒ
tj
SntjS(NsM3U8Downloader._terminateiÿÿÿÿ(RR)R*tkillR	RQRRRR(t	sendCtrlCR‡RHRR]tCODE_NOT_DOWNLOADING(
R?((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyt
_terminatei
s







	




cCs|
jd
ƒ
dS(Nt
iptv_stampi(
R™(R?turi((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyRlv
s
cCstd
|
||j
fƒ

tjj}|rHtj|ƒ

tjj}nª|jj	|j
kr¯d|_d|_dt
|jƒ
kr3y˜tj|j|jƒ}|jrõdt
|jƒ
kr|j|jdjƒ
|_|jƒ
tjj}qn&dt
|jƒ
kr|jset|_d|jkrY
g|jD]}|j|jƒ
^q5
|_nãg|_d}|j}xot|jƒ
D]^}d|j kr¦
||j 7}n
||7}|jj!|j|jƒ
ƒ

||jkr
Pq
q
W|jj"ƒ
t
|jƒ
t
|jƒ
kr<t
|jƒ
|j#kr<|j|j#|_n|j$t
|jƒ
|_%|j&dƒ

n§g|jD]}|j|jƒ
^qo|_yOd|_'g|_(x6|jD]+}|j'|j 7_'|j(j!|j ƒ

q¯WWn*t)k
r


t*ƒ
d|_'g|_(n
X|j+ƒ}nWq3t)k
r/


q3Xntd||j,fƒ

|tjjkr£|j,|j-kr£d|_d|_|j,d7_,|j|j.ƒ

dSd|_,nC
|jræ|jj/|j
krætdƒ

|j+ƒ}n
tj|ƒ

td|j|j0|j1|j2fƒ

d|j1krO|js@tjj}qò|j+ƒ}n£d|j1|j2kr¾|j'dkr¯y|j3|j(|j47_3Wq¯t)k
r«


t*ƒ
q¯Xn|j+ƒ}n4d|j1|j2kræ|j+tƒ
}ntjj}||_5tjj|j5krdS|j6r;d|_7d|_8d|_6nt9|_|j:rxd|_d|_|j:j;ƒ
d|_:n|s‹|j<ƒ
ndS(NsDM3U8Downloader._cmdFinished code[%r] terminated[%r] downloadType[%s]iiÿÿÿÿs->>>>>>>>>>>>>>>>>> localStatus [%s] tries[%d]i
sAm3u8 liveStream waitting finished--------------------------------s9m3u8 nextFragment finished: live[%r]: r[%d], l[%d], p[%d](=RR†R	RQtERRORRtupdateStatisticR”R…RR)RˆRŠRfR„RRgRZRht	playlistsRlRmR[RRkt
is_endlistRHRFR7RTRjRxtdurationtappendtreverseR8RoRUR-R;R=RpR
R—RWR>R4R"RRRR<RVRRR+R.R1R9R(R¢tonFinish(R?RIt
terminatedtlocalStatusRsRttcurrentDurationtmaxFragDuration((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyR‡y
s¸






	
	


	





	
	

.	

	








6
+

	
	






	







$
	
	







&

	







	

	
	
	
	
	
	
	




c


CstS(
N(
RH(
R?((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pythasDurationInfoù
s
c

Cs
t|j
ƒ
S(
N(RiR;(
R?((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pytgetTotalFileDurationü
sc

Cs
t|j
ƒ
S(
N(RiR<(
R?((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pytgetDownloadedFileDurations( t__name__t
__module__R4R“RaR6RR&R…R%R@RARERGRCR`RbRdR-R0R~RnR[R9R—R‰R¤RlR‡R³R´Rµ(((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyR%sB






	

		 								%	@;		
	€		(t-Plugins.Extensions.IPTVPlayer.tools.iptvtoolsRR
RRRt-Plugins.Extensions.IPTVPlayer.tools.iptvtypesRRt"Plugins.Extensions.IPTVPlayer.libsRt3Plugins.Extensions.IPTVPlayer.iptvdm.basedownloaderRt+Plugins.Extensions.IPTVPlayer.iptvdm.iptvdhR	tTools.BoundFunctionR
tenigmaRR
RRœtdatetimeRR(((sN/usr/lib/enigma2/python/Plugins/Extensions/IPTVPlayer/iptvdm/m3u8downloader.pyt<module>s(