chore: add activity logging to Endpoints backend (#39863)

Co-authored-by: Cursor Agent <cursoragent@cursor.com>

Author: sakce

posthog/models/activity_logging/activity_log.py

@@ -36,6 +36,7 @@
     "EventDefinition",
     "PropertyDefinition",
     "Notebook",
+    "Endpoint",
     "Dashboard",
     "Replay",
     "Experiment",

products/endpoints/backend/api.py

@@ -5,6 +5,7 @@
 from django.shortcuts import get_object_or_404
 
 from django_filters.rest_framework import DjangoFilterBackend
+from loginas.utils import is_impersonated_session
 from pydantic import BaseModel
 from rest_framework import status, viewsets
 from rest_framework.exceptions import Throttled, ValidationError
@@ -40,6 +41,7 @@
 from posthog.hogql_queries.hogql_query_runner import HogQLQueryRunner
 from posthog.hogql_queries.query_runner import BLOCKING_EXECUTION_MODES
 from posthog.models import User
+from posthog.models.activity_logging.activity_log import Detail, changes_between, log_activity
 from posthog.rate_limit import APIQueriesBurstThrottle, APIQueriesSustainedThrottle
 from posthog.schema_migrations.upgrade import upgrade
 from posthog.types import InsightQueryNode
@@ -156,6 +158,18 @@ def create(self, request: Request, *args, **kwargs) -> Response:
                 is_active=data.is_active if data.is_active is not None else True,
             )
 
+            # Activity log: created
+            log_activity(
+                organization_id=self.organization.id,
+                team_id=self.team.id,
+                user=cast(User, request.user),
+                was_impersonated=is_impersonated_session(request),
+                item_id=str(endpoint.id),
+                scope="Endpoint",
+                activity="created",
+                detail=Detail(name=endpoint.name),
+            )
+
             return Response(
                 {
                     "id": str(endpoint.id),
@@ -183,6 +197,11 @@ def create(self, request: Request, *args, **kwargs) -> Response:
     def update(self, request: Request, name=None, *args, **kwargs) -> Response:
         """Update an existing endpoint."""
         endpoint = get_object_or_404(Endpoint, team=self.team, name=name)
+        # Capture a snapshot for diffing
+        try:
+            before_update = Endpoint.objects.get(pk=endpoint.id)
+        except Endpoint.DoesNotExist:
+            before_update = None
 
         upgraded_query = upgrade(request.data)
         data = self.get_model(upgraded_query, EndpointRequest)
@@ -200,6 +219,19 @@ def update(self, request: Request, name=None, *args, **kwargs) -> Response:
 
             endpoint.save()
 
+            # Activity log: updated with field diffs
+            changes = changes_between("Endpoint", previous=before_update, current=endpoint)
+            log_activity(
+                organization_id=self.organization.id,
+                team_id=self.team.id,
+                user=cast(User, request.user),
+                was_impersonated=is_impersonated_session(request),
+                item_id=str(endpoint.id),
+                scope="Endpoint",
+                activity="updated",
+                detail=Detail(name=endpoint.name, changes=changes),
+            )
+
             return Response(
                 {
                     "id": str(endpoint.id),

products/endpoints/backend/tests/test_endpoint.py

@@ -8,6 +8,7 @@
 
 from posthog.schema import EndpointLastExecutionTimesRequest
 
+from posthog.models.activity_logging.activity_log import ActivityLog
 from posthog.models.insight_variable import InsightVariable
 from posthog.models.team import Team
 from posthog.models.user import User
@@ -61,6 +62,14 @@ def test_create_endpoint(self):
         self.assertEqual(endpoint.query, self.sample_query)
         self.assertEqual(endpoint.created_by, self.user)
 
+        # Activity log created
+        logs = ActivityLog.objects.filter(team_id=self.team.id, scope="Endpoint", activity="created")
+        self.assertEqual(logs.count(), 1, list(logs.values("activity", "scope", "item_id")))
+        log = logs.latest("created_at")
+        self.assertEqual(log.item_id, str(endpoint.id))
+        assert log.detail is not None
+        self.assertEqual(log.detail.get("name"), "test_query")
+
     def test_update_endpoint(self):
         """Test updating an existing endpoint."""
         endpoint = Endpoint.objects.create(
@@ -107,6 +116,18 @@ def test_update_endpoint(self):
         self.assertEqual(endpoint.description, "Updated description")
         self.assertFalse(endpoint.is_active)
 
+        # Activity log updated with changes
+        logs = ActivityLog.objects.filter(
+            team_id=self.team.id, scope="Endpoint", activity="updated", item_id=str(endpoint.id)
+        )
+        self.assertEqual(logs.count(), 1, list(logs.values("activity", "detail")))
+        log = logs.latest("created_at")
+        assert log.detail is not None
+        changes = log.detail.get("changes", [])
+        changed_fields = {c.get("field") for c in changes}
+        self.assertIn("description", changed_fields)
+        self.assertIn("is_active", changed_fields)
+
     def test_delete_endpoint(self):
         """Test deleting a endpoint."""
         Endpoint.objects.create(