chore(controller):check mount volume path

Author: lijianguo

rootfs/api/models/app.py

@@ -11,7 +11,6 @@
 import requests
 import string
 import time
-import uuid
 from urllib.parse import urljoin
 
 from django.conf import settings

rootfs/api/views.py

@@ -669,6 +669,22 @@ def path(self, request, *args, **kwargs):
         if container_types:
             raise DryccException("process type {} is not included in profile".
                                  format(','.join(container_types)))
+
+        if set(new_path.items()).issubset(set(obj.path.items())):
+            raise DryccException("mount path not changed")
+
+        other_volumes = self.get_app().volume_set.exclude(name=obj.name)
+        type_paths = {}  # {'type1':[path1,path2], tyep2:[path3,path4]}
+        for _ in other_volumes:
+            for k, v in _.path.items():
+                if k not in type_paths:
+                    type_paths[k] = [v]
+                else:
+                    type_paths[k].append(k)
+        repeat_path = [v for k, v in new_path.items() if v in type_paths.get(k, [])]  # noqa
+        if repeat_path:
+            raise DryccException("path {} is used by another volume".
+                                 format(','.join(repeat_path)))
         path = obj.path
         pre_path = deepcopy(path)
         # merge mount path

rootfs/scheduler/resources/deployment.py

@@ -34,7 +34,7 @@ def manifest(self, namespace, name, image, entrypoint, command, spec_annotations
         replicas = kwargs.get('replicas', 0)
         batches = kwargs.get('deploy_batches', None)
         tags = kwargs.get('tags', {})
-        volumes = kwargs.get('volumes', [])
+
         labels = {
             'app': namespace,
             'type': kwargs.get('app_type'),
@@ -107,6 +107,8 @@ def manifest(self, namespace, name, image, entrypoint, command, spec_annotations
         # set the old deployment spec annotations on this deployment
         manifest['spec']['template']['metadata']['annotations'] = spec_annotations
 
+        return manifest
+
     def create(self, namespace, name, image, entrypoint, command, spec_annotations, **kwargs):
         manifest = self.manifest(namespace, name, image,
                                  entrypoint, command, spec_annotations, **kwargs)