TCIA Adapter

src/mds/agg_mds/adapters.py

@@ -1581,6 +1581,105 @@ def normalizeToGen3MDSFields(self, data, **kwargs) -> Dict[str, Any]:
         return results
 
 
+class TCIAAdapter(RemoteMetadataAdapter):
+    """
+    Simple adapter for TCIA (cancerimagingarchive.net)
+    """
+
+    @retry(
+        stop=stop_after_attempt(5),
+        retry=retry_if_exception_type(httpx.TimeoutException),
+        wait=wait_random_exponential(multiplier=1, max=10),
+    )
+    def getRemoteDataAsJson(self, **kwargs) -> Dict:
+        results = {"results": []}
+
+        mds_url = kwargs.get("mds_url", None)
+        if mds_url is None:
+            return results
+
+        try:
+            response = httpx.get(mds_url)
+            response.raise_for_status()
+
+            response_data = response.json()
+            results["results"] = response_data
+
+        except httpx.TimeoutException as exc:
+            logger.error(f"An timeout error occurred while requesting {mds_url}.")
+            raise
+        except httpx.HTTPError as exc:
+            logger.error(
+                f"An HTTP error {exc.response.status_code if exc.response is not None else ''} occurred while requesting {exc.request.url}. Returning {len(results['results'])} results"
+            )
+        except Exception as exc:
+            logger.error(
+                f"An error occurred while requesting {mds_url} {exc}. Returning {len(results['results'])} results."
+            )
+
+        return results
+
+    @staticmethod
+    def addGen3ExpectedFields(
+        item, mappings, keepOriginalFields, globalFieldFilters, schema
+    ):
+        """
+        Map item fields to gen3 normalized fields
+        using the mapping and adding the location
+        """
+        results = item
+        if mappings is not None:
+            mapped_fields = RemoteMetadataAdapter.mapFields(
+                item, mappings, globalFieldFilters, schema
+            )
+            if keepOriginalFields:
+                results.update(mapped_fields)
+            else:
+                results = mapped_fields
+
+        return results
+
+    def normalizeToGen3MDSFields(self, data, **kwargs) -> Dict[str, Any]:
+        """
+        Iterates over the response.
+        :param data:
+        :return:
+        """
+        mappings = kwargs.get("mappings", None)
+        keepOriginalFields = kwargs.get("keepOriginalFields", False)
+        globalFieldFilters = kwargs.get("globalFieldFilters", [])
+        schema = kwargs.get("schema", {})
+
+        results = {}
+        for item in data["results"]:
+            normalized_item = TCIAAdapter.addGen3ExpectedFields(
+                item,
+                mappings,
+                keepOriginalFields,
+                globalFieldFilters,
+                schema,
+            )
+
+            normalized_item[
+                "description"
+            ] = f"TCIA data from collection: {normalized_item['program_name']}."
+
+            normalized_item["tags"] = [
+                {
+                    "name": normalized_item[tag] if normalized_item[tag] else "",
+                    "category": tag,
+                }
+                for tag in ["program_name"]
+            ]
+
+            results[normalized_item["_unique_id"]] = {
+                "_guid_type": "discovery_metadata",
+                "gen3_discovery": normalized_item,
+            }
+
+        return results
+
+
 def gather_metadata(
     gather,
     mds_url,
@@ -1627,6 +1726,7 @@ def gather_metadata(
     "gdc": GDCAdapter,
     "cidc": CIDCAdapter,
     "pdc": PDCAdapter,
+    "tcia": TCIAAdapter,
 }
 
 

tests/test_agg_mds_tcia_adapter.py

@@ -0,0 +1,94 @@
+import respx
+import httpx
+
+from mds.agg_mds.adapters import get_metadata
+
+
+@respx.mock
+def test_get_metadata_tcia():
+    tcia_response = """
+    [
+        {
+            "StudyInstanceUID": "study_id_1",
+            "StudyDate": "",
+            "StudyDescription": "Collection One.",
+            "PatientAge": "",
+            "PatientID": "",
+            "PatientName": "",
+            "PatientSex": "",
+            "EthnicGroup": "",
+            "Collection": "Collection1",
+            "SeriesCount": 1,
+            "LongitudinalTemporalEventType": "",
+            "LongitudinalTemporalOffsetFromEvent": 0
+        },
+        {
+            "StudyInstanceUID": "study_id_2",
+            "StudyDate": "",
+            "StudyDescription": "Collection Two.",
+            "PatientAge": "",
+            "PatientID": "",
+            "PatientName": "",
+            "PatientSex": "",
+            "EthnicGroup": "",
+            "Collection": "Collection2",
+            "SeriesCount": 2,
+            "LongitudinalTemporalEventType": "",
+            "LongitudinalTemporalOffsetFromEvent": 1
+        }
+    ]
+    """
+
+    field_mappings = {
+        "_unique_id": "path:StudyInstanceUID",
+        "commons": "TCIA",
+        "study_title": "path:StudyDescription",
+        "program_name": "path:Collection",
+        "description": "",
+        "tags": [],
+    }
+
+    respx.get("http://test/ok").mock(side_effect=httpx.HTTPError)
+    assert (
+        get_metadata("tcia", "http://test/ok", filters=None, mappings=field_mappings)
+        == {}
+    )
+
+    respx.get("http://test/ok").mock(side_effect=Exception)
+    assert (
+        get_metadata("tcia", "http://test/ok", filters=None, mappings=field_mappings)
+        == {}
+    )
+
+    respx.get(
+        "http://test/ok",
+    ).mock(return_value=httpx.Response(status_code=200, content=tcia_response))
+
+    filters = {"size": 5}
+
+    assert get_metadata(
+        "tcia", "http://test/ok", filters=filters, mappings=field_mappings
+    ) == {
+        "study_id_1": {
+            "_guid_type": "discovery_metadata",
+            "gen3_discovery": {
+                "_unique_id": "study_id_1",
+                "commons": "TCIA",
+                "description": "TCIA data from collection: Collection1.",
+                "program_name": "Collection1",
+                "study_title": "Collection One.",
+                "tags": [{"category": "program_name", "name": "Collection1"}],
+            },
+        },
+        "study_id_2": {
+            "_guid_type": "discovery_metadata",
+            "gen3_discovery": {
+                "_unique_id": "study_id_2",
+                "commons": "TCIA",
+                "description": "TCIA data from collection: Collection2.",
+                "program_name": "Collection2",
+                "study_title": "Collection Two.",
+                "tags": [{"category": "program_name", "name": "Collection2"}],
+            },
+        },
+    }