darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-02-01 23:55:58 -05:00
Code Issues Packages Projects Releases Wiki Activity

merge from main

Browse Source
This commit is contained in:
Kenneth Kehl
2024-08-02 13:53:58 -07:00
parent e7ef25af01 4dcadfd5c8
commit d27e5fa151
1 changed files with 19 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
notifications_utils/request_helper.py
View File

@@ -62,22 +62,30 @@ class ResponseHeaderMiddleware(object):
self._app = app self._app = app
def __call__(self, environ, start_response): def __call__(self, environ, start_response):
req = NotifyRequest(environ) try:
req = NotifyRequest(environ)
def rewrite_response_headers(status, headers, exc_info=None): def rewrite_response_headers(status, headers, exc_info=None):
lower_existing_header_names = frozenset( lower_existing_header_names = frozenset(
name.lower() for name, value in headers name.lower() for name, value in headers
) )
if TRACE_ID_HEADER.lower() not in lower_existing_header_names: if TRACE_ID_HEADER.lower() not in lower_existing_header_names:
headers.append((TRACE_ID_HEADER, str(req.trace_id))) headers.append((TRACE_ID_HEADER, str(req.trace_id)))
if SPAN_ID_HEADER.lower() not in lower_existing_header_names: if SPAN_ID_HEADER.lower() not in lower_existing_header_names:
headers.append((SPAN_ID_HEADER, str(req.span_id))) headers.append((SPAN_ID_HEADER, str(req.span_id)))
return start_response(status, headers, exc_info) return start_response(status, headers, exc_info)
return self._app(environ, rewrite_response_headers) return self._app(environ, rewrite_response_headers)
except BaseException as be: # noqa
if "AuthError" in str(be): # notify-api-1135
current_app.logger.error(be)
elif "AttributeError" in str(be): # notify-api-1394
current_app.logger.error(be)
else:
raise be
def init_app(app): def init_app(app):