From 6f4b1dcb8e05b816d315bbd42608f10d6252559d Mon Sep 17 00:00:00 2001
From: XnpioChV <xnpiochv@gmail.com>
Date: Mon, 16 Mar 2026 18:10:27 -0500
Subject: [PATCH] feat: `get_entity_draft_history` added

---
 src/openedx_content/applets/publishing/api.py | 40 +++++++++++++++++++
 1 file changed, 40 insertions(+)

diff --git a/src/openedx_content/applets/publishing/api.py b/src/openedx_content/applets/publishing/api.py
index 64b190a0..ce92985c 100644
--- a/src/openedx_content/applets/publishing/api.py
+++ b/src/openedx_content/applets/publishing/api.py
@@ -71,6 +71,7 @@
     "publish_from_drafts",
     "get_draft_version",
     "get_published_version",
+    "get_entity_draft_history",
     "set_draft_version",
     "soft_delete_draft",
     "reset_drafts_to_published",
@@ -584,6 +585,45 @@ def get_published_version(publishable_entity_or_id: PublishableEntity | int, /)
     return published.version
 
 
+def get_entity_draft_history(
+    publishable_entity_or_id: PublishableEntity | int, /
+) -> QuerySet[DraftChangeLogRecord]:
+    """
+    Return DraftChangeLogRecords for a PublishableEntity since its last publication,
+    ordered from most recent to oldest.
+
+    If the entity has never been published, all DraftChangeLogRecords are returned.
+    """
+    if isinstance(publishable_entity_or_id, int):
+        entity_id = publishable_entity_or_id
+    else:
+        entity_id = publishable_entity_or_id.pk
+
+    qs = (
+        DraftChangeLogRecord.objects
+        .filter(entity_id=entity_id)
+        .select_related(
+            "draft_change_log__changed_by",
+            "old_version",
+            "new_version",
+        )
+        .order_by("-draft_change_log__changed_at")
+    )
+
+    # Narrow to changes since the last publication
+    try:
+        published = Published.objects.select_related(
+            "publish_log_record__publish_log"
+        ).get(entity_id=entity_id)
+        qs = qs.filter(
+            draft_change_log__changed_at__gt=published.publish_log_record.publish_log.published_at
+        )
+    except Published.DoesNotExist:
+        pass
+
+    return qs
+
+
 def set_draft_version(
     draft_or_id: Draft | int,
     publishable_entity_version_pk: int | None,