ouczbs/anki-sync-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

sync apkg

Browse Source
This commit is contained in:
ouczbs 2023-07-30 03:28:49 +00:00
parent 08ed42de9d
commit c41c2d40f1
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/ankisyncd/sync_app.py
View File

@ -531,8 +531,9 @@ class Requests(object):
request_items_dict = self.parsePC(body, env) request_items_dict = self.parsePC(body, env)
else: else:
request_items_dict = self.parseAndroid(body, env) request_items_dict = self.parseAndroid(body, env)
length = request_items_dict if len(body) < 10240 else len(body) self.body = body
logger.info(f">>>>>::request body or size: {length}") length = request_items_dict if len(body) < 1024 else len(body)
#logger.info(f">>>>>::request body or size: {length}")
self.request_items_dict = request_items_dict self.request_items_dict = request_items_dict
return request_items_dict return request_items_dict
@ -555,9 +556,9 @@ class chunked(object):
w = self.__wrapped__(*args, **kwargs) w = self.__wrapped__(*args, **kwargs)
if type(w) is str: if type(w) is str:
w = w.encode() w = w.encode()
length = w if len(w) < 10240 else len(w) length = w if len(w) < 1024 else len(w)
body = b.wrap_body(w, environ) body = b.wrap_body(w, environ)
logger.info(f"<<<<<::response body or size: {length} compress size{len(body)}") #logger.info(f"<<<<<::response body or size: {length} compress size{len(body)}")
resp = Response(body, "200 OK" ,[ resp = Response(body, "200 OK" ,[
("anki-original-size", str(len(body))), ("anki-original-size", str(len(body))),
]) ])
@ -665,8 +666,10 @@ class SyncApp:
try: try:
data = req.POST["data"] data = req.POST["data"]
data = json.loads(data.decode()) data = json.loads(data.decode())
except KeyError: except Exception as e:
data = {} self.error_env = {"error":e,"data":data,"body":req.body,"path":req.path}
logger.error(f"error request data: {e}")
data = {"data":data}
if req.path.startswith(self.base_url): if req.path.startswith(self.base_url):
url = req.path[len(self.base_url) :] url = req.path[len(self.base_url) :]
if url not in self.valid_urls: if url not in self.valid_urls: