mirrors/copyparty
1
0
Fork 0
mirror of https://github.com/9001/copyparty.git synced 2026-04-13 15:42:36 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update authsrv.py

Browse source 
Signed-off-by: ed <s@ocv.me>
This commit is contained in:
ed 2026-03-04 06:22:52 +00:00 committed by GitHub
parent ef99b8ef69
commit 81f6129003
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 13 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
copyparty/authsrv.py
View file

@ -147,8 +147,11 @@ class AXS(object):
class Lim(object): class Lim(object):
def __init__(self, log_func: Optional["RootLogger"]) -> None: def __init__(
self, args: argparse.Namespace, log_func: Optional["RootLogger"]
) -> None:
self.log_func = log_func self.log_func = log_func
self.use_scandir = not args.no_scandir
self.reg: Optional[dict[str, dict[str, Any]]] = None # up2k registry self.reg: Optional[dict[str, dict[str, Any]]] = None # up2k registry
@ -312,27 +315,17 @@ class Lim(object):
return ret, d return ret, d
def dive(self, path: str, lvs: int) -> Optional[str]: def dive(self, path: str, lvs: int) -> Optional[str]:
items = bos.listdir(path)
if not lvs: if not lvs:
# at leaf level # at leaf level
nfiles = 0 items = statdir(self.log_func, self.use_scandir, False, path, True)
for name in items: items = [
if name.endswith(".PARTIAL"): x
continue for x in items
if not stat.S_ISDIR(x[1].st_mode) and not x[0].endswith(".PARTIAL")
ap = os.path.join(path, name) ]
try: return None if len(items) >= self.rotn else ""
is_dir = stat.S_ISDIR(bos.stat(ap).st_mode)
except:
nfiles += 1
continue
if not is_dir:
nfiles += 1
return None if nfiles >= self.rotn else ""
items = bos.listdir(path)
dirs = [int(x) for x in items if x and all(y in "1234567890" for y in x)] dirs = [int(x) for x in items if x and all(y in "1234567890" for y in x)]
dirs.sort() dirs.sort()
@ -2299,7 +2292,7 @@ class AuthSrv(object):
vol.flags["zipmax"] = True vol.flags["zipmax"] = True
for vol in vfs.all_vols.values(): for vol in vfs.all_vols.values():
lim = Lim(self.log_func) lim = Lim(self.args, self.log_func)
use = False use = False
if vol.flags.get("nosub"): if vol.flags.get("nosub"):