@j4 <dZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZmZddlmZej(dZd \ZZZZZd Zd Zej:d Zd:dZde d e e fdZ!de d e fdZ"de d e e fdZ#de de d e fdZ$de d e e%e e ffdZ&de d e e fdZ'de de d dfdZ(de de d e)fdZ*de de de)d dfdZ+de de d e,d e e)fd!Z-de de d e,d"e)d df d#Z. d;de de d$e d%e e d&e e)d e)f d'Z/du  shoot_service.py — shooting session driven from the photographer's phone (the /shoot web app). Why this exists: the schools may not give us names, so a child cannot be known in advance, and photographing a card before each child (the HEC way) is not acceptable for the client. How a photo finds its child — by ORDER and by what the photographer DECLARES, never by clocks. An earlier design matched photos to phone events by time; one FTP delay and a child's photos landed on the wrong family without anyone noticing. This one cannot do that silently: 1. The photographer scans the CLASS QR on the phone (a "run" starts). 2. After each child they tap how many photos that child had: [1] [2] [3]. (Test shots: "ignore N".) 3. Closing the run (next class, pause, end) takes a FENCE: the exact list of files that were in the FTP folder at that moment and belong to the run. The run therefore owns exactly those files, whatever their delay, and a mistake in one run can never shift the next one. 4. The server turns the run into children ONLY if the declared total equals the files of the fence. If it does not, nothing is assigned: the files are parked and the operator is alerted. The phone shows "declared N · received M" live, so the mismatch is fixed while the child is still in front of the camera. Files inside a run are ordered by the camera's own capture order (EXIF, then file name): that is a sequence, not a comparison with any other device's clock. Faces are never compared (biometric data of minors). N) dataclassfield)Path)Optional)get_db ensure_column TABLE_OPTIONS) utcnow_isozmeeconic.shoot)classchildskipundoendi: z0^MEEC:CLASS:([a-z0-9][a-z0-9-]{0,63}):(.{1,40})$returnct5}|jdtt|ddd|j dddy#1swYyxYw)Na CREATE TABLE IF NOT EXISTS shoot_events ( id BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY, school_id VARCHAR(64) NOT NULL, photographer VARCHAR(64) NOT NULL, at_ts DOUBLE NOT NULL, kind VARCHAR(10) NOT NULL, target VARCHAR(64), meta MEDIUMTEXT, created_at VARCHAR(40) NOT NULL, KEY idx_shoot_events (school_id, photographer, id) ) shoot_eventsmeta MEDIUMTEXT)rexecuter rcommit)conns 1/var/www/photos/backend/services/shoot_service.pyinit_shoot_tablesr/sT T   /   dNFLA s 7A  A school_idctd|S)N shoot_token:)_kv_get)rs r get_tokenrCs \)- ..cNtjd}td|||S)Nr)secrets token_urlsafe_kv_set)rtokens r rotate_tokenr'Gs(  ! !" %E l9+ &. Lr r&cl|xsdj}t|dkst|dkDryt5}|jdj }dddd}D]=}t j t|d|s&|djdd d }?|S#1swYOxYw) zXThe school a token opens, or None. Compared in constant time against every stored token.rPNz@SELECT `key`, value FROM app_kv WHERE `key` LIKE 'shoot_token:%'valuekey:) striplenrrfetchallhmaccompare_digeststrsplit)r&rrowsfoundrs rschool_for_tokenr9Ms [b   !E 5zB#e*r/ kT||^_hhjk E .   s1W: 6eHNN3*1-E. L kks B**B3 class_namecd|d|S)Nz MEEC:CLASS:r-)rr:s rclass_qr_payloadr=]s  1ZL 11r textctj|xsdj}|r?|jddj |jdj fSdS)Nr)r. ) _CLASS_QR_REmatchr/groupjoinr5)r>ms rparse_class_qrrGasSDJB--/0A9:AGGAJ!1!1!34 5DDr r,ct5}|jd|fj}dddr|dSdS#1swYxYw)Nz$SELECT value FROM app_kv WHERE key=?r+)rrfetchone)r,rrows rrrhsO VTllAC6JSSUV3w<(D(VVs ">Ar+ct5}|jd||f|jdddy#1swYyxYw)Nz7INSERT OR REPLACE INTO app_kv (key, value) VALUES (?,?))rrr)r,r+rs rr%r%ns= T NQTV[P\] s %9A photographerctd|d|}dgd} i||rtj|SiS#t$r|cYSwxYw)zI`processed`: id of the last run already turned into children (or parked). shoot_state:r-r) processedblockedrjsonloads ValueError)rrLrawbases r get_staterWts^ L 1\N; RSr kindtargetrc t5}|jd||tj|||rtj|ndt f}|j |j||dcdddS#1swYyxYw)NzpINSERT INTO shoot_events (school_id, photographer, at_ts, kind, target, meta, created_at) VALUES (?,?,?,?,?,?,?))idrdre)rrtimerRr[r r lastrowid)rrLrdrerrcurs r record_eventrksz ETll %  diik4UYDAQ_ceoeq rt mmTVD EEEs A*A??Bsincec z|tjdz n|}t5}|jd|||fj}dddg}D]E} |drt j |dni}|j|d|d|d|d|dG|S#1swYWxYw#t $ri}Y@wxYw) NiztSELECT id, at_ts, kind, target, meta FROM shoot_events WHERE school_id=? AND photographer=? AND at_ts>=? ORDER BY idrrgat_tsrdre)rgatrdrer)rhrrr1rRrSrTappend)rrLrlrr6outr8rs r events_forrrs).TYY[9 $EE HT|| %|U;==EXZ H C n ,-fI4::ai(2D !D'7QvYRST\R]gklm n JHH D s$B B, B), B:9B:limitc t5}|jd|t|fj}dddDcgc]}|d|d|d|d|ddc}S#1swY.xYwcc}w)NziSELECT id, photographer, at_ts, kind, target FROM shoot_events WHERE school_id=? ORDER BY id DESC LIMIT ?rgrLrnrdre)rgrLrordre)rrintr1)rrsrr6r8s r recent_eventsrvs LT|| ')2CJ(?AAI L .2 3()T7An,=QwZYZ[aYb{ $ 33 LL 3s,A$A0$A-ct5}|jdtjtz fj}|j ddd|S#1swYSxYw)Nz&DELETE FROM shoot_events WHERE at_tszRun.declared..s,A1,ssumrselfs rdeclaredz Run.declareds,,,,r c:td|jDS)Nc3:K|]\}}|tk(sdyw)r.N) KIND_CHILD)rkrs rrzRun.children..s?AqJ1?srrs rchildrenz Run.childrens????r )__name__ __module__ __qualname__ru__annotations__r4rlistrrtuplerboolrrpropertyrrr<r rr}r}s GOd3FDI3#(#>E4c3h >FD!%E8DI % -#--@#@@r r}eventsc g}d}t|dD]O}|d}|tk(rh||jsd|_t|d|dxsdt |j d ij d g }|j |z| |jr|ttfvr3 t|d}|d k\s|jj ||f|tk(r(|js|jj|tk(sd|_|j d ij d }t!|tr t |nd|_R|S#ttf$rYgwxYw)zDFold the event stream (in insertion order, never by time) into runs.Nc |dS)Nrgr<)xs rzbuild_runs..s !D'r r,rdTrgrer)rr)rgr:rr.r)sorted KIND_CLASSrr}rgetrpr KIND_SKIPru TypeErrorrTr KIND_UNDOpopKIND_END isinstancer)rrunsrjerdrzrs r build_runsrsYDC F 1 2Iy : szz! 4Qx[->BtAEERXZ\L]LaLabjlnLoGpqC KK  [CJJ  j), , ( $Av   $+ Y yy  X CJEE&"%))'2E'1%'>U DCI-I. Kz*  s+E((E;:E;cHt|}|r|djs|dSdS)N)rr)rrs ropen_runrs' f DDHOO48==r rrOct}|D]G}|js|j|kDs |js-|j |jI|S)zOFiles already owned by a closed run that has not been turned into children yet.)setrrgrupdate)rrOrqr8s r claimed_namesrsGEC   88y(QWW JJqww   Jr pathsc<dtfdt|fdS)zUThe camera's own capture order: EXIF time when present, then the (natural) file name.namectjd|Dcgc]-}|jr t|n|j /c}Scc}w)Nz(\d+))rer5isdigitrulower)rts rnaturalz#sort_capture_order..naturals9>@hhxQU>VW!))+A17794WWWs2Ac@|xsd|jfS)Nr)r)p exif_timers rrz$sort_capture_order..s ! (97166?'Kr r)r4r)rrrs `@rsort_capture_orderrsXcX %K LLr cddlm}ddlm}ddlm}|j Dchc]}|j}}||}g} |jD]} | js| jj|vs1| jjdrM|j|| j|k(sm|j| j t!|Scc}w#t$rgcYSwxYw)zZImage files currently waiting in the school's FTP folder that belong to this photographer.r)config)photographer_service)incoming_dir_for.)corerservicesrservices.organizer_servicerIMAGE_EXTENSIONSriterdiris_filesuffixr startswithresolve_photographerrpOSErrorr) rrLrrrrextsfoldernamesfs r pool_namesrs-;%66 7!AGGI 7D 7 i (F E! %A  0D 8ARARSVAW,AA)QVVTXdd QVV$ % %= 8  s/C+#C0)C0C0"C0C00 C>=C>ct||}t|}t||d}|r|djs|dnd}|ddddddSt t ||}|t ||z t |jz }|j|jd|jt||j|jt|k(dS)zZWhat the phone shows while shooting: the open run, what was declared and what has arrived.rOrNrT)activerreceivedrok)r:run) rrrrWrrrrrr:rgrr0r)rrLrrrOrpoolowns r live_countsrs  < 0F f D)\2;?I48??$r(C {A1!SWXX z)\2 3D tY/ /#cjj/ AC%(^^CFFCQTQ]Q]Ccll#,,RUVYRZBZ \\r c ddlm}ddlm}t 5}|||j |}|j d|ddt|f|j d||f|jddd|S#1swYSxYw)z]A new family code attached to `class_name`, created by the shooting itself (nobody types it).r)school_service)generate_unique_codezYINSERT INTO families (code, family_name, email, created_at, school_id) VALUES (?,?,?,?,?)r)Nz;INSERT INTO students (family_code, class_name) VALUES (?,?)) rrutils.code_generatorrrcode_prefix_forrr r)rr:rrrcodes rcreate_child_familyr$s'9 T#D.*H*H*ST pBjlI> @ RUY[eTfg  K  Ks AA==B)rN)NNr) )>__doc__r2rRloggingrr#rh dataclassesrrpathlibrtypingrcore.dbrrr core.timeutilr getLoggerloggerrrrrrrxMAX_SKIPcompilerBrr4rr'r9r=rrGrr%dictrWr\rur`rcrkfloatrrrrvr{r}rrrrrrrrr<r rrs@,   (88$   + ,9`6 J 9h  rzzMN (//#/CC C HSM  2222EE%S/!:E))#) ST CDJJCJJJCsCHTNTCTsTCT4TTXT X\(,ECEsE#ExPS}E~E15E # S % TXY]T^  3S33d4j3 c  @@ @"tDzd3i<>T$Z>HSM> S cc#hMd4jMT M#ST#Y$ \3 \c \d \ 3 C C r