|
|
@ -24,6 +24,10 @@ from tests_aio.unit import _constants |
|
|
|
|
|
|
|
|
|
|
|
_INITIAL_METADATA_KEY = "x-grpc-test-echo-initial" |
|
|
|
_INITIAL_METADATA_KEY = "x-grpc-test-echo-initial" |
|
|
|
_TRAILING_METADATA_KEY = "x-grpc-test-echo-trailing-bin" |
|
|
|
_TRAILING_METADATA_KEY = "x-grpc-test-echo-trailing-bin" |
|
|
|
|
|
|
|
_PRIVATE_KEY = resources.private_key() |
|
|
|
|
|
|
|
_CERTIFICATE_CHAIN = resources.certificate_chain() |
|
|
|
|
|
|
|
_TEST_ROOT_CERTIFICATES = resources.test_root_certificates() |
|
|
|
|
|
|
|
_SERVER_CERTS = ((_PRIVATE_KEY, _CERTIFICATE_CHAIN),) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
async def _maybe_echo_metadata(servicer_context): |
|
|
|
async def _maybe_echo_metadata(servicer_context): |
|
|
@ -38,11 +42,6 @@ async def _maybe_echo_metadata(servicer_context): |
|
|
|
invocation_metadata[_TRAILING_METADATA_KEY]) |
|
|
|
invocation_metadata[_TRAILING_METADATA_KEY]) |
|
|
|
servicer_context.set_trailing_metadata((trailing_metadatum,)) |
|
|
|
servicer_context.set_trailing_metadata((trailing_metadatum,)) |
|
|
|
|
|
|
|
|
|
|
|
_PRIVATE_KEY = resources.private_key() |
|
|
|
|
|
|
|
_CERTIFICATE_CHAIN = resources.certificate_chain() |
|
|
|
|
|
|
|
_TEST_ROOT_CERTIFICATES = resources.test_root_certificates() |
|
|
|
|
|
|
|
_SERVER_CERTS = ((_PRIVATE_KEY, _CERTIFICATE_CHAIN),) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
async def _maybe_echo_status(request: messages_pb2.SimpleRequest, |
|
|
|
async def _maybe_echo_status(request: messages_pb2.SimpleRequest, |
|
|
|
servicer_context): |
|
|
|
servicer_context): |
|
|
|