5Ij3 "UdZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZmZmZmZmZddlmZdd lmZdd lmZmZej4d Zd ZeDchc]}|j;c}Zej>d Z d$de e!de e!de"fdZ#dede$e e!e e!ffdZ%d%dede"de&de"de$e"e'ff dZ(dede!de&fdZ)de"fdZ*de"fdZ+da,gZ-e.e$e!e"fe/d<d&dZ0de"fd Z1de"fd!Z2de"fd"Z3d&d#Z4ycc}w)'u^ cleanup_service.py — mantenimiento periódico. 1. Suppression automatique des photos (RGPD mineurs) : images plus vieilles que la rétention DE L'ÉCOLE de la famille (réglage « rgpd_days », modifiable dans l'admin ; défaut PHOTO_RETENTION_DAYS) dans PHOTOS_DIR (layout `photos/{école}/{photographe}/{CODE}/` et l'ancien `photos/{CODE}/`), la corbeille et INCOMING_DIR. Chaque suppression est tracée (audit « critical ») ; au-delà de RGPD_ALERT_THRESHOLD fichiers, une alerte e-mail part. 2. Aperçus (réduits / visages floutés) et cache `.protect/` orphelins : on ne garde jamais une copie d'une photo qui n'existe plus. 3. Corbeille : purgée après TRASH_RETENTION_DAYS, sans jamais dépasser la rétention RGPD de l'école. 4. Commandes jamais payées : annulées après UNPAID_ORDER_TTL_HOURS (le PaymentIntent Stripe est annulé) — sauf si Stripe indique qu'il est payé : la commande est alors enregistrée comme payée (voir expire_unpaid_orders). 5. Purge des compteurs de rate limiting périmés. Tourne une fois au démarrage puis toutes les 24 h (sur le worker leader). N) timedelta)Path)Optional)config) PHOTOS_DIR INCOMING_DIR THUMBS_DIRPHOTO_RETENTION_DAYSIMAGE_EXTENSIONS)get_db)utcnow) audit_service alert_servicezmeeconic.cleanupQz>^(?P.+?)\.(?Pwm|pv|h[0-9a-f]{10})(?:\.\d+)?\.webp$ family_code school_idreturnc ddlm}|rt|j|dS|r|j |S tS#t $r'}t jd|||Yd}~tSd}~wwxYw)uaRétention de l'école (directe, ou celle de la famille) ; à défaut, la valeur globale du .env.r)school_service rgpd_daysz+Per-school retention unreadable (%s/%s): %sN) servicesrint get_settingsretention_days_for_family Exceptionlogwarningr )rrres 3/var/www/photos/backend/services/cleanup_service.py_retention_daysr 's{^+ ~229=kJK K !;;KH H   ^ A9k[\]] ^s$AA A1 A,,A1relc|j}|sy|ddk(r/t|dk\r |d|dfSt|dkDr|dnddfSt|dk\r |d|dfSd|dfS) u (école, code famille) d'après le chemin relatif à PHOTOS_DIR. école/photographe/CODE/… → nouveau layout .trash/école/lot/photographe/CODE/… → corbeille CODE/… → ancien layout (l'école se déduit de la base) NNrz.trashN)partslen)r!r(s r_locater*4s IIE  Qx8'*5zQa%(#hUVWU1X]acg directory default_days by_family keep_depthcr|jsdifStj}d}i}i}|jdD]}|jr |jj t vs4d} |r9t|j|} | |vr| \} } t| | || <|| } n|} |jj|| dzz kr4|j|dz }| r| dr|j| ddz|| <t#|jdd D]L}|j%st'|j|j(|kDs< |j+N||fS#t$r"} tj!d|| Yd} ~ bd} ~ wwxYw#t$rYwxYw) uSupprime les images trop vieilles. Si `by_family`, la rétention est celle de l'école de chaque famille. Les dossiers vides sont élagués, sauf ceux à moins de `keep_depth` niveaux : `incoming/{école}/` est le dossier de dépôt FTP de l'appareil, il doit survivre vide (incident : élagué par ce nettoyage, l'organizer a enchaîné des centaines d'erreurs « No such file or directory » et l'appareil ne pouvait plus déposer). Retourne (total supprimé, {(école, famille): n}).r*Nrrrr%zSuppression impossible %s: %sTreverse)existstimerglobis_filesuffixlower _IMG_EXTSr* relative_tor statst_mtimeunlinkgetOSErrorrrsortedis_dirr)r(rmdir)r,r-r.r/nowdeleted per_familycachefkeyschoolfamilydaysrds r _delete_oldrOEs    "u ))+CGJE __S !?  0I =  !-- 23C%!$,6Rc :DD ?vvx  3#55 1 3q6&0nnS!& > ?   s+4AE<&F*< F'F""F'* F65F6 photos_dirstemch tfd|jDS#t$rYywxYw)Nc3^K|]$}|js|jk(&ywN)r8rQ).0rIrQs r z#_original_exists..ps!Oa199;166T>Os--F)anyiterdirrA)rPrQs `r_original_existsrYns4O:+=+=+?OOO s !% 11cjd}tjrtjdD]}|jstj |j }|r|jdn |j}t|xr|jddk(} t|jjtz }|s t||r |j|dz }t#tjddD]$}|j%s |j'&tjrtjd D]}|j%s|j)D]M}|j j+d d}t|j|r8 |j|dz }O |j'|S#t$rYwxYw#t $rYwxYw#t $rYwxYw#t $rYwxYw#t $rYwxYw) ucSupprime aperçus et cache `.protect/` dont l'original n'existe plus. Retourne le nombre supprimé.rr1rQkindwmr%Tr3z.protect_heads_)r r5r7r8 _PREVIEW_REmatchnamegrouprQboolrparentr< ValueErrorrYr?rArBrCrDrXsplit)removedrImrQlegacy originalsrNprotects rprune_orphan_derivativesrkusG!!#& A99;!!!&&)A&'1776?QVVD!74 78F &)=)=j)II -i>HHJqLG " ((-t< AxxzGGI  !'' 3 G>>#__& vv||I.q1'= 1       N=    #  sZ!&G'G7#H;HH&' G43G47 HH HH H#"H#& H21H2c ddlm}m}d} |jD]A}t t j t|d}||j|d|z }C |S#t$r!}tjd|Yd}~|Sd}~wwxYw)Nr) photo_servicerid)rzTrash purge failed: %s) rrmr list_schoolsminrTRASH_RETENTION_DAYSr purge_trashrrr)rmrpurgedsrMrs r purge_trashesrus6 F1,,. ?Av22OaPTg4VWD m//$> >F ? M 1 ,a00 M1sAA## B ,BB _paid_at_stripec|ayrT)_payment_reconciler)fns rset_payment_reconcilerrzsr+c  tttjz j }t 5}|j d|fj}dddd}tjrddl }tj|_ g}D]}|d}|r| |jj|}|ddk(rQtj|t|j!dxs|d ft"j%d |d ||dd k7r|jj'||j|d |r\t 5}|D]} |j d| f|j+dddt"j-dt/|t/|S#1swY\xYw#t($r&}t"j%d |d ||Yd}~Zd}~wwxYw#1swYrxYw)aCancels orders never paid after the TTL. Returns how many were cancelled. Incident behind the Stripe check: two orders were charged at Stripe (`succeeded`) but the webhook never reached us (STRIPE_WEBHOOK_SECRET empty), so this job marked them `expired`/`cancelled` and the family paid for photos that were then refused. An order is now expired only when Stripe says the PaymentIntent is NOT paid; when Stripe cannot be asked, the order is left for the next cycle rather than guessed.)hourszSELECT id, stripe_payment_intent_id FROM orders WHERE payment_status IN ('unpaid','failed') AND status='pending' AND created_at < ?Nrstripe_payment_intent_idstatus succeededamount_receivedamountuTOrder %s is paid at Stripe (%s) but was never confirmed — booking it, not expiringrncanceledzAOrder %s left for the next cycle, Stripe could not confirm %s: %szIUPDATE orders SET status='cancelled', payment_status='expired' WHERE id=?z%d unpaid order(s) expired)r rrUNPAID_ORDER_TTL_HOURS isoformatr executefetchallSTRIPE_SECRET_KEYstripeapi_key PaymentIntentretrievervappendrr@rrcancelrcommitinfor)) cutoffconnrowsr to_expirerpi_idpirorder_ids rexpire_unpaid_ordersrsh)F)FGG R R TF yT|| bdjclnnvnvnx y F 11I ",- V' ))2259h<;.#**E3rvv>O7P7`TVW_T`3a+bcKK vxyz~xBGHh<:-((//6 4!"  X % w hksjuv w KKM  -s9~> y>Cyy,  _abcgahjoqrs    s6"F:$A3G#G+G9:G G6G11G69HcfKd}trstj\}}tjd|dd|dtt j d|X t ||d{|dz }trs|S7#t$r#}t j d ||d Yd}~2d}~wwxYww) zZRuns the webhook's booking for every order found paid at Stripe by `expire_unpaid_orders`.rzstripe-unconfirmed:z-Stripe payment was never confirmed by webhookzpayment_intent=z succeeded at Stripe but the order was still unpaid. Check that the webhook endpoint is configured and STRIPE_WEBHOOK_SECRET is set.NuRNo payment reconciler registered — %s stays unpaid until the webhook is replayedr%zBooking %s failed: %sTexc_info)rvpoprnotifyrxrerrorr)bookedrrrs rbook_orders_paid_at_stripers F '++- v!% )+ZeW%G H I  & IIjlq r  H%eV4 4 4 aKF  M 5 H II-ua$I G G HsHAB1B-B. B7B1>B1B B. B)$B1)B..B1c tttd\}}ttt d\}}||z}|rt j d||jD]D\\}}} ddlm }|xs||} tjdd ||t || d d | F|r%tjddd|t d d |tjkDrrsz" dd 1g*+ 0 11QWWY 1 bjjZ[   #  (3-  [^  % x} <="&4&s&t&Y\&ejknptkteu&RST+#+\ s )+eCHo&+ )c)X#(*#*Z /I 2s&D