add reviewer to bpmn

app/apps/workflow/migrations/0008_caseusertask_author.py

@@ -0,0 +1,26 @@
+# Generated by Django 5.0.8 on 2025-01-30 09:17
+
+import django.db.models.deletion
+from django.conf import settings
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ("workflow", "0007_workflowoption"),
+        migrations.swappable_dependency(settings.AUTH_USER_MODEL),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name="caseusertask",
+            name="requires_review",
+            field=models.ForeignKey(
+                null=True,
+                on_delete=django.db.models.deletion.PROTECT,
+                related_name="case_user_tasks",
+                to=settings.AUTH_USER_MODEL,
+            ),
+        ),
+    ]

app/apps/workflow/models.py

@@ -2,6 +2,7 @@
 import os
 
 
+from apps.users import auth
 from apps.events.models import CaseEvent, TaskModelEventEmitter
 from apps.cases.models import Case, CaseStateType
 from django.conf import settings
@@ -199,6 +200,13 @@ def _create_user_tasks(self, wf):
                 due_date=make_aware(datetime.datetime.today()),
                 case=self.case,
                 workflow=self,
+                initiated_by=(
+                    auth.get_user_model().objects.get(id=self.data.get("author"))
+                    if self.data.get("author")
+                    else None
+                ),
+                requires_review=task.task_spec.extensions.get("requires_review", False)
+                or False,
             )
             for task in ready_tasks
             if not CaseUserTask.objects.filter(
@@ -392,8 +400,17 @@ class CaseUserTask(models.Model):
         related_name="tasks",
         on_delete=models.CASCADE,
     )
-
+    initiated_by = models.ForeignKey(
+        to=settings.AUTH_USER_MODEL,
+        related_name="case_user_tasks",
+        on_delete=models.PROTECT,
+        null=True,
+    )
     objects = BulkCreateSignalsManager()
+    requires_review = models.BooleanField(
+        default=False,
+        help_text="Indicates whether this task requires review by another user.",
+    )
 
     @property
     def get_form_variables(self):

app/apps/workflow/serializers.py

@@ -11,6 +11,10 @@
 class CaseUserTaskSerializer(serializers.ModelSerializer):
     case = serializers.PrimaryKeyRelatedField(queryset=Case.objects.all())
     homeowner_association = serializers.SerializerMethodField()
+    initiated_by = serializers.SerializerMethodField()
+
+    def get_initiated_by(self, obj):
+        return obj.initiated_by.email if obj.initiated_by else None
 
     def get_homeowner_association(self, obj):
         return (
@@ -35,6 +39,8 @@ class Meta:
             "completed",
             "case",
             "homeowner_association",
+            "initiated_by",
+            "requires_review",
         )
 
 

app/apps/workflow/views.py

@@ -96,7 +96,7 @@ def _complete_task_common(self, serializer, save_document=False):
                 "value": serializer.validated_data.get("name"),
             }
             serializer.save()
-
+        variables["author"] = author.id
         task_data = {
             "case_user_task_id": case_user_task_id,
             "description": task.name,

app/config/settings.py

@@ -249,6 +249,7 @@ def get_redis_url():
                 "1.6.0": {},
                 "1.7.0": {},
                 "1.8.0": {},
+                "1.9.0": {},
             },
         },
         "sub_workflow": {