Add fields in graphql response for pc events

Author: gmazoyer

backend/infrahub/graphql/types/event.py

@@ -113,6 +113,27 @@ class Meta:
     payload = Field(GenericScalar, required=True)
 
 
+# ---------------------------------------
+# Proposed change events
+# ---------------------------------------
+class ProposedChangeReviewEvent(ObjectType):
+    class Meta:
+        interfaces = (EventNodeInterface,)
+
+    reviewer_account_id = String(required=True, description="The ID of the user who reviewed the proposed change")
+    reviewer_account_name = String(required=True, description="The name of the user who reviewed the proposed change")
+    reviewer_decision = String(required=True, description="The decision made by the reviewer")
+
+
+class ProposedChangeReviewRevokedEvent(ObjectType):
+    class Meta:
+        interfaces = (EventNodeInterface,)
+
+    reviewer_account_id = String(required=True, description="The ID of the user who reviewed the proposed change")
+    reviewer_account_name = String(required=True, description="The name of the user who reviewed the proposed change")
+    reviewer_former_decision = String(required=True, description="The decision made by the reviewer")
+
+
 # ---------------------------------------
 # Node/Object events
 # ---------------------------------------
@@ -163,5 +184,9 @@ class Meta:
     events.BranchDeletedEvent.event_name: BranchDeletedEvent,
     events.GroupMemberAddedEvent.event_name: GroupEvent,
     events.GroupMemberRemovedEvent.event_name: GroupEvent,
+    events.ProposedChangeApprovedEvent.event_name: ProposedChangeReviewEvent,
+    events.ProposedChangeApprovalRevokedEvent.event_name: ProposedChangeReviewRevokedEvent,
+    events.ProposedChangeRejectedEvent.event_name: ProposedChangeReviewEvent,
+    events.ProposedChangeRejectionRevokedEvent.event_name: ProposedChangeReviewRevokedEvent,
     "undefined": StandardEvent,
 }

backend/infrahub/task_manager/event.py

@@ -172,6 +172,18 @@ def _return_group_event(self) -> dict[str, Any]:
 
         return {"members": members, "ancestors": ancestors}
 
+    def _return_proposed_change_reviewer(self) -> dict[str, Any]:
+        return {
+            "reviewer_account_id": self.resource.get("infrahub.proposed_change.reviewer_account_id"),
+            "reviewer_account_name": self.resource.get("infrahub.proposed_change.reviewer_account_name"),
+        }
+
+    def _return_proposed_change_reviewer_decision(self) -> dict[str, Any]:
+        return {"reviewer_decision": self.resource.get("infrahub.proposed_change.reviewer_decision")}
+
+    def _return_proposed_change_reviewer_former_decision(self) -> dict[str, Any]:
+        return {"reviewer_former_decision": self.resource.get("infrahub.proposed_change.reviewer_former_decision")}
+
     def _return_event_specifics(self) -> dict[str, Any]:
         """Return event specific data based on the type of event being processed"""
 
@@ -192,6 +204,16 @@ def _return_event_specifics(self) -> dict[str, Any]:
                 event_specifics = self._return_branch_rebased()
             case "infrahub.group.member_added" | "infrahub.group.member_removed":
                 event_specifics = self._return_group_event()
+            case "infrahub.proposed_change.approved" | "infrahub.proposed_change.rejected":
+                event_specifics = {
+                    **self._return_proposed_change_reviewer(),
+                    **self._return_proposed_change_reviewer_decision(),
+                }
+            case "infrahub.proposed_change.approval_revoked" | "infrahub.proposed_change.rejection_revoked":
+                event_specifics = {
+                    **self._return_proposed_change_reviewer(),
+                    **self._return_proposed_change_reviewer_former_decision(),
+                }
 
         return event_specifics