\n4dZddlZddlZddlZddlmZddlZdZdZdZdZ dZ ej Z ej fd Zd Zd Zd Zd ZddZddZdZdZddZddZdS)uPro tebe in the service: when to rebuild the snapshot, and the manual rebuild (docs/plan/pro-tebe/030 §2). A rebuild runs when there is no snapshot, the day or the time-of-day slot changed, it is older than REBUILD_AFTER, or the household's signals changed (a play ended, feedback) and the last build is at least SIGNAL_GAP old. One build at a time (a lock file), rows are told through the row revisions (wcs/skin/refresh.py), never by touching controls. N)datetime-i,i`TiicVtjd||dS)Nu[Milionář ProTebe] {})xbmclogformat)messagelevels `/Users/chudy/Library/Application Support/Kodi/addons/plugin.video.milionar/wcs/foryou/service.py_logr s)H & - -g 6 6>>>>>cddlm}tjtj|dS)Nrstorez foryou.lock) wcs.library2rospathjoindirnamedb_pathrs r _lock_pathrs@"""""" 7<< 88- H HHr cHt} tj|rPt jtj|z t krtj|tj|tj tj ztj z}tj |ttjtj|dS#t"$rYdSwxYw)zBCross-process lock (service and a manual rebuild from the plugin).TF)rrrexiststimegetmtime LOCK_STALEremoveopenO_CREATO_EXCLO_WRONLYwritestrgetpidencodecloseOSError)rfds r _acquirer) s <>$   DIKK"'2B2B42H2H$H:$U$U IdOOO WT2: 1BK? @ @ S%%,,..///  t uusDD D! D!cj tjtdS#t$rYdSwxYwN)rrrr'r r _releaser-.sC  *,,      s $ 22cddlm}|} |d}|d}|d}|n#|wxYwdjt|t|zt|zS)zXChanges when the household's signals change: plays, finished plays, feedback, the lists.rrzBSELECT COUNT(*), MAX(COALESCE(ended_at, started_at)) FROM play_logz&SELECT COUNT(*), MAX(at) FROM feedbackz3SELECT SUM(in_list), MAX(list_added_at) FROM titlesz{}:{}|{}:{}|{}:{})rrconnectexecutefetchoner&rtuple)rconnplaysfeedbacklistss r signals_stampr75s"""""" ==??D abbkkmm<< HIIRRTT RSS\\^^  %  %e uX(Fu(U WWs A5B&&B<c ddlm}m}tdsdS t s+t d tdS tj}t} | t }nl#|j $r_}t d |tjYd}~ttdSd}~wwxYw||d<||dd lm}||jt d |pd t+|d t+|d dtj|z |dd|ttS#twxYw#t,$rd}t d t/|j|tjYd}~tdSd}~wwxYw#twxYw)zbBuild and store a new snapshot, then tell the rows. Returns the snapshot, or None (busy / failed).r)enginewidgetsFNz)rebuild skipped: another build is running)rz!rebuild kept the old snapshot: {}signals)refreshz:snapshot built ({}): {} titles, {} rows, {:.1f} s, TMDb {}manualitemsmodesallstatstmdbzrebuild failed: {}: {}) wcs.foryour:r;_lockacquirer)r releaserr7build NotEnoughrr LOGWARNINGr-savewcs.skinr=changedALL_ROWSlen Exceptiontype__name__LOGERROR)reasonr:r;startedstampsnapshotexcr=s r build_nowrYBse******** ==  tzz  < = = =.  - ikkG!OOE !<AI>I%I""I%%Jcddlm}|ptj}|sdS|t|dpdz }t j|}|d|krdS|d| |j krdS|tkrd S|tkr'|d tkrd Sd S) z)Why a rebuild is due ('' when it is not).r)composemissingbuilt_atdayznew dayslotz time of dayager<r8)rDr[rintgetr fromtimestampdate isoformatslot_ofhour REBUILD_AFTER SIGNAL_GAPr7)rWnowr[r`moments r duerlds"""""" C y HLL,,122 2C  #C ( (F||Efkkmm557777y||Fwv{;;;;} mu jX\\)44 GGy 2r xctjdrdStjd}|o,tjdt S)zNot now: a video is playing (no network next to the stream), or the user is moving around Pro tebe (the rows must not reshuffle under the cursor). The rebuild waits for the next check.zPlayer.HasVideoTzXWindow.IsActive(home) + String.IsEqual(Container(9000).ListItem.Property(id),mil_foryou)zSystem.IdleTime({}))rgetCondVisibilityrIDLE_BEFORE_REBUILD)browsings r busyrrzs] /00t%'455H  eD23H3O3OPc3d3deeeer cddlm}ddlm}||pt j}|trdS| s ddlm }| drdn t| }|r#|dkstst|nW#t $rJ}t#dt'|j|t jYd}~nd}~wwxYw|t,rdS| dSdS) zService thread.r)r:) userfirstN)warmforyour\zcheck failed: {}: {})rDr:rLrtbackground_threadrMonitor waitForAbort FIRST_DELAYabortRequestedruhiddenrlloadrrrYrPr rrQrRrJ CHECK_EVERY)monitorr:rtrurTrXs r runrs!!!!!!"""""" !!!'GK(($$&&  Z % % % % % %![[22JTTFKKMM8J8JF "6Y..dff.&!!! Z Z Z '..tCyy/A3GG Y Y Y Y Y Y Y Y Z    , ,  F$$&&     s'A#C DADDcddl}ddlddlmm|dfd}|ddt d}||rd nd |rd nd dS) zPlugin action `foryou_build`: rebuild now (the empty-state button). A first build with the Webshare check takes a while, so it only tells the user; the rows refresh by themselves when it is done.rN) S_SECTION_textzplugin.video.milionarc|p|jdddS)NiF)Dialog notificationgetLocalizedStringNOTIFICATION_INFO) string_idfallbackrraddonxbmcguis r notezmanual..notesa%%eeI&6&68P8PQZ8[8[8g_g&-&?u N N N N Nr iuPřipravuji doporučení…r>iiuDoporučení jsou připravenáu+Doporučení se teď nepodařilo připravit) xbmcaddonrwcs.foryou.widgetsrrAddonrY)paramsrrrWrrrrs @@@@r r>r>sNNN33333333 OO3 4 4ENNNNNNNN D-...""HD( %8(G'G'GZGHHHHHr )r8r+)__doc__r threadingrrrrzr~rhrirLockrELOGINFOr rr)r-r7rYrlrprrrr>r,r r rsJ           ????III       X X XD&fff( H H H H H Hr