Add None check for grpc.aio interceptor (#3109)

---------

Co-authored-by: Neel Shah <[email protected]>

Author: ordinary-jamie

sentry_sdk/integrations/grpc/aio/server.py

@@ -7,7 +7,7 @@
 
 if TYPE_CHECKING:
     from collections.abc import Awaitable, Callable
-    from typing import Any
+    from typing import Any, Optional
 
 
 try:
@@ -26,9 +26,11 @@ def __init__(self, find_name=None):
         super().__init__()
 
     async def intercept_service(self, continuation, handler_call_details):
-        # type: (ServerInterceptor, Callable[[HandlerCallDetails], Awaitable[RpcMethodHandler]], HandlerCallDetails) -> Awaitable[RpcMethodHandler]
+        # type: (ServerInterceptor, Callable[[HandlerCallDetails], Awaitable[RpcMethodHandler]], HandlerCallDetails) -> Optional[Awaitable[RpcMethodHandler]]
         self._handler_call_details = handler_call_details
         handler = await continuation(handler_call_details)
+        if handler is None:
+            return None
 
         if not handler.request_streaming and not handler.response_streaming:
             handler_factory = grpc.unary_unary_rpc_method_handler

tests/integrations/grpc/test_grpc_aio.py

@@ -29,6 +29,29 @@ def event_loop(request):
     loop.close()
 
 
+@pytest.mark.asyncio
+async def test_noop_for_unimplemented_method(sentry_init, capture_events, event_loop):
+    sentry_init(traces_sample_rate=1.0, integrations=[GRPCIntegration()])
+    server = grpc.aio.server()
+    server.add_insecure_port("[::]:{}".format(AIO_PORT))
+
+    await event_loop.create_task(server.start())
+
+    events = capture_events()
+    try:
+        async with grpc.aio.insecure_channel(
+            "localhost:{}".format(AIO_PORT)
+        ) as channel:
+            stub = gRPCTestServiceStub(channel)
+            with pytest.raises(grpc.RpcError) as exc:
+                await stub.TestServe(gRPCTestMessage(text="test"))
+            assert exc.value.details() == "Method not found!"
+    finally:
+        await server.stop(None)
+
+    assert not events
+
+
 @pytest_asyncio.fixture(scope="function")
 async def grpc_server(sentry_init, event_loop):
     sentry_init(traces_sample_rate=1.0, integrations=[GRPCIntegration()])