j~ddlZddlZddlZddlZddlmZmZmZmZddl Z ddl Z dee de fdZ GddZedk(r.ed Zej# ej$d y#e$rej)YywxYw) N)ListOptionalCallableAnypathsreturncd}|D]}|rtjj|s% tj|D]P\}}}|D]E}tjj ||} |tjj |z }GR|S#t tf$rY_wxYw#t$r}td|d|Yd}~d}~wwxYw)uECalcula el tamaño total combinado en bytes de uno o más directoriosru1[WATCHER] Error calculando tamaño de directorio z: N) ospathexistswalkjoingetsizeOSErrorFileNotFoundError Exceptionprint) rtotalr root_filesffpes 0/var/www/html/ioplay-suite/ioplay-dcm/watcher.pyget_directories_total_sizer s E S277>>$/  S"$''$- aAdA.B!44  S L $%67 S EdV2aSQ R R Ss<AB,-"BB,B) &B,(B) )B,, C5C  Cc eZdZddeededefdZddefdZdZ d Z ddeed eedee e d e fd Zdefd Zy)StorageWatcherN storage_pathsinterval_secondsdebounce_secondsc|tj|_nt|trIt j d|Dcgc]#}|js|j%c}|_n@t|ttfrt||_ntj|_||_ ||_ d|_ d|_ d|_tj |_ycc}w)Nz[,;]Fr)indexerget_configured_storage_pathsr isinstancestrresplitstriplisttupleintervaldebouncerunningthread last_size threadingLocklock)selfrr r!ps r__init__zStorageWatcher.__init__s  !(!E!E!GD   s +57XXg}5U!cYZY`Y`Yb!'')!cD   e} 5!%m!4D !(!E!E!GD ( (  26 NN$ "ds C3C3run_initial_scanc (|jryd|_tj|j|fd|_|jj t dt|jd|jd|jdy)NT)targetargsdaemonz+[WATCHER] Observador multiruta iniciado en z directorio(s): z (Intervalo: zs)) r.r1Thread _run_loopr/startrlenrr,)r4r7s rr>zStorageWatcher.start-s <<  &&dnnDTCV_cd   ;C@R@RrD)r4r rLrs r update_configzStorageWatcher.update_configCs  ',xYw#t $r7}td |tj|jYd}~|d}~wwxYw) Nu:[WATCHER] Ejecutando escaneo inicial de indexación sobre z rutas...z$[WATCHER] Error en escaneo inicial: rFu=[WATCHER] Cambio detectado en almacenamiento: tamaño previo=z bytes, nuevo=z bytes. Esperando debounce de zs...uC[WATCHER] Disparando indexador por cambio de tamaño en carpetas...z'[WATCHER] Error en ciclo de monitoreo: )rr?rr#rGrrr0rHrIr&r.timesleepr,r-r3)r4r7r current_sizes rr=zStorageWatcher._run_loop\s  BRSVW[WiWiSjRkktuv..t/A/AB4D4F4FG *C,?@ll * 4==)||9$:L:LM  4>>1YZ^ZhZhYiiwyExFFdeiererdsswxyJJt}}-$>d>P>P#QLQ ce66t7I7IJ)5 $:CrDrKrr&dictrPr=r@rrrs%hsm%c%jm%"YdY0  hsm XVZ^ s{}ABE}FtG SW 2#*$#*r@r__main__)r )r r'rRr1typingrrrrr#rHr&rOrrrWwatcherr>rSKeyboardInterruptrDr\r@rrcs 00 d3iC$d*d*L za0G MMO DJJqM   sA..BB