Rewrite wrong_input.py generator

CHANGELOG.md

@@ -7,7 +7,7 @@
 #### Schema migrations
 #### Data migrations
 ### Changes
-- [#169](https://github.com/LayerManager/layman/issues/169) [POST Workspace Layers](doc/rest.md#post-workspace-layers) accepts also compressed data files in ZIP format (`*.zip`) in `file` parameter. [PATCH Workspace Layer](doc/rest.md#patch-workspace-layer) accepts also data file in ZIP format (`*.zip`) in `file` parameter.
+- [#169](https://github.com/LayerManager/layman/issues/169) [POST Workspace Layers](doc/rest.md#post-workspace-layers) accepts also compressed data files in ZIP format (`*.zip`) in `file` parameter. [PATCH Workspace Layer](doc/rest.md#patch-workspace-layer) accepts also data file in ZIP format (`*.zip`) in `file` parameter. ZIP archives can be also uploaded by chunks.
 - [#169](https://github.com/LayerManager/layman/issues/169) [GET Workspace Layer](doc/rest.md#get-workspace-layer) returns path to main file inside archive if zipped file was sent (key `file.path`).
 - [#465](https://github.com/LayerManager/layman/issues/465) Fix situation, when Layman does not start if *.qgis file of the first layer with QML style does not exist. It was already fixed in v1.14.1.
 - [#464](https://github.com/LayerManager/layman/issues/464) Fix publishing layers with unusual attribute  names (e.g. `x,` or `Číslo`) and QML styles. It was already fixed in v1.14.1.

doc/rest.md

@@ -123,7 +123,7 @@ Body parameters:
       - PNG (.png, with .png.aux.xml or .pgw)
       - JPEG (.jpg, with .jpg.aux.xml or .jgw)
       - any of above types in single ZIP file (.zip)
-      - file names, i.e. array of strings (not supported for ZIP file)
+      - file names, i.e. array of strings
    - if file names are provided, files must be uploaded subsequently using [POST Workspace Layer Chunk](#post-workspace-layer-chunk)
    - in case of raster data input, following input combinations of bands and color interpretations are supported:
       - 1 band: Gray

src/layman/layer/filesystem/input_chunk.py

@@ -41,14 +41,14 @@ def delete_layer(workspace, layername):
 get_publication_uuid = input_file.get_publication_uuid
 
 
-def save_layer_files_str(workspace, layername, files_str, check_crs):
+def save_layer_files_str(workspace, layername, input_files, check_crs):
     input_file_dir = input_file.get_layer_input_file_dir(workspace, layername)
-    if len(files_str) == 1 and input_file.get_compressed_main_file_extension(files_str[0]):
-        main_filename = files_str[0]
+    if input_files.is_one_archive:
+        main_filename = input_files.raw_paths_to_archives[0]
     else:
-        main_filename = input_file.get_main_file_name(files_str)
+        main_filename = input_files.raw_main_file_paths[0]
     _, filepath_mapping = input_file.get_file_name_mappings(
-        files_str, main_filename, layername, input_file_dir
+        input_files.raw_paths, main_filename, layername, input_file_dir
     )
     filepath_mapping = {
         k: v for k, v in filepath_mapping.items() if v is not None

src/layman/layer/filesystem/input_file.py

@@ -185,12 +185,14 @@ def check_filenames(workspace, layername, input_files, check_crs, ignore_existin
                                               + ', '.join(settings.COMPRESSED_FILE_EXTENSIONS.keys()),
                                   'files': [os.path.relpath(fp, input_files.saved_paths_dir) for fp in input_files.raw_paths_to_archives],
                                   })
-        raise LaymanError(2, {'parameter': 'file',
-                              'expected': 'At least one file with any of extensions: '
-                                          + ', '.join(util.get_all_allowed_main_extensions())
-                                          + '; or one of them in single .zip file.',
-                              'files': [os.path.relpath(fp, input_files.saved_paths_dir) for fp in filenames],
-                              })
+        if len(input_files.raw_paths_to_archives) == 0 or input_files.archived_paths:
+            raise LaymanError(2, {'parameter': 'file',
+                                  'expected': 'At least one file with any of extensions: '
+                                              + ', '.join(util.get_all_allowed_main_extensions())
+                                              + '; or one of them in single .zip file.',
+                                  'files': [os.path.relpath(fp, input_files.saved_paths_dir) for fp in filenames],
+                                  })
+        main_files = input_files.raw_paths_to_archives
     main_filename = main_files[0]
     basename, ext = map(
         lambda s: s.lower(),
@@ -211,7 +213,7 @@ def check_filenames(workspace, layername, input_files, check_crs, ignore_existin
         if len(missing_exts) > 0:
             detail = {
                 'missing_extensions': missing_exts,
-                'path': main_filename,
+                'path': os.path.relpath(main_filename, input_files.saved_paths_dir),
             }
             if '.prj' in missing_exts:
                 detail['suggestion'] = 'Missing .prj file can be fixed also ' \
@@ -230,18 +232,17 @@ def check_filenames(workspace, layername, input_files, check_crs, ignore_existin
             raise LaymanError(3, conflict_paths)
 
 
-def save_layer_files(workspace, layername, files, check_crs, *, output_dir=None, zipped=False):
-    filenames = list(map(lambda f: f.filename, files))
-    if zipped:
-        main_filename = files[0].filename
+def save_layer_files(workspace, layername, input_files, check_crs, *, output_dir=None):
+    if input_files.is_one_archive:
+        main_filename = input_files.raw_paths_to_archives[0]
     else:
-        main_filename = get_main_file_name(filenames)
+        main_filename = input_files.raw_main_file_paths[0]
     output_dir = output_dir or ensure_layer_input_file_dir(workspace, layername)
     _, filepath_mapping = get_file_name_mappings(
-        filenames, main_filename, layername, output_dir
+        input_files.raw_paths, main_filename, layername, output_dir
     )
 
-    common.save_files(files, filepath_mapping)
+    common.save_files(input_files.sent_streams, filepath_mapping)
 
     main_filepath = get_gdal_format_file_path(filepath_mapping[main_filename])
     check_main_file(main_filepath, check_crs=check_crs)

src/layman/layer/filesystem/util.py

@@ -68,7 +68,7 @@ def saved_paths_to_archives(self):
 
     @property
     def is_one_archive(self):
-        return len(self.raw_paths) == 1 and len(self.raw_paths_to_archives) == 1
+        return len(self.raw_paths_to_archives) == 1 and not self.raw_main_file_paths
 
     def archived_paths(self, *, with_zip_in_path=False):
         return [
@@ -84,6 +84,11 @@ def raw_or_archived_paths(self):
             return self.archived_paths(with_zip_in_path=True)
         return self.raw_paths
 
+    @property
+    def raw_main_file_paths(self):
+        return [fn for fn in self.raw_paths
+                if os.path.splitext(fn)[1] in get_all_allowed_main_extensions()]
+
     @property
     def raw_or_archived_main_file_paths(self):
         return [fn for fn in self.raw_or_archived_paths
@@ -98,7 +103,7 @@ def raw_or_archived_main_file_path(self):
 
     @property
     def archive_type(self):
-        return os.path.splitext(self.raw_paths[0])[1] if self.is_one_archive else None
+        return os.path.splitext(self.saved_paths_to_archives[0])[1] if self.is_one_archive else None
 
     @property
     def main_file_path_for_gdal(self):

src/layman/layer/rest_workspace_layer.py

@@ -108,8 +108,7 @@ def patch(workspace, layername):
         # file checks
         if not use_chunk_upload:
             temp_dir = tempfile.mkdtemp(prefix="layman_")
-            input_file.save_layer_files(workspace, layername, input_files.sent_streams, check_crs,
-                                        output_dir=temp_dir, zipped=input_files.is_one_archive)
+            input_file.save_layer_files(workspace, layername, input_files, check_crs, output_dir=temp_dir)
 
     if input_files.raw_paths:
         file_type = input_file.get_file_type(input_files.raw_or_archived_main_file_path)
@@ -152,7 +151,7 @@ def patch(workspace, layername):
 
             if use_chunk_upload:
                 files_to_upload = input_chunk.save_layer_files_str(
-                    workspace, layername, input_files.sent_paths, check_crs)
+                    workspace, layername, input_files, check_crs)
                 layer_result.update({
                     'files_to_upload': files_to_upload,
                 })

src/layman/layer/rest_workspace_layers.py

@@ -141,7 +141,7 @@ def post(workspace):
         input_style.save_layer_file(workspace, layername, style_file, style_type)
         if use_chunk_upload:
             files_to_upload = input_chunk.save_layer_files_str(
-                workspace, layername, input_files.sent_paths, check_crs)
+                workspace, layername, input_files, check_crs)
             layer_result.update({
                 'files_to_upload': files_to_upload,
             })
@@ -150,8 +150,7 @@ def post(workspace):
             })
         else:
             try:
-                input_file.save_layer_files(workspace, layername, input_files.sent_streams, check_crs,
-                                            zipped=input_files.is_one_archive)
+                input_file.save_layer_files(workspace, layername, input_files, check_crs)
             except BaseException as exc:
                 uuid.delete_layer(workspace, layername)
                 input_file.delete_layer(workspace, layername)

tests/dynamic_data/publications/__init__.py

@@ -2,7 +2,7 @@
 import tests.asserts.final.publication as publication
 import tests.asserts.processing as processing
 from test_tools import process_client
-from . import wrong_input
+from . import wrong_input, file_input
 from .. import predefined_actions, predefined_zip_files
 from ... import Action, Publication, dynamic_data as consts
 
@@ -1045,4 +1045,5 @@
         },
     ],
     **wrong_input.generate(consts.COMMON_WORKSPACE + '_generated_wrong_input'),
+    **file_input.generate(consts.COMMON_WORKSPACE + '_generated_file_input'),
 }

tests/dynamic_data/publications/file_input.py

@@ -0,0 +1,68 @@
+import tests.asserts.processing as processing
+import tests.asserts.final.publication as publication
+from test_tools import process_client
+from ... import Action, Publication, dynamic_data as consts
+
+KEY_PUBLICATION_TYPE = 'publ_type'
+KEY_ACTION_PARAMS = 'action_params'
+
+TESTCASES = {
+    'zip_and_other_than_main_file': {
+        KEY_PUBLICATION_TYPE: process_client.LAYER_TYPE,
+        KEY_ACTION_PARAMS: {
+            'file_paths': [
+                'sample/style/small_layer.qml',
+                'sample/layman.layer/small_layer.zip',
+            ],
+        },
+        consts.KEY_FINAL_ASSERTS: [
+            Action(publication.internal.correct_values_in_detail, {
+                'exp_publication_detail': {
+                    'bounding_box': [1571204.369948366, 6268896.225570714, 1572590.854206196, 6269876.33561699],
+                },
+                'file_extension': 'zip/small_layer.geojson',
+                'gdal_prefix': '/vsizip/',
+                'publ_type_detail': ('vector', 'sld'),
+            }),
+            Action(publication.internal.thumbnail_equals, {
+                'exp_thumbnail': 'sample/style/basic_sld.png',
+            }),
+        ],
+    },
+}
+
+
+def generate(workspace=None):
+    workspace = workspace or consts.COMMON_WORKSPACE
+
+    result = dict()
+    for testcase, tc_params in TESTCASES.items():
+        post = [{
+            consts.KEY_ACTION: {
+                consts.KEY_CALL: Action(process_client.publish_workspace_publication,
+                                        tc_params[KEY_ACTION_PARAMS]),
+                consts.KEY_RESPONSE_ASSERTS: [
+                    Action(processing.response.valid_post, dict()),
+                ], },
+            consts.KEY_FINAL_ASSERTS: [
+                *publication.IS_LAYER_COMPLETE_AND_CONSISTENT,
+                *tc_params[consts.KEY_FINAL_ASSERTS],
+            ],
+        }]
+        post_chunks = [{
+            consts.KEY_ACTION: {
+                consts.KEY_CALL: Action(process_client.publish_workspace_publication,
+                                        {**tc_params[KEY_ACTION_PARAMS],
+                                         'with_chunks': True, }),
+                consts.KEY_RESPONSE_ASSERTS: [
+                    Action(processing.response.valid_post, dict()),
+                ], },
+            consts.KEY_FINAL_ASSERTS: [
+                *publication.IS_LAYER_COMPLETE_AND_CONSISTENT,
+                *tc_params[consts.KEY_FINAL_ASSERTS],
+            ],
+        }]
+        result[Publication(workspace, tc_params[KEY_PUBLICATION_TYPE], testcase + '_post_sync')] = post
+        result[Publication(workspace, tc_params[KEY_PUBLICATION_TYPE], testcase + '_post_chunks')] = post_chunks
+
+    return result