test WPS endpoint to allow execute with empty string input

tests/functional/test_wps_app.py

@@ -20,6 +20,7 @@
     setup_config_with_celery,
     setup_config_with_mongodb,
     setup_config_with_pywps,
+    setup_mongodb_jobstore,
     setup_mongodb_processstore
 )
 from weaver import xml_util
@@ -45,6 +46,7 @@ def setUp(self):
         config = setup_config_with_pywps(config)
         config = setup_config_with_celery(config)
         self.process_store = setup_mongodb_processstore(config)
+        self.job_store = setup_mongodb_jobstore(config)
         self.app = get_test_weaver_app(config=config, settings=settings)
 
         # add processes by database Process type
@@ -146,6 +148,24 @@ def test_execute_allowed_demo(self):
         resp.mustcontain("<wps:ProcessAccepted")
         resp.mustcontain(f"PyWPS Process {HelloWPS.identifier}")
 
+    def test_execute_allowed_empty_string(self):
+        template = "service=wps&request=execute&version=1.0.0&identifier={}&datainputs=name="
+        params = template.format(HelloWPS.identifier)
+        url = self.make_url(params)
+        with contextlib.ExitStack() as stack_exec:
+            for mock_exec in mocked_execute_celery():
+                stack_exec.enter_context(mock_exec)
+            resp = self.app.get(url)
+        assert resp.status_code == 200  # FIXME: replace by 202 Accepted (?) https://github.com/crim-ca/weaver/issues/14
+        assert resp.content_type in ContentType.ANY_XML
+        resp.mustcontain("<wps:ExecuteResponse")
+        resp.mustcontain("<wps:ProcessAccepted")
+        resp.mustcontain(f"PyWPS Process {HelloWPS.identifier}")
+        loc = resp.xml.get("statusLocation")
+        job_id = loc.rsplit("/", 1)[-1].split(".", 1)[0]
+        job = self.job_store.fetch_by_id(job_id)
+        assert job.inputs[0]["data"] == ""
+
     def test_execute_deployed_with_visibility_allowed(self):
         headers = {"Accept": ContentType.APP_XML}
         params_template = "service=wps&request=execute&version=1.0.0&identifier={}&datainputs=test_input=test"

weaver/store/mongodb.py

@@ -891,7 +891,7 @@ def delete_job(self, job_id):
         result = self.collection.delete_one({"id": job_id})
         return result.deleted_count == 1
 
-    def fetch_by_id(self, job_id):
+    def c(self, job_id):
         # type: (AnyUUID) -> Job
         """
         Gets job for given ``job_id`` from `MongoDB` storage.