.json`) are still written by the channel's own monitor. `sync` reconciles the two worlds when the MyTV switch changes (service worker, the only place here that may use the network): on: the further progress wins: the episodes up to a channel's pointer become watched in the store off: every channel takes over the store's current pointer and resume point Until the first `sync` succeeded the channels keep reading their files (`active` is False), so a failed merge never shows a series from its beginning. N)metastorezplugin.video.milionarmytv_shared_progressmycinema_shared_progress)tvcinemazshared.tv.appliedz shared:syncwidget_mytv_nextwidget_mytv_channelsccVtjd||dS)Nu[Milionář Shared] {})xbmclogformat)messagelevels a/Users/chudy/Library/Application Support/Kodi/addons/plugin.video.milionar/wcs/library2/shared.py_logr's)H % , ,W 5 5u=====rc tjtt|dkS#t $rYdSwxYw)z/The user's switch; on unless it was turned off.falseT) xbmcaddonAddonADDON_ID getSettingSETTINGS Exceptionkinds renabledr+sPx((33HTNCCwNN tts:= A  A ct|sdS|dkrdS tjtdkS#t$rYdSwxYw)zkThe store speaks for the channels of `kind` now (MyTV: only after its channels were merged into the store).FrT1)rrget_flagFLAGrrs ractiver$3s_ 4==u t||t~d##s** uus8 AAc tjttdrdndkS#t$rYdSwxYw)z2The MyTV switch changed and `sync` has work to do.rr!0F)rr"r#rrrrpendingr(?sM~d##wt}}(E#FF uus -0 >>cR t|S#ttf$rYdSwxYw)N)int TypeError ValueError)values r_numberr.Is:5zz z "tts &&cdt|}|iSdtj|DS)z?{(season, episode): state} of the regular episodes of a series.NcHi|]}|ddk|d|df| S)seasonrepisoder'.0rs r z_states..Us9 f f fqVWX`VadeVeVeQx[!I, 'VeVeVer)r.rget_episode_states) series_idshows r_statesr:Ps8 9  D | f fE4LT4R4R f f ffrcd|D}|sdSt|d}|d|dt|dt|dpdd S) Ncg|]T}t|dpddk*t|dpddkR|US) resume_posr playcount)floatgetr*r3s r z_resume_of..Yse t t t!%l0C0C0Hq*I*IA*M*MRUVWV[V[\gVhVhVmlmRnRnrsRsRsARsRsRsrc0|dpdS)Nlast_played_atrr@)r5s rz_resume_of..\s!%%(8"9"9">Qr)keyr1r2r= resume_totalrr1r2positiontotal)valuesmaxr?r@)statesrowsrows r _resume_ofrPXs t tv}} t t tD t d>> ? ? ?C(mIERUVbRcLdLd377>227a88 : ::rcD|dkr||dz fS|dkr |dz tfndS)zBThe channel pointer that makes (season, episode) the next episode.rRr) BEFORE_FIRSTr1r2s rbeforerVas6{{w{"")/!FQJ % %?rct|}|rt|d|dSd|D}|rt|ndS)Nr1r2chg|]/\}}t|dpddk-|0S)r>r)r*r@)r4rFr5s rrAz_pointer_of..ls@TTTvsA3quu[7I7I7NQ3O3ORS3S3Ss3S3S3SrrS)rPrVitemsrL)rMpointwatcheds r _pointer_ofr\hs` v  E 9eHouY'7888TTTTTG" .3w<<<.rc:tt|S)z`The episode in progress (newest play first): {'season', 'episode', 'position', 'total'} or None.)rPr:r8s rresumer_ps gi(( ) ))rc:tt|S)z(season, episode) a channel counts as its last watched one: its next episode is the first after it. The same rule as Continue watching: an episode in progress comes first, else the one after the latest watched by order.)r\r:r^s rpointerraus wy)) * **rct|}|tjd|nd}t|o't |dpddkS)Nmovier>r)r.r get_stateboolr*r@movie_idrcstates r movie_watchedri{s[ H  E/4/@EOGU + + +dE >#eii 449::Q> ? ??rcrt|}|tjd|nd}|rPt|dpddks(t |dpddkrdSddt|dt|dpddS)z5{'position', 'total'} of a film in progress, or None.Nrcr=rr>rGrH)r.rrdr?r@r*rfs r movie_resumerks H  E/4/@EOGU + + +dE E%))L116Q771<<EIIkDZDZD_^_@`@`cd@d@dtA5|9L3M3MX]^c^g^ghv^w^w^|{|X}X} ~ ~~rFc \ddlm}|d|}||rddlm} ||nX#t $rK}t d|t|j tj Yd}~dSd}~wwxYw|d|}|S)zl[(season, episode)] of the aired regular episodes from the metadata cache; `network`: fetch what is missing.r)jobsrN)tmdbz%metadata of series {} unavailable: {}) wcs.library2rmcached_targetsrn refresh_showrrrtype__name__r LOGWARNING)r8networkrmtargetsrnexcs r_airedrxs!!!!!!!!$ 22G7%%%%%%    i ( ( ( (    8?? 4PS99K]^^`d`o p p p44444 %%dI66 Ns> BABBTcvt|}|t||nd}|dSt|t|ft|tt |z}t jd|fd|Ddt jd|fd|DddS)zManual edit in MyTV: every aired episode up to (season, episode) is watched, every later one is not. Returns False when the episode list of the series is not available.NFrc g|] }|k| Sr'r'r4trZs rrAzset_pointer..s B B BqqEzzzzzrTc g|] }|k| Sr'r'r{s rrAzset_pointer..s ? ? ?qQYYYYYr)r.rxr*setr:r mark_many)r8r1r2rur9rvknownrZs @r set_pointerrs 9  D'+'7fT7###TGu [[#g,, 'E LL3wt}}-- -E OD$ B B B BG B B BDIII OD$ ? ? ? ?E ? ? ?GGG 4rc|pi}|dkr|dn|dp|pt|}|dkrdnd}d||dkrdnd|d||pdd d d |d dd |d dd |d dd|ddiS)z`What a title stores when it joins My movies / My series (shown until its TMDb detail is cached).rctitlename release_datefirst_air_dateidyearrNoverview poster_path backdrop_path vote_averager)r@str)mediatmdb_iddatarrdate_keys r list_snapshotrs :2D!&'!1!1DHHW   txx7G7G aE aUXY`UaUaD!&'!1!1~~7GH 'u'7'7GGVd TXXh''-2rr2JUW@X@X 488M266RaceIfIf DHH^Q77 99rc ,t|}tj||rdStj|dkrtj|ntj|d}tj||dt||||dS)zkA title played from a channel belongs to My movies / My series. Cache only (runs beside the playback loop).FrcrT) r*r is_in_listrr@ key_moviekey_tv set_in_listr)rrrrs r ensure_listedrs'llG w''u 8u/?/?DN7+++T[QXEYEY Z Z[\ ]D eWdM%$PU,V,VWWW 4rc ddlm} |dkrdndt||dkrdnt||dkrdnt|d} | | ||||| j|S)zfTracker contract of a channel's playlist item (its stream is resolved outside the canonical resolver).r)playrcr2N)rrrnse)r show_titleoriginfollow)rorr*contractORIGIN_CHANNEL) rrstreamselectedr1r2rrrrinfos rrrs!!!!!!$//GGYG '))s6{{RYIYIY_bcj_k_k m mD ==vxu $ 3F  D DDrcZtjdtS)Nz special://profile/addon_data/{}/)xbmcvfs translatePathrrr'rr_profilers"  !C!J!J8!T!T U UUrcN ttjt ddd5}t j|}dddn #1swxYwYn#ttf$rgcYSwxYwt|tr d|DngS)Nzmytv_channels.jsonr5zutf-8)encodingcfg|].}t|t|d,|/Sr) isinstancedictr@)r4cs rrAz_channels..s6 C C C!z!T22 CquuT{{ CA C C Cr) openospathjoinrjsonloadOSErrorr,rlist)handlers r _channelsrs "',,xzz+?@@#PW X X X %\b9V$$D % % % % % % % % % % % % % % % Z  GQRVX\G]G] e C Ct C C C Ccees4.s6 y y y!X_`a`e`efj`k`kXlXlXxAXxXxXxr media_list series_listrD)channels r _series_ofrs9 y yw{{<00TGKK 4N4NTRT y y yyrc 8 ttjtjt dd|S#t$r#ttjcYSwxYw)N mytv_historyz{}.json) r*rrgetmtimerrrrtime) channel_ids r _history_timers 27##BGLL^YM]M]^hMiMi$j$jkklll    49;; sA)A,,*BBcddlm} ttjt dp|jS#t$rt|jcYSwxYw)Nrpolicylib_resume_min_seconds) rorr?rrrrDEFAULT_RESUME_MIN_SECONDSr,rs r_resume_thresholdrs{######8Y_X..99:RSSxW]Wxyyy 888V6777778s?AA)(A)c ddlm}i}tD]}||d}t |d}t |D]}|t|dpi}t|dpdt|dpdf}d} t|dpddkrt|d pdt|d pdt|dt|d pdf} |d kr| s(|t|dr |d krG|| ||dp|dpdd|t|d<dt} } | D]\} t| |} | d} tjd| fd| Dddt!| }drt#|s{d\}}}}|||fpi}|| krO||krIt|dpddkr!tjd| ||||dt'd| dt)dt-|| rdnd| S)a&Switch on: the further progress wins. A series' furthest channel pointer marks its episodes watched in the store, a channel's resume point of an unwatched episode is kept, and the series joins My series. Returns False when a series could not be merged yet (its episode list is missing).rChannelHistoryrr1rRr2Nresume_positionresume_sresume_erGrSrZrrr)rZr_whenrTFrc,g|]}|dk|S)rZr')r4r|bests rrAz$merge_into_store..s'$N$N$N11W ;M;MQ;M;M;Mrrr_r>)rz1merged {} series of the channels into the store{}z (some are waiting for metadata))wcs.airrload_channel_historyrrr@rr.r?r*rrYrxrrr:rP save_resumerrrlen)rurfurthestrhistoryrseriesentryrZ resume_pointcompleteminimumr9rvrMr1r2rIrJrhrs @rmerge_into_storers&%%%%%H;;gg 55gdmDDWT]++ )) g gFKKF4L 1 1228bEUYYx00116Q )@T@T8U8U8ZYZ[ELUYY0116Q77!;; ' *(=(= > > C!WUYYWaMbMbEcEcEhgh %e,=&> ? ?uyyQ_G`G`GedeAfAf h |<<F4L 1 122D g54=008=_c6 c*V"4"4 c/3H~ ,FGXuJJ0117RE7""ux'7'7C +@V@V@[Z[<\<\`arsr& $$$$$$$$ "(4N O O  !7 8   >>>>    ggg:::@@@///*** +++ @@@         9999DDDDVVVfffzzz   888%%%%P(r