Implement the workflows Django app

Author: jbernal0019

.github/workflows/dev.yml

@@ -41,7 +41,8 @@
     'pacsfiles',
     'servicefiles',
     'filebrowser',
-    'users'
+    'users',
+    'workflows'
 ]
 
 # Pagination

chris_backend/config/settings/common.py

@@ -72,7 +72,7 @@
 
 for app in ['collectionjson', 'core', 'feeds', 'plugins', 'plugininstances', 'pipelines',
             'pipelineinstances', 'uploadedfiles', 'pacsfiles', 'servicefiles', 'users',
-            'filebrowser']:
+            'filebrowser', 'workflows']:
     LOGGING['loggers'][app] = {
             'level': 'DEBUG',
             'handlers': ['console_verbose', 'file'],

chris_backend/config/settings/local.py

@@ -9,6 +9,7 @@
 from plugininstances import views as plugininstance_views
 from pipelines import views as pipeline_views
 from pipelineinstances import views as pipelineinstance_views
+from workflows import views as workflow_views
 from uploadedfiles import views as uploadedfile_views
 from pacsfiles import views as pacsfile_views
 from servicefiles import views as servicefile_views
@@ -276,6 +277,23 @@
         name='pipelineinstance-plugininstance-list'),
 
 
+    path('v1/pipelines/<int:pk>/workflows/',
+         workflow_views.WorkflowList.as_view(),
+         name='workflow-list'),
+
+    path('v1/pipelines/workflows/',
+         workflow_views.AllWorkflowList.as_view(),
+         name='allworkflow-list'),
+
+    path('v1/pipelines/workflows/search/',
+         workflow_views.AllWorkflowListQuerySearch.as_view(),
+         name='allworkflow-list-query-search'),
+
+    path('v1/pipelines/workflows/<int:pk>/',
+         workflow_views.WorkflowDetail.as_view(),
+         name='workflow-detail'),
+
+
     path('v1/uploadedfiles/',
         uploadedfile_views.UploadedFileList.as_view(),
         name='uploadedfile-list'),

chris_backend/core/api.py

@@ -303,6 +303,7 @@ def list(self, request, *args, **kwargs):
                  'pipelines': reverse('pipeline-list', request=request),
                  'pipeline_instances': reverse('allpipelineinstance-list',
                                                request=request),
+                 'workflows': reverse('allworkflow-list', request=request),
                  'tags': reverse('tag-list', request=request),
                  'uploadedfiles': reverse('uploadedfile-list', request=request),
                  'pacsfiles': reverse('pacsfile-list', request=request),

chris_backend/feeds/views.py

@@ -48,7 +48,7 @@ def validate_previous_plugin_inst(self, previous_plugin_inst_id):
         except (ValueError, ObjectDoesNotExist):
             raise serializers.ValidationError(
                 {'previous_plugin_inst_id':
-                     ["Couldn't find any 'previous' plugin instance with id %s."]})
+                     [f"Couldn't find any 'previous' plugin instance with id {pk}."]})
         # check that the user can run plugins within this feed
         user = self.context['request'].user
         if user not in previous_plugin_inst.feed.owner.all():

chris_backend/pipelineinstances/serializers.py

@@ -27,13 +27,14 @@ class PipelineSerializer(serializers.HyperlinkedModelSerializer):
     default_parameters = serializers.HyperlinkedIdentityField(
         view_name='pipeline-defaultparameter-list')
     instances = serializers.HyperlinkedIdentityField(view_name='pipelineinstance-list')
+    workflows = serializers.HyperlinkedIdentityField(view_name='workflow-list')
 
     class Meta:
         model = Pipeline
         fields = ('url', 'id', 'name', 'locked', 'authors', 'category', 'description',
                   'plugin_tree', 'plugin_inst_id', 'owner_username', 'creation_date',
                   'modification_date', 'plugins', 'plugin_pipings', 'default_parameters',
-                  'instances')
+                  'instances', 'workflows')
 
     def create(self, validated_data):
         """
@@ -118,10 +119,10 @@ def validate_plugin_inst_id(self, plugin_inst_id):
             raise serializers.ValidationError(
                 ["Couldn't find any plugin instance with id %s." % plugin_inst_id])
         plg = plg_inst.plugin
-        if plg.meta.type == 'fs':
+        if plg.meta.type != 'ds':
             raise serializers.ValidationError(
-                ["Plugin instance of %s which is of type 'fs' and therefore can not "
-                 "be used as the root of a new pipeline." % plg.meta.name])
+                [f"Plugin instance of %s which is of type {plg.meta.type} and therefore "
+                 f"can not be used as the root of a new pipeline." % plg.meta.name])
         return plg_inst
 
     def validate_plugin_tree(self, plugin_tree):
@@ -313,19 +314,21 @@ def _add_plugin_tree_to_pipeline(pipeline, tree_dict):
 
 class PluginPipingSerializer(serializers.HyperlinkedModelSerializer):
     plugin_id = serializers.ReadOnlyField(source='plugin.id')
+    plugin_name = serializers.ReadOnlyField(source='plugin.meta.name')
+    plugin_version = serializers.ReadOnlyField(source='plugin.version')
     pipeline_id = serializers.ReadOnlyField(source='pipeline.id')
     previous_id = serializers.ReadOnlyField(source='previous.id')
     previous = serializers.HyperlinkedRelatedField(view_name='pluginpiping-detail',
-                                                 read_only=True)
+                                                   read_only=True)
     plugin = serializers.HyperlinkedRelatedField(view_name='plugin-detail',
                                                  read_only=True)
     pipeline = serializers.HyperlinkedRelatedField(view_name='pipeline-detail',
                                                    read_only=True)
 
     class Meta:
         model = PluginPiping
-        fields = ('url', 'id', 'plugin_id', 'pipeline_id', 'previous_id', 'previous',
-                  'plugin', 'pipeline')
+        fields = ('url', 'id', 'previous_id', 'plugin_id', 'plugin_name',
+                  'plugin_version', 'pipeline_id', 'previous', 'plugin', 'pipeline')
 
 
 class DefaultPipingStrParameterSerializer(serializers.HyperlinkedModelSerializer):

chris_backend/pipelines/serializers.py

@@ -353,3 +353,11 @@ class Meta:
 
     def __str__(self):
         return self.value
+
+
+PARAMETER_MODELS = {'string': StrParameter,
+                    'integer': IntParameter,
+                    'float': FloatParameter,
+                    'boolean': BoolParameter,
+                    'path': PathParameter,
+                    'unextpath': UnextpathParameter}

chris_backend/plugininstances/models.py

@@ -0,0 +1,3 @@
+from django.contrib import admin
+
+# Register your models here.