def process()

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),)