yumoqing/ahserver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2023-06-01 02:10:07 +08:00
commit 4a528907a4
3 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ahserver/configuredServer.py
View File

@ -29,7 +29,11 @@ class ConfiguredServer(AppLogger):
DBPools(config.databases) DBPools(config.databases)
initEnv() initEnv()
setupTemplateEngine() setupTemplateEngine()
client_max_size = 1024 * 1024 * 15 client_max_size = 1024 * 10240
if config.website.client_max_size:
client_max_size = config.website.client_max_size
print(f'{client_max_size=}')
self.app = web.Application(client_max_size=client_max_size) self.app = web.Application(client_max_size=client_max_size)
auth = auth_klass() auth = auth_klass()
auth.setupAuth(self.app) auth.setupAuth(self.app)

6
ahserver/filestorage.py
View File

@ -22,7 +22,7 @@ class TmpFileRecord:
self.filename = self.savefilename() self.filename = self.savefilename()
self.loop = asyncio.get_event_loop() self.loop = asyncio.get_event_loop()
self.loop.call_later(0.01, self.load) self.loop.call_later(0.01, self.load)
print('TmpFileRecord() .........................') # print('TmpFileRecord() .........................')
def newtmpfile(self, path:str): def newtmpfile(self, path:str):
self.filetime[path] = time.time() self.filetime[path] = time.time()
@ -44,7 +44,7 @@ class TmpFileRecord:
self.change_flg = False self.change_flg = False
async def load(self): async def load(self):
print('load() called ............') # print('load() called ............')
fn = self.filename fn = self.filename
if not os.path.isfile(fn): if not os.path.isfile(fn):
return return
@ -110,6 +110,6 @@ class FileStorage:
siz += len(d); siz += len(d);
await f.write(d) await f.write(d)
await f.flush() await f.flush()
# print(f'{name=} file({fpath}) write {siz} bytes') # print(f'{name=} file({fpath}) write {siz} bytes')
self.tfr.newtmpfile(fpath) self.tfr.newtmpfile(fpath)
return fpath return fpath

5
ahserver/processorResource.py
View File

@ -102,7 +102,6 @@ class ProcessorResource(AppLogger, StaticResource,Url2File):
def abspath(self, request, path:str): def abspath(self, request, path:str):
url = self.entireUrl(request, path) url = self.entireUrl(request, path)
fname = self.url2file(url) fname = self.url2file(url)
print(f'abspath():, {path=}, {url=}, {fname=}')
return fname return fname
async def getPostData(self,request: Request) -> dict: async def getPostData(self,request: Request) -> dict:
@ -227,7 +226,6 @@ class ProcessorResource(AppLogger, StaticResource,Url2File):
self.user = await auth.get_auth(request) self.user = await auth.get_auth(request)
self.y_env.user = self.user self.y_env.user = self.user
self.request_filename = self.url2file(str(request.path)) self.request_filename = self.url2file(str(request.path))
print(f'225:{request.path=}, {self.request_filename=}')
path = request.path path = request.path
config = getConfig() config = getConfig()
if config.website.dbadm and path.startswith(config.website.dbadm): if config.website.dbadm and path.startswith(config.website.dbadm):
@ -312,13 +310,11 @@ class ProcessorResource(AppLogger, StaticResource,Url2File):
return False return False
def url2processor(self, request, url, fpath): def url2processor(self, request, url, fpath):
print('fpath=', fpath)
config = getConfig() config = getConfig()
url = self.entireUrl(request, url) url = self.entireUrl(request, url)
host = '/'.join(str(request.url).split('/')[:3]) host = '/'.join(str(request.url).split('/')[:3])
path = request.path path = request.path
real_path = self.abspath(request, path) real_path = self.abspath(request, path)
print(f'url2processor():{path=}, {real_path=}')
if config.website.startswiths: if config.website.startswiths:
for a in config.website.startswiths: for a in config.website.startswiths:
if path.startswith(a.leading): if path.startswith(a.leading):
@ -351,7 +347,6 @@ class ProcessorResource(AppLogger, StaticResource,Url2File):
async def path_call(self, request, path, params={}): async def path_call(self, request, path, params={}):
url = self.entireUrl(request, path) url = self.entireUrl(request, path)
fpath = self.url2file(url) fpath = self.url2file(url)
print(f'path_call():{path=}, {url=}, {fpath=}')
processor = self.url2processor(request, url, fpath) processor = self.url2processor(request, url, fpath)
return await processor.path_call(request, params=params) return await processor.path_call(request, params=params)