Await coroutine and add new annotated value

Author: alexander-alderman-webb

sentry_sdk/_types.py

@@ -76,6 +76,22 @@ def removed_because_over_size_limit(cls, value=""):
             },
         )
 
+    @classmethod
+    def removed_because_body_consumed_and_not_cached(cls, value=""):
+        # type: (Any) -> AnnotatedValue
+        """The actual value was removed because the underlying stream has been consumed, without caching the value."""
+        return AnnotatedValue(
+            value=value,
+            metadata={
+                "rem": [  # Remark
+                    [
+                        "!consumed",  # Because the original stream is unavailable
+                        "x",  # The fields original value was removed
+                    ]
+                ]
+            },
+        )
+
     @classmethod
     def substituted_because_contains_sensitive_data(cls):
         # type: () -> AnnotatedValue

sentry_sdk/integrations/starlette.py

@@ -663,7 +663,7 @@ async def extract_request_info(self):
                 and "sentry_sdk.is_body_cached" in self.request.scope["state"]
                 and self.request.scope["state"]["sentry_sdk.is_body_cached"]
             )
-            if self.request.is_disconnected() and not is_body_cached:
+            if await self.request.is_disconnected() and not is_body_cached:
                 request_info["data"] = (
                     AnnotatedValue.removed_because_body_consumed_and_not_cached()
                 )