feat(bitbucket): CODEOWNERS support (#86446)

Bitbucket CODEOWNERS support. Note that this PR depends on
#86445.

<details>
<summary>Expand for Screenshots</summary>


![image](https://github.com/user-attachments/assets/391ec447-18d9-4aff-b9b0-f53a6c024ba1)

![image](https://github.com/user-attachments/assets/9d2a9315-1ffc-49a4-8953-ece91127adce)

![image](https://github.com/user-attachments/assets/7c4fe508-86aa-4d8e-bc5c-2acdb595b435)

![image](https://github.com/user-attachments/assets/97f89519-eace-4db1-acfd-cdedaff5bfd3)

![image](https://github.com/user-attachments/assets/93f34094-5a69-4545-8aa5-b69b1ce55a34)

</details>

---------

Co-authored-by: Josh Ferge <[email protected]>

Author: jianyuan

src/sentry/integrations/bitbucket/client.py

@@ -7,7 +7,6 @@
 
 from requests import PreparedRequest
 
-from sentry.integrations.base import IntegrationFeatureNotImplementedError
 from sentry.integrations.client import ApiClient
 from sentry.integrations.models.integration import Integration
 from sentry.integrations.services.integration.model import RpcIntegration
@@ -182,4 +181,13 @@ def check_file(self, repo: Repository, path: str, version: str | None) -> object
     def get_file(
         self, repo: Repository, path: str, ref: str | None, codeowners: bool = False
     ) -> str:
-        raise IntegrationFeatureNotImplementedError
+        response = self.get_cached(
+            path=BitbucketAPIPath.source.format(
+                repo=repo.name,
+                sha=ref,
+                path=path,
+            ),
+            allow_redirects=True,
+            raw_response=True,
+        )
+        return response.text

src/sentry/integrations/bitbucket/integration.py

@@ -78,6 +78,12 @@
         """,
         IntegrationFeatures.STACKTRACE_LINK,
     ),
+    FeatureDescription(
+        """
+        Import your Bitbucket [CODEOWNERS file](https://support.atlassian.com/bitbucket-cloud/docs/set-up-and-use-code-owners/) and use it alongside your ownership rules to assign Sentry issues.
+        """,
+        IntegrationFeatures.CODEOWNERS,
+    ),
 ]
 
 metadata = IntegrationMetadata(
@@ -94,6 +100,8 @@
 
 
 class BitbucketIntegration(RepositoryIntegration, BitbucketIssuesSpec):
+    codeowners_locations = [".bitbucket/CODEOWNERS"]
+
     @property
     def integration_name(self) -> str:
         return "bitbucket"
@@ -185,6 +193,7 @@ class BitbucketIntegrationProvider(IntegrationProvider):
             IntegrationFeatures.ISSUE_BASIC,
             IntegrationFeatures.COMMITS,
             IntegrationFeatures.STACKTRACE_LINK,
+            IntegrationFeatures.CODEOWNERS,
         ]
     )
 

src/sentry/models/commitfilechange.py

@@ -48,13 +48,16 @@ def is_valid_type(value: str) -> bool:
 
 
 def process_resource_change(instance, **kwargs):
+    from sentry.integrations.bitbucket.integration import BitbucketIntegration
     from sentry.integrations.github.integration import GitHubIntegration
     from sentry.integrations.gitlab.integration import GitlabIntegration
     from sentry.tasks.codeowners import code_owners_auto_sync
 
     def _spawn_task():
-        filepaths = set(GitHubIntegration.codeowners_locations) | set(
-            GitlabIntegration.codeowners_locations
+        filepaths = (
+            set(GitHubIntegration.codeowners_locations)
+            | set(GitlabIntegration.codeowners_locations)
+            | set(BitbucketIntegration.codeowners_locations)
         )
 
         # CODEOWNERS file added or modified, trigger auto-sync

src/sentry/shared_integrations/client/base.py

@@ -335,10 +335,15 @@ def request(self, *args: Any, **kwargs: Any) -> Any:
     def delete(self, *args: Any, **kwargs: Any) -> Any:
         return self.request("DELETE", *args, **kwargs)
 
-    def get_cache_key(self, path: str, query: str = "", data: str | None = "") -> str:
+    def get_cache_key(self, path: str, method: str, query: str = "", data: str | None = "") -> str:
         if not data:
-            return self.get_cache_prefix() + md5_text(self.build_url(path), query).hexdigest()
-        return self.get_cache_prefix() + md5_text(self.build_url(path), query, data).hexdigest()
+            return (
+                self.get_cache_prefix() + md5_text(self.build_url(path), method, query).hexdigest()
+            )
+        return (
+            self.get_cache_prefix()
+            + md5_text(self.build_url(path), method, query, data).hexdigest()
+        )
 
     def check_cache(self, cache_key: str) -> Any | None:
         return cache.get(cache_key)
@@ -352,7 +357,7 @@ def _get_cached(self, path: str, method: str, *args: Any, **kwargs: Any) -> Any:
         if kwargs.get("params", None):
             query = json.dumps(kwargs.get("params"))
 
-        key = self.get_cache_key(path, query, data)
+        key = self.get_cache_key(path, method, query, data)
         result = self.check_cache(key)
         if result is None:
             cache_time = kwargs.pop("cache_time", None) or self.cache_time

tests/sentry/integrations/bitbucket/test_client.py

@@ -17,6 +17,12 @@
 control_address = "http://controlserver"
 secret = "hush-hush-im-invisible"
 
+BITBUCKET_CODEOWNERS = {
+    "filepath": ".bitbucket/CODEOWNERS",
+    "html_url": "https://bitbucket.org/sentryuser/newsdiffs/src/master/.bitbucket/CODEOWNERS",
+    "raw": "docs/* @jianyuan @getsentry/ecosystem\n* @jianyuan\n",
+}
+
 
 @control_silo_test
 class BitbucketApiClientTest(TestCase, BaseTestCase):
@@ -121,3 +127,30 @@ def test_get_stacktrace_link(self):
             source_url
             == "https://bitbucket.org/sentryuser/newsdiffs/src/master/src/sentry/integrations/bitbucket/client.py"
         )
+
+    @responses.activate
+    def test_get_codeowner_file(self):
+        self.config = self.create_code_mapping(
+            repo=self.repo,
+            project=self.project,
+        )
+
+        path = ".bitbucket/CODEOWNERS"
+        url = f"https://api.bitbucket.org/2.0/repositories/{self.config.repository.name}/src/{self.config.default_branch}/{path}"
+
+        responses.add(
+            method=responses.HEAD,
+            url=url,
+            json={"text": 200},
+        )
+        responses.add(
+            method=responses.GET,
+            url=url,
+            content_type="text/plain",
+            body=BITBUCKET_CODEOWNERS["raw"],
+        )
+
+        result = self.install.get_codeowner_file(
+            self.config.repository, ref=self.config.default_branch
+        )
+        assert result == BITBUCKET_CODEOWNERS

tests/sentry/integrations/test_client.py

@@ -70,7 +70,7 @@ def test_cache_mocked(self, cache):
         resp = ApiClient().get_cached("http://example.com")
         assert resp == {"key": "value1"}
 
-        key = "integration.undefined.client:a9b9f04336ce0181a08e774e01113b31"
+        key = "integration.undefined.client:41c2952996340270af611f0d7fad7286"
         cache.get.assert_called_with(key)
         cache.set.assert_called_with(key, {"key": "value1"}, 900)
 
@@ -121,6 +121,41 @@ def test_head_cached_query_param(self):
         ApiClient().head_cached("http://example.com", params={"param": "different"})
         assert len(responses.calls) == 2
 
+    @responses.activate
+    def test_get_and_head_cached(self):
+        # Same URL, different HTTP method
+        url = "http://example.com"
+        responses.add(
+            responses.GET,
+            url,
+            json={"key": "response-for-get"},
+            adding_headers={"x-method": "GET"},
+        )
+        responses.add(
+            responses.HEAD,
+            url,
+            json={},
+            adding_headers={"x-method": "HEAD"},
+        )
+
+        resp = ApiClient().head_cached(url)
+        assert resp.headers["x-method"] == "HEAD"
+        assert len(responses.calls) == 1
+
+        resp = ApiClient().head_cached(url)
+        assert resp.headers["x-method"] == "HEAD"
+        assert len(responses.calls) == 1
+
+        resp = ApiClient().get_cached(url, raw_response=True)
+        assert resp.headers["x-method"] == "GET"
+        assert resp.json() == {"key": "response-for-get"}
+        assert len(responses.calls) == 2
+
+        resp = ApiClient().get_cached(url, raw_response=True)
+        assert resp.headers["x-method"] == "GET"
+        assert resp.json() == {"key": "response-for-get"}
+        assert len(responses.calls) == 2
+
     @responses.activate
     def test_default_redirect_behaviour(self):
         destination_url = "http://example.com/destination"