Added fullUrl unique check to $extract

app/sdc/extract.py

@@ -1,6 +1,8 @@
 from aiohttp import ClientSession, web
 from funcy.seqs import flatten
 
+from .utils import check_mappers_bundles_full_url_duplicates
+
 
 async def get_external_service_bundle(session, service, template, context):
     async with session.post(
@@ -17,12 +19,16 @@ async def get_external_service_bundle(session, service, template, context):
 
 
 async def execute_mappers_bundles(client, mappers_bundles):
+    flatted_mappers_bundles = list(flatten(bundle["entry"] for bundle in mappers_bundles))
+
+    check_mappers_bundles_full_url_duplicates(flatted_mappers_bundles)
+
     not_transaction = any(bundle.get("type") != "transaction" for bundle in mappers_bundles)
 
     result_bundle = {
         "resourceType": "Bundle",
         "type": "batch" if not_transaction else "transaction",
-        "entry": list(flatten(bundle["entry"] for bundle in mappers_bundles)),
+        "entry": flatted_mappers_bundles,
     }
 
     return await client.execute("/", data=result_bundle)

app/sdc/utils.py

@@ -170,3 +170,26 @@ def validate_context(context_definition, env):
                 )
         if len(errors) > 0:
             raise ConstraintCheckOperationOutcome(errors)
+
+
+def check_mappers_bundles_full_url_duplicates(flatted_mappers_bundles):
+    full_urls_set = set()
+
+    for bundle in flatted_mappers_bundles:
+        full_url = bundle.get("fullUrl")
+
+        if full_url is None:
+            continue
+
+        if full_url in full_urls_set:
+            raise ConstraintCheckOperationOutcome(
+                [
+                    {
+                        "severity": "error",
+                        "key": "duplicate-full-url",
+                        "human": f"Duplicate fullUrl '{full_url}' in mappers bundles",
+                    }
+                ]
+            )
+
+        full_urls_set.add(full_url)