From a65583c325a58f68eabdeea40fab3728ced2ed59 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 24 Jul 2026 12:38:33 -0400 Subject: [PATCH] Clean up some headers missed in the rebase to aio http --- confluent_server/confluent/selfservice.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/confluent_server/confluent/selfservice.py b/confluent_server/confluent/selfservice.py index 1d7aad75..5a98291f 100644 --- a/confluent_server/confluent/selfservice.py +++ b/confluent_server/confluent/selfservice.py @@ -116,10 +116,10 @@ async def handle_request(req, make_response, mimetype): configmanager.check_quorum() cfg = configmanager.ConfigManager(None) reqpath = req.rel_url.path - nodename = req.headers.get('CONFLUENT_NODENAME', None) + nodename = req.headers.get('CONFLUENT_NODENAME', req.headers.get('CONFLUENT-NODENAME', None)) clientip = req.headers.get('X-Forwarded-For', None) if reqpath == '/self/whoami': - clientids = req.headers.get('HTTP_CONFLUENT_IDS', None) + clientids = req.headers.get('CONFLUENT_IDS', req.headers.get('CONFLUENT-IDS', None)) if not clientids: rsp = await make_response(mimetype, 400, 'Bad Request') await rsp.write(b'Bad Request') @@ -134,10 +134,10 @@ async def handle_request(req, make_response, mimetype): rsp = await make_response(mimetype, 404, 'Unknown') return rsp if reqpath == '/self/registerapikey': - crypthmac = req.headers.get('HTTP_CONFLUENT_CRYPTHMAC', None) + crypthmac = req.headers.get('CONFLUENT_CRYPTHMAC', req.headers.get('CONFLUENT-CRYPTHMAC', None)) if int(req.content_length) > 64: rsp = await make_response(mimetype, 400, 'Bad Request') - await rsp.write('Bad Request') + await rsp.write(b'Bad Request') return rsp cryptkey = await req.read() if not (crypthmac and cryptkey):