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

partyfuse: normalize naming in parsers

Browse source
This commit is contained in:
ed 2024-10-01 16:55:00 +00:00
parent 73d05095b5
commit 3dff6cda40
1 changed files with 11 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
bin/partyfuse.py
View file

@ -390,13 +390,12 @@ class Gateway(object):
return r.read()
def parse_jls(self, datasrc):
def parse_jls(self, sck):
rsp = b""
while True:
buf = datasrc.read(1024 * 32)
buf = sck.read(1024 * 32)
if not buf:
break
rsp += buf
rsp = json.loads(rsp.decode("utf-8"))
@ -414,24 +413,24 @@ class Gateway(object):
return ret
def parse_html(self, datasrc):
def parse_html(self, sck):
ret = []
remainder = b""
rem = b""
ptn = re.compile(
r'^<tr><td>(-|DIR|<a [^<]+</a>)</td><td><a[^>]* href="([^"]+)"[^>]*>([^<]+)</a></td><td>([^<]+)</td><td>[^<]+</td><td>([^<]+)</td></tr>$'
)
while True:
buf = remainder + datasrc.read(4096)
# print('[{}]'.format(buf.decode('utf-8')))
buf = sck.read(4096)
if not buf:
break
remainder = b""
endpos = buf.rfind(b"\n")
if endpos >= 0:
remainder = buf[endpos + 1 :]
buf = buf[:endpos]
buf = rem + buf
rem = b""
idx = buf.rfind(b"\n")
if idx >= 0:
rem = buf[idx + 1 :]
buf = buf[:idx]
lines = buf.decode("utf-8").split("\n")
for line in lines: