xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-04-24 17:51:29 +00:00
Code Issues Projects Releases Wiki Activity

Change webauthn to aiohttp

Browse Source 
Co-authored-by: Copilot <copilot@github.com>
This commit is contained in:
Jarrod Johnson
2026-04-22 10:55:49 -04:00
parent 06786f202c
commit 3fecec7743
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
confluent_server/confluent/httpapi.py
View File

@@ -629,7 +629,7 @@ async def resourcehandler(request):
# any 'yield' needs to become a write to the streamresponse
#TODO:asyncmerge: Replace /confluent-api with '' in path
# Needs testing for confluent header names with golang clients
async def make_response(mimetype, status=200, reason=None, headers=None, cookies=None, body=None):
async def make_response(mimetype='application/json', status=200, reason=None, headers=None, cookies=None, body=None):
rspheaders = {
'Cache-Control': 'no-store',
'Pragma': 'no-cache',
@@ -1012,8 +1012,9 @@ async def resourcehandler_backend(req, make_response):
if not webauthn:
rsp = await make_response('text/plain', 501, 'Not Implemented')
return rsp
for rspd in webauthn.handle_api_request(url, env, start_response, authorized['username'], cfgmgr, headers, reqbody, authorized):
rsp.write(rspd)
try:
wauthbody = webauthn.handle_api_request(url, req, authorized['username'], cfgmgr, reqbody, authorized)
await rsp.write(wauthbody.encode('utf8'))
return rsp
resource = '.' + url[url.rindex('/'):]
lquerydict = copy.deepcopy(querydict)