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

fix_upload_block_process

Browse Source
This commit is contained in:
dobefore 2021-09-14 16:37:20 +08:00 committed by Vikash Kothary
parent 0409ff9592
commit c95ea86a3b
1 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/ankisyncd/sync_app.py
View File

@ -14,22 +14,17 @@
# You should have received a copy of the GNU Affero General Public License # You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>. # along with this program. If not, see <http://www.gnu.org/licenses/>.
from datetime import date
import gzip import gzip
import hashlib
import io import io
import json import json
import logging import logging
import os import os
import random import random
import re import re
import string
import sys import sys
import time import time
import unicodedata import unicodedata
import zipfile import zipfile
from configparser import ConfigParser
from sqlite3 import dbapi2 as sqlite
from webob import Response from webob import Response
from webob.exc import * from webob.exc import *
@ -420,30 +415,35 @@ class Requests(object):
if input is None: if input is None:
return return
if env.get('HTTP_TRANSFER_ENCODING','0') == 'chunked': if env.get('HTTP_TRANSFER_ENCODING','0') == 'chunked':
body =input.read() # method readlines() and read(no len) will block the process
repeat=body.splitlines()[1] leng=int(input.readline(),16)
items=body.split(repeat) while leng >0:
body += input.read(leng+2)
leng = int(input.readline(),16)
boundary=body.splitlines()[0]
items=body.split(boundary)
items.pop() items.pop()
items.pop(0) items.pop(0)
# parse data # parse data
data_raw=items[0] data_raw=items[0].strip()
data_raw_li=data_raw.splitlines() data_raw_li=data_raw.splitlines()
data1=data_raw_li[7] data1=data_raw_li[3]
cd=data_raw_li[3] cd=data_raw_li[0]
start_len=len(data_raw_li[2])+len(cd)+len(data1)+len(data_raw_li[8])+len(data_raw_li[6])+len(b'\r\n')*9 start_len=4*len(b'\r\n')+len(cd)+len(data1)
end_len=-len(data_raw_li[-1])-len(data_raw_li[-4])-len(b'\r\n')*5 data2=data_raw[start_len:]
data=data1+data_raw[start_len:end_len] data=data1+data2
d['data']=data d['data']=data
# #
others=items[1:] others=items[1:]
for i in others: for i in others:
i=i.splitlines() i=i.splitlines()
key=re.findall(b'name="(.*?)"',i[3])[0].decode('utf-8') print(i)
v=i[-5].decode('utf-8') key=re.findall(b'name="(.*?)"',i[2])[0].decode('utf-8')
v=i[-3].decode('utf-8')
d[key]=v d[key]=v
return d return d
if self.query_string !='': if self.query_string !='':
# GET method # GET method
body=self.query_string body=self.query_string