mirrors/copyparty
1
0
Fork 0
mirror of https://github.com/9001/copyparty.git synced 2025-08-17 09:02:15 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

print thumbnail cleanup summary

Browse source
This commit is contained in:
ed 2021-06-16 18:57:10 +02:00
parent 415757af43
commit 38c00ea8fc
1 changed files with 13 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
copyparty/th_srv.py
View file

@ -339,29 +339,32 @@ class ThumbSrv(object):
interval = self.args.th_clean interval = self.args.th_clean
while True: while True:
time.sleep(interval) time.sleep(interval)
ndirs = 0
for vol, histpath in self.asrv.vfs.histtab.items(): for vol, histpath in self.asrv.vfs.histtab.items():
if histpath.startswith(vol): if histpath.startswith(vol):
self.log("\033[Jcln {}/\033[A".format(histpath)) self.log("\033[Jcln {}/\033[A".format(histpath))
else: else:
self.log("\033[Jcln {} ({})/\033[A".format(histpath, vol)) self.log("\033[Jcln {} ({})/\033[A".format(histpath, vol))
self.clean(histpath) ndirs += self.clean(histpath)
self.log("\033[Jcln ok") self.log("\033[Jcln ok; rm {} dirs".format(ndirs))
def clean(self, histpath): def clean(self, histpath):
# self.log("cln {}".format(histpath)) thumbpath = os.path.join(histpath, "th")
# self.log("cln {}".format(thumbpath))
maxage = self.args.th_maxage maxage = self.args.th_maxage
now = time.time() now = time.time()
prev_b64 = None prev_b64 = None
prev_fp = None prev_fp = None
try: try:
ents = os.listdir(histpath) ents = os.listdir(thumbpath)
except: except:
return return 0
ndirs = 0
for f in sorted(ents): for f in sorted(ents):
fp = os.path.join(histpath, f) fp = os.path.join(thumbpath, f)
cmp = fp.lower().replace("\\", "/") cmp = fp.lower().replace("\\", "/")
# "top" or b64 prefix/full (a folder) # "top" or b64 prefix/full (a folder)
@ -376,10 +379,11 @@ class ThumbSrv(object):
break break
if safe: if safe:
ndirs += 1
self.log("rm -rf [{}]".format(fp)) self.log("rm -rf [{}]".format(fp))
shutil.rmtree(fp, ignore_errors=True) shutil.rmtree(fp, ignore_errors=True)
else: else:
self.clean(fp) ndirs += self.clean(fp)
continue continue
# thumb file # thumb file
@ -401,3 +405,5 @@ class ThumbSrv(object):
prev_b64 = b64 prev_b64 = b64
prev_fp = fp prev_fp = fp
return ndirs