feat(http): [Data Collection 13] Apply cookie collection policy

sentry-apollo-3/src/main/java/io/sentry/apollo3/SentryApollo3HttpInterceptor.kt

@@ -270,6 +270,28 @@ constructor(
   private fun getHeader(key: String, headers: List<HttpHeader>): String? =
     headers.firstOrNull { it.name.equals(key, true) }?.value
 
+  private fun getRequestCookies(headers: List<HttpHeader>): String? {
+    val cookies = getHeader("Cookie", headers)
+    return if (scopes.options.dataCollectionResolver.isDataCollectionConfigured) {
+      HttpUtils.filterCookies(cookies, scopes.options.dataCollectionResolver.cookies, null)
+    } else if (scopes.options.isSendDefaultPii) {
+      cookies
+    } else {
+      null
+    }
+  }
+
+  private fun getResponseCookies(headers: List<HttpHeader>): String? {
+    val cookies = getHeader("Set-Cookie", headers)
+    return if (scopes.options.dataCollectionResolver.isDataCollectionConfigured) {
+      HttpUtils.filterSetCookie(cookies, scopes.options.dataCollectionResolver.cookies)
+    } else if (scopes.options.isSendDefaultPii) {
+      cookies
+    } else {
+      null
+    }
+  }
+
   private fun getRequestHeaders(headers: List<HttpHeader>): MutableMap<String, String>? {
     if (scopes.options.dataCollectionResolver.isDataCollectionConfigured) {
       val requestHeaders = mutableMapOf<String, String>()
@@ -391,9 +413,7 @@ constructor(
       val sentryRequest =
         Request().apply {
           urlDetails.applyToRequest(this)
-          // Cookie is only sent if isSendDefaultPii is enabled
-          cookies =
-            if (scopes.options.isSendDefaultPii) getHeader("Cookie", request.headers) else null
+          cookies = getRequestCookies(request.headers)
           method = request.method.name
           headers = getRequestHeaders(request.headers)
           apiTarget = "graphql"
@@ -419,13 +439,7 @@ constructor(
 
       val sentryResponse =
         Response().apply {
-          // Set-Cookie is only sent if isSendDefaultPii is enabled due to PII
-          cookies =
-            if (scopes.options.isSendDefaultPii) {
-              getHeader("Set-Cookie", response.headers)
-            } else {
-              null
-            }
+          cookies = getResponseCookies(response.headers)
           headers = getResponseHeaders(response.headers)
           statusCode = response.statusCode
 

sentry-apollo-3/src/test/java/io/sentry/apollo3/SentryApollo3InterceptorClientErrors.kt

@@ -73,6 +73,7 @@ class SentryApollo3InterceptorClientErrors {
       httpStatusCode: Int = 200,
       responseBody: String = responseBodyOk,
       sendDefaultPii: Boolean = false,
+      includeCookies: Boolean = sendDefaultPii,
       socketPolicy: SocketPolicy = SocketPolicy.KEEP_OPEN,
       configureOptions: SentryOptions.() -> Unit = {},
     ): ApolloClient {
@@ -98,8 +99,8 @@ class SentryApollo3InterceptorClientErrors {
           .setSocketPolicy(socketPolicy)
           .setResponseCode(httpStatusCode)
 
-      if (sendDefaultPii) {
-        response.addHeader("Set-Cookie", "Test")
+      if (includeCookies) {
+        response.addHeader("Set-Cookie", "theme=dark; Path=/")
       }
 
       server.enqueue(response)
@@ -112,8 +113,8 @@ class SentryApollo3InterceptorClientErrors {
             captureFailedRequests = captureFailedRequests,
             failedRequestTargets = failedRequestTargets,
           )
-      if (sendDefaultPii) {
-        builder.addHttpHeader("Cookie", "Test")
+      if (includeCookies) {
+        builder.addHttpHeader("Cookie", "theme=dark; sessionId=secret")
       }
 
       return builder.build()
@@ -362,6 +363,46 @@ class SentryApollo3InterceptorClientErrors {
       )
   }
 
+  @Test
+  fun `data collection filters cookies`() {
+    val sut =
+      fixture.getSut(responseBody = fixture.responseBodyNotOk, includeCookies = true) {
+        dataCollection.cookies = KeyValueCollectionBehavior.denyList("theme")
+      }
+    executeQuery(sut)
+
+    verify(fixture.scopes)
+      .captureEvent(
+        check {
+          assertEquals("theme=[Filtered]; sessionId=[Filtered]", it.request!!.cookies)
+          assertEquals("theme=[Filtered]; Path=/", it.contexts.response!!.cookies)
+        },
+        any<Hint>(),
+      )
+  }
+
+  @Test
+  fun `data collection can disable cookies`() {
+    val sut =
+      fixture.getSut(
+        responseBody = fixture.responseBodyNotOk,
+        sendDefaultPii = true,
+        includeCookies = true,
+      ) {
+        dataCollection.cookies = KeyValueCollectionBehavior.off()
+      }
+    executeQuery(sut)
+
+    verify(fixture.scopes)
+      .captureEvent(
+        check {
+          assertNull(it.request!!.cookies)
+          assertNull(it.contexts.response!!.cookies)
+        },
+        any<Hint>(),
+      )
+  }
+
   @Test
   fun `data collection can disable request headers`() {
     val sut =
@@ -387,7 +428,7 @@ class SentryApollo3InterceptorClientErrors {
         check {
           val request = it.request!!
 
-          assertEquals("Test", request.cookies)
+          assertEquals("theme=dark; sessionId=secret", request.cookies)
           assertNotNull(request.headers)
           assertEquals("LaunchDetails", request.headers?.get("X-APOLLO-OPERATION-NAME"))
         },
@@ -477,7 +518,7 @@ class SentryApollo3InterceptorClientErrors {
         check {
           val response = it.contexts.response!!
 
-          assertEquals("Test", response.cookies)
+          assertEquals("theme=dark; Path=/", response.cookies)
           assertNotNull(response.headers)
           assertEquals(200, response.headers?.get("Content-Length")?.toInt())
         },

sentry-apollo-4/src/main/java/io/sentry/apollo4/SentryApollo4HttpInterceptor.kt

@@ -269,6 +269,28 @@ constructor(
   private fun getHeader(key: String, headers: List<HttpHeader>): String? =
     headers.firstOrNull { it.name.equals(key, true) }?.value
 
+  private fun getRequestCookies(headers: List<HttpHeader>): String? {
+    val cookies = getHeader("Cookie", headers)
+    return if (scopes.options.dataCollectionResolver.isDataCollectionConfigured) {
+      HttpUtils.filterCookies(cookies, scopes.options.dataCollectionResolver.cookies, null)
+    } else if (scopes.options.isSendDefaultPii) {
+      cookies
+    } else {
+      null
+    }
+  }
+
+  private fun getResponseCookies(headers: List<HttpHeader>): String? {
+    val cookies = getHeader("Set-Cookie", headers)
+    return if (scopes.options.dataCollectionResolver.isDataCollectionConfigured) {
+      HttpUtils.filterSetCookie(cookies, scopes.options.dataCollectionResolver.cookies)
+    } else if (scopes.options.isSendDefaultPii) {
+      cookies
+    } else {
+      null
+    }
+  }
+
   private fun getRequestHeaders(headers: List<HttpHeader>): MutableMap<String, String>? {
     if (scopes.options.dataCollectionResolver.isDataCollectionConfigured) {
       val requestHeaders = mutableMapOf<String, String>()
@@ -390,9 +412,7 @@ constructor(
       val sentryRequest =
         Request().apply {
           urlDetails.applyToRequest(this)
-          // Cookie is only sent if isSendDefaultPii is enabled
-          cookies =
-            if (scopes.options.isSendDefaultPii) getHeader("Cookie", request.headers) else null
+          cookies = getRequestCookies(request.headers)
           method = request.method.name
           headers = getRequestHeaders(request.headers)
           apiTarget = "graphql"
@@ -418,13 +438,7 @@ constructor(
 
       val sentryResponse =
         Response().apply {
-          // Set-Cookie is only sent if isSendDefaultPii is enabled due to PII
-          cookies =
-            if (scopes.options.isSendDefaultPii) {
-              getHeader("Set-Cookie", response.headers)
-            } else {
-              null
-            }
+          cookies = getResponseCookies(response.headers)
           headers = getResponseHeaders(response.headers)
           statusCode = response.statusCode
 

sentry-apollo-4/src/test/java/io/sentry/apollo4/SentryApollo4BuilderExtensionsClientErrorsTest.kt

@@ -87,6 +87,7 @@ abstract class SentryApollo4BuilderExtensionsClientErrorsTest(
       httpStatusCode: Int = 200,
       responseBody: String = responseBodyOk,
       sendDefaultPii: Boolean = false,
+      includeCookies: Boolean = sendDefaultPii,
       socketPolicy: SocketPolicy = SocketPolicy.KEEP_OPEN,
       configureOptions: SentryOptions.() -> Unit = {},
     ): ApolloClient {
@@ -112,8 +113,8 @@ abstract class SentryApollo4BuilderExtensionsClientErrorsTest(
           .setSocketPolicy(socketPolicy)
           .setResponseCode(httpStatusCode)
 
-      if (sendDefaultPii) {
-        response.addHeader("Set-Cookie", "Test")
+      if (includeCookies) {
+        response.addHeader("Set-Cookie", "theme=dark; Path=/")
       }
 
       server.enqueue(response)
@@ -126,8 +127,8 @@ abstract class SentryApollo4BuilderExtensionsClientErrorsTest(
             captureFailedRequests = captureFailedRequests,
             failedRequestTargets = failedRequestTargets,
           )
-      if (sendDefaultPii) {
-        builder.addHttpHeader("Cookie", "Test")
+      if (includeCookies) {
+        builder.addHttpHeader("Cookie", "theme=dark; sessionId=secret")
       }
 
       return builder.build()
@@ -356,6 +357,46 @@ abstract class SentryApollo4BuilderExtensionsClientErrorsTest(
       )
   }
 
+  @Test
+  fun `data collection filters cookies`() {
+    val sut =
+      fixture.getSut(responseBody = fixture.responseBodyNotOk, includeCookies = true) {
+        dataCollection.cookies = KeyValueCollectionBehavior.denyList("theme")
+      }
+    executeQuery(sut)
+
+    verify(fixture.scopes)
+      .captureEvent(
+        check {
+          assertEquals("theme=[Filtered]; sessionId=[Filtered]", it.request!!.cookies)
+          assertEquals("theme=[Filtered]; Path=/", it.contexts.response!!.cookies)
+        },
+        any<Hint>(),
+      )
+  }
+
+  @Test
+  fun `data collection can disable cookies`() {
+    val sut =
+      fixture.getSut(
+        responseBody = fixture.responseBodyNotOk,
+        sendDefaultPii = true,
+        includeCookies = true,
+      ) {
+        dataCollection.cookies = KeyValueCollectionBehavior.off()
+      }
+    executeQuery(sut)
+
+    verify(fixture.scopes)
+      .captureEvent(
+        check {
+          assertNull(it.request!!.cookies)
+          assertNull(it.contexts.response!!.cookies)
+        },
+        any<Hint>(),
+      )
+  }
+
   @Test
   fun `data collection can disable request headers`() {
     val sut =
@@ -381,7 +422,7 @@ abstract class SentryApollo4BuilderExtensionsClientErrorsTest(
         check {
           val request = it.request!!
 
-          assertEquals("Test", request.cookies)
+          assertEquals("theme=dark; sessionId=secret", request.cookies)
           assertNotNull(request.headers)
         },
         any<Hint>(),
@@ -470,7 +511,7 @@ abstract class SentryApollo4BuilderExtensionsClientErrorsTest(
         check {
           val response = it.contexts.response!!
 
-          assertEquals("Test", response.cookies)
+          assertEquals("theme=dark; Path=/", response.cookies)
           assertNotNull(response.headers)
           assertEquals(200, response.headers?.get("Content-Length")?.toInt())
         },

sentry-ktor-client/src/main/java/io/sentry/ktorClient/SentryKtorClientUtils.kt

@@ -36,18 +36,16 @@ internal object SentryKtorClientUtils {
 
     val sentryRequest =
       io.sentry.protocol.Request().apply {
-        // Cookie is only sent if isSendDefaultPii is enabled
         urlDetails.applyToRequest(this)
-        cookies = if (scopes.options.isSendDefaultPii) request.headers["Cookie"] else null
+        cookies = getRequestCookies(scopes, request.headers["Cookie"])
         method = request.method.value
         headers = getRequestHeaders(scopes, request.headers)
         bodySize = request.content.contentLength
       }
 
     val sentryResponse =
       io.sentry.protocol.Response().apply {
-        // Set-Cookie is only sent if isSendDefaultPii is enabled due to PII
-        cookies = if (scopes.options.isSendDefaultPii) response.headers["Set-Cookie"] else null
+        cookies = getResponseCookies(scopes, response.headers["Set-Cookie"])
         headers = getResponseHeaders(scopes, response.headers)
         statusCode = response.status.value
         try {
@@ -67,6 +65,28 @@ internal object SentryKtorClientUtils {
     scopes.captureEvent(event, hint)
   }
 
+  private fun getRequestCookies(scopes: IScopes, cookies: String?): String? =
+    if (scopes.options.dataCollectionResolver.isDataCollectionConfigured) {
+      HttpUtils.filterCookies(
+        cookies,
+        scopes.options.dataCollectionResolver.cookies,
+        null,
+      )
+    } else if (scopes.options.isSendDefaultPii) {
+      cookies
+    } else {
+      null
+    }
+
+  private fun getResponseCookies(scopes: IScopes, cookies: String?): String? =
+    if (scopes.options.dataCollectionResolver.isDataCollectionConfigured) {
+      HttpUtils.filterSetCookie(cookies, scopes.options.dataCollectionResolver.cookies)
+    } else if (scopes.options.isSendDefaultPii) {
+      cookies
+    } else {
+      null
+    }
+
   private fun getRequestHeaders(scopes: IScopes, headers: Headers): MutableMap<String, String>? {
     if (scopes.options.dataCollectionResolver.isDataCollectionConfigured) {
       val requestHeaders =