feat: Use Snuba for Group.filter_by_event_id

This is the second part of
#13905, which updates
the group model to use events from Snuba instead of Postgres.
This PR updates the filter_by_event_id function.

Author: lynnagara

src/sentry/models/group.py

@@ -175,18 +175,20 @@ def from_event_id(self, project, event_id):
         return Group.objects.get(id=group_id)
 
     def filter_by_event_id(self, project_ids, event_id):
-        from sentry.models import EventMapping, Event
-        group_ids = set()
-        # see above for explanation as to why we're
-        # looking at both Event and EventMapping
-        for model in Event, EventMapping:
-            group_ids.update(
-                model.objects.filter(
-                    project_id__in=project_ids,
-                    event_id=event_id,
-                    group_id__isnull=False,
-                ).values_list('group_id', flat=True)
-            )
+        from sentry.utils import snuba
+
+        group_ids = set([evt['issue'] for evt in snuba.raw_query(
+            start=datetime.utcfromtimestamp(0),
+            end=datetime.utcnow(),
+            selected_columns=['issue'],
+            conditions=[['issue', 'IS NOT NULL', None]],
+            filter_keys={
+                'event_id': [event_id],
+                'project_id': project_ids,
+            },
+            limit=1000,
+            referrer="Group.filter_by_event_id",
+        )['data']])
 
         return Group.objects.filter(id__in=group_ids)
 

tests/snuba/api/endpoints/test_organization_group_index.py

@@ -10,9 +10,9 @@
 from mock import patch, Mock
 
 from sentry.models import (
-    Activity, ApiToken, Event, EventMapping, ExternalIssue, Group, GroupAssignee,
-    GroupBookmark, GroupHash, GroupLink, GroupSeen, GroupShare, GroupSnooze,
-    GroupStatus, GroupResolution, GroupSubscription, GroupTombstone, Integration,
+    Activity, ApiToken, ExternalIssue, Group, GroupAssignee, GroupBookmark,
+    GroupHash, GroupLink, GroupSeen, GroupShare, GroupSnooze, GroupStatus,
+    GroupResolution, GroupSubscription, GroupTombstone, Integration,
     OrganizationIntegration, UserOption, Release
 )
 from sentry.testutils import APITestCase, SnubaTestCase
@@ -209,22 +209,21 @@ def test_auto_resolved(self):
     def test_lookup_by_event_id(self):
         project = self.project
         project.update_option('sentry:resolve_age', 1)
-        group = self.create_group(checksum='a' * 32)
-        self.create_group(checksum='b' * 32)
         event_id = 'c' * 32
-        Event.objects.create(project_id=self.project.id, event_id=event_id)
-        EventMapping.objects.create(
-            event_id=event_id,
-            project=group.project,
-            group=group,
+        event = self.store_event(
+            data={
+                'event_id': event_id,
+                'timestamp': self.min_ago.isoformat()[:19],
+            },
+            project_id=self.project.id
         )
 
         self.login_as(user=self.user)
 
         response = self.get_valid_response(query='c' * 32)
         assert response['X-Sentry-Direct-Hit'] == '1'
         assert len(response.data) == 1
-        assert response.data[0]['id'] == six.text_type(group.id)
+        assert response.data[0]['id'] == six.text_type(event.group.id)
         assert response.data[0]['matchingEventId'] == event_id
 
     def test_lookup_by_event_id_incorrect_project_id(self):
@@ -257,20 +256,20 @@ def test_lookup_by_event_id_incorrect_project_id(self):
     def test_lookup_by_event_id_with_whitespace(self):
         project = self.project
         project.update_option('sentry:resolve_age', 1)
-        group = self.create_group(checksum='a' * 32)
         event_id = 'c' * 32
-        self.create_group(checksum='b' * 32)
-        EventMapping.objects.create(
-            event_id=event_id,
-            project=group.project,
-            group=group,
+        event = self.store_event(
+            data={
+                'event_id': event_id,
+                'timestamp': self.min_ago.isoformat()[:19],
+            },
+            project_id=self.project.id
         )
 
         self.login_as(user=self.user)
         response = self.get_valid_response(query='  {}  '.format('c' * 32))
         assert response['X-Sentry-Direct-Hit'] == '1'
         assert len(response.data) == 1
-        assert response.data[0]['id'] == six.text_type(group.id)
+        assert response.data[0]['id'] == six.text_type(event.group.id)
         assert response.data[0]['matchingEventId'] == event_id
 
     def test_lookup_by_unknown_event_id(self):