in callouts/python/extproc/example/e2e_tests/metadata_server.py [0:0]
def process(self, request: ProcessingRequest,
context: ServicerContext) -> ProcessingResponse:
"""Process the incoming request.
Args:
request (ProcessingRequest): The processing request received.
context (ServicerContext): The context object for the gRPC service.
Returns:
ProcessingResponse: The processing response to be sent back.
"""
logging.info('Received request %s.', request)
if request.HasField('response_body'):
return ProcessingResponse(
response_body=callout_tools.add_body_mutation('e2e-test'))
if not check_metadata(request):
return ProcessingResponse(
response_headers=callout_tools.add_header_mutation(
default_headers),)
return ProcessingResponse(
response_headers=callout_tools.add_header_mutation(
add=[('metadata', 'found')] + default_headers),)