feat: add edited_at field to activation

Expose this field in API for activations. Also write the field
to rulebook process log if the activation has been edited.

implements AAP-38382

src/aap_eda/api/serializers/activation.py

@@ -20,6 +20,7 @@
 
 import yaml
 from django.conf import settings
+from django.utils import timezone
 from rest_framework import serializers
 
 from aap_eda.api.constants import (
@@ -254,6 +255,7 @@ class Meta:
             "current_job_id",
             "created_at",
             "modified_at",
+            "edited_at",
             "status_message",
             "awx_token_id",
             "eda_credentials",
@@ -265,6 +267,7 @@ class Meta:
             "id",
             "created_at",
             "modified_at",
+            "edited_at",
             "rulebook_name",
         ]
 
@@ -315,6 +318,7 @@ class Meta:
             "rules_fired_count",
             "created_at",
             "modified_at",
+            "edited_at",
             "created_by",
             "modified_by",
             "status_message",
@@ -365,6 +369,7 @@ def to_representation(self, activation):
             "rules_fired_count": rules_fired_count,
             "created_at": activation.created_at,
             "modified_at": activation.modified_at,
+            "edited_at": activation.edited_at,
             "status_message": activation.status_message,
             "awx_token_id": activation.awx_token_id,
             "log_level": activation.log_level,
@@ -617,6 +622,7 @@ def validate(self, data):
     def prepare_update(self, activation: models.Activation):
         rulebook_id = self.validated_data.get("rulebook_id")
         self.validated_data["user_id"] = self.context["request"].user.id
+        self.validated_data["edited_at"] = timezone.now()
         if rulebook_id:
             rulebook = models.Rulebook.objects.get(id=rulebook_id)
             self.validated_data["rulebook_name"] = rulebook.name
@@ -818,6 +824,7 @@ class Meta:
             "rules_fired_count",
             "created_at",
             "modified_at",
+            "edited_at",
             "created_by",
             "modified_by",
             "restarted_at",
@@ -830,7 +837,13 @@ class Meta:
             "source_mappings",
             "skip_audit_events",
         ]
-        read_only_fields = ["id", "created_at", "modified_at", "restarted_at"]
+        read_only_fields = [
+            "id",
+            "created_at",
+            "modified_at",
+            "edited_at",
+            "restarted_at",
+        ]
 
     def to_representation(self, activation):
         decision_environment = (
@@ -915,6 +928,7 @@ def to_representation(self, activation):
             "rules_fired_count": rules_fired_count,
             "created_at": activation.created_at,
             "modified_at": activation.modified_at,
+            "edited_at": activation.edited_at,
             "restarted_at": restarted_at,
             "status_message": activation.status_message,
             "awx_token_id": activation.awx_token_id,
@@ -977,6 +991,7 @@ class Meta:
             "user_id",
             "created_at",
             "modified_at",
+            "edited_at",
             "awx_token_id",
             "rulebook_id",
             "eda_credentials",
@@ -988,6 +1003,7 @@ class Meta:
             "id",
             "created_at",
             "modified_at",
+            "edited_at",
         ]
 
 

src/aap_eda/core/migrations/0057_activation_edited_at.py

@@ -0,0 +1,17 @@
+# Generated by Django 4.2.16 on 2025-01-23 19:06
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+    dependencies = [
+        ("core", "0056_alter_activation_options"),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name="activation",
+            name="edited_at",
+            field=models.DateTimeField(null=True),
+        ),
+    ]

src/aap_eda/core/models/activation.py

@@ -96,6 +96,7 @@ class Meta:
     user = models.ForeignKey(User, on_delete=models.CASCADE, null=False)
     created_at = models.DateTimeField(auto_now_add=True, null=False)
     modified_at = models.DateTimeField(auto_now=True, null=False)
+    edited_at = models.DateTimeField(null=True)
     status_updated_at = models.DateTimeField(null=True)
     status_message = models.TextField(null=True, default=None)
     latest_instance = models.OneToOneField(

src/aap_eda/services/activation/activation_manager.py

@@ -207,6 +207,13 @@ def _start_activation_instance(self):
 
         self.db_instance.refresh_from_db()
         log_handler = self.container_logger_class(self.latest_instance.id)
+        if self.db_instance.edited_at:
+            edited_at = self.db_instance.edited_at.strftime(
+                "%Y-%m-%dT%H:%M:%S.%fZ"
+            )
+            log_handler.write(
+                f"The activation was edited at {edited_at}", flush=True
+            )
 
         LOGGER.info(
             "Starting container for activation instance: "

tests/integration/api/test_activation.py

@@ -1115,8 +1115,10 @@ def test_update_activation(
     )
     assert response.status_code == status.HTTP_200_OK
     data = response.data
+    assert data["edited_at"] is not None
     activation = models.Activation.objects.filter(id=data["id"]).first()
     assert activation.name == "another_name"
+    assert activation.edited_at is not None
 
 
 @pytest.mark.django_db

tests/integration/services/activation/test_manager.py

@@ -354,6 +354,11 @@ def test_start_first_run(
     )
     assert rulebook_process_queue.queue_name == job_mock.origin
 
+    logs = models.RulebookProcessLog.objects.filter(
+        activation_instance=basic_activation.latest_instance
+    ).all()
+    assert not any("The activation was edited at" in log.log for log in logs)
+
 
 @pytest.mark.django_db
 def test_monitor_to_running_status(
@@ -423,6 +428,8 @@ def test_start_restart(
     preseed_credential_types,
 ):
     """Test start verb for a restarted activation."""
+    running_activation.edited_at = timezone.now()
+    running_activation.save(update_fields=["edited_at"])
     activation_manager = ActivationManager(
         db_instance=running_activation,
         container_engine=container_engine_mock,
@@ -449,6 +456,10 @@ def test_start_restart(
         process=running_activation.latest_instance,
     )
     assert rulebook_process_queue.queue_name == job_mock.origin
+    logs = models.RulebookProcessLog.objects.filter(
+        activation_instance=running_activation.latest_instance
+    ).all()
+    assert any("The activation was edited at" in log.log for log in logs)
 
 
 @pytest.mark.django_db