mirror of
https://github.com/9001/copyparty.git
synced 2025-10-30 12:12:20 -06:00
50 lines
1.2 KiB
Python
50 lines
1.2 KiB
Python
import os
|
|
import time
|
|
|
|
from .util import Cooldown
|
|
from .th_srv import thumb_path, THUMBABLE, FMT_FF
|
|
|
|
|
|
class ThumbCli(object):
|
|
def __init__(self, broker):
|
|
self.broker = broker
|
|
self.args = broker.args
|
|
|
|
# cache on both sides for less broker spam
|
|
self.cooldown = Cooldown(self.args.th_poke)
|
|
|
|
def get(self, ptop, rem, mtime, fmt):
|
|
ext = rem.rsplit(".")[-1].lower()
|
|
if ext not in THUMBABLE:
|
|
return None
|
|
|
|
if self.args.no_vthumb and ext in FMT_FF:
|
|
return None
|
|
|
|
if fmt == "j" and self.args.th_no_jpg:
|
|
fmt = "w"
|
|
|
|
if fmt == "w" and self.args.th_no_webp:
|
|
fmt = "j"
|
|
|
|
tpath = thumb_path(ptop, rem, mtime, fmt)
|
|
ret = None
|
|
try:
|
|
st = os.stat(tpath)
|
|
if st.st_size:
|
|
ret = tpath
|
|
else:
|
|
return None
|
|
except:
|
|
pass
|
|
|
|
if ret:
|
|
tdir = os.path.dirname(tpath)
|
|
if self.cooldown.poke(tdir):
|
|
self.broker.put(False, "thumbsrv.poke", tdir)
|
|
|
|
return ret
|
|
|
|
x = self.broker.put(True, "thumbsrv.get", ptop, rem, mtime, fmt)
|
|
return x.get()
|