[Fixes #10192] Include source into the ExecutionRequest model (#10193)

Co-authored-by: Alessio Fabiani <alessio.fabiani@geosolutionsgroup.com>

geonode/resource/api/tests.py

@@ -190,3 +190,27 @@ def test_endpoint_should_raise_error_if_pk_is_not_passed(self):
 
         self.assertEqual(500, response.status_code)
         self.assertDictEqual(expected, response.json())
+
+    def test_endpoint_should_return_the_source(self):
+        # creating dummy execution request
+        obj = ExecutionRequest.objects.create(
+            user=self.superuser,
+            func_name='import_new_resource',
+            action="import",
+            source="upload_workflow"
+        )
+        self.client.force_login(self.superuser)
+
+        _url = f"{reverse('executionrequest-list')}/{obj.exec_id}"
+
+        response = self.client.get(_url)
+        self.assertEqual(200, response.status_code)
+        self.assertIsNotNone(response.json())
+        payload = response.json()
+
+        source = payload.get("request", {}).get("source", None)
+        self.assertIsNotNone(source)
+        self.assertEqual('upload_workflow', source)
+
+        # cleanup
+        obj.delete()

geonode/resource/migrations/0008_executionrequest_source.py

@@ -0,0 +1,18 @@
+# Generated by Django 3.2.16 on 2022-10-25 07:43
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('resource', '0007_alter_executionrequest_action'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='executionrequest',
+            name='source',
+            field=models.CharField(default=None, max_length=250, null=True),
+        ),
+    ]

geonode/resource/models.py

@@ -69,3 +69,5 @@ class ExecutionRequest(models.Model):
         default=ExecutionRequestAction.UNKNOWN.value,
         null=True
     )
+
+    source = models.CharField(max_length=250, null=True, default=None)