Testing external contributor PR #313

docs/howto/devTest.md

@@ -1,25 +1,11 @@
 ## Dev-Test
 
-### Set up Python Virtual Environment
-
-You can set up a Python development environment with a virtual environment:
-
-```bash
-python3 -m venv py3
-```
-
-Make sure that you have the virtual environment activated:
-
-```bash
-. py3/bin/activate
-```
-
 ### Install poetry
 
 To use the latest code in this repo (or to develop new features) you can clone this repo, install `poetry`:
 
 ```
-curl -sSL https://raw.githubusercontent.com/python-poetry/poetry/master/get-poetry.py | python -
+curl -sSL https://install.python-poetry.org | python3 -
 ```
 
 and then use `poetry` to install this package:
@@ -34,8 +20,7 @@ poetry install -vv
 Local development like this:
 
 ```
-poetry shell
-poetry install -vv
+eval $(poetry env activate)
 python3 -m pytest
 ```
 

docs/howto/fhir.md

@@ -0,0 +1,30 @@
+## FHIR 
+
+This integration aims to enhance the data ingestion capabilities of Gen3 by integrating a Fast Healthcare Interoperability Resources (FHIR) data ingestion pipeline & tools.  FHIR is an important standard for working with Electronic Health Records (EHR) and we have started development of a Gen3 FHIR Proxy service.  The overall goal is to allow users to seamlessly ingest data into an existing FHIR server. Gen3 is working on adding support for FHIR and this tool will help with data preparation and interaction in the future. 
+
+
+The fhir commands can be invoked as follows
+
+`gen3 fhir COMMAND [ARGS] [OPTIONS]`
+
+For a list of commands and options run
+
+`gen3 fhir --help`
+
+For example, the following tags the 'Patient.ndjson' file with Gen3 authorization and outputs 'gen3_Patient.ndjson' using the authorization rules from 'config.yaml'
+
+`gen3 fhir transform Patient.ndjson gen3_Patient.ndjson config.yaml --batch_size 10000 --workers 8 `
+
+
+The authorization configuration file has to be in yaml format and can have multiple conditions, e.g:
+
+```yaml
+rules:
+ - resource_type: "Patient"
+   condition: "Patient.managingOrganization.reference = 'Organization/site-alpha'"
+   authz: "/programs/Alpha/projects/Main"
+
+ - resource_type: "Patient"
+   condition: "Patient.managingOrganization.reference = 'Organization/site-alpha' and Patient.gender = 'male'"
+   authz: "/programs/Alpha/projects/Main"
+```

gen3/cli/__main__.py

@@ -15,6 +15,7 @@
 import gen3.cli.drs_pull as drs_pull
 import gen3.cli.users as users
 import gen3.cli.wrap as wrap
+import gen3.cli.fhir as fhir
 import gen3
 from gen3 import logging as sdklogging
 from gen3.cli import nih
@@ -145,4 +146,5 @@ def main(
 main.add_command(nih.nih)
 main.add_command(users.users)
 main.add_command(wrap.run)
+main.add_command(fhir.fhir)
 main()

gen3/cli/fhir.py

@@ -0,0 +1,106 @@
+import click
+import os
+import pathlib
+from cdislogging import get_logger
+from gen3.fhir import *
+
+logging = get_logger(__name__)
+TMP_ROOT = pathlib.Path(".fhir_transform/tmp")
+
+
+@click.group()
+def fhir():
+    """Commands for FHIR data processing"""
+    pass
+
+
+@click.command(
+    context_settings={"help_option_names": ["-h", "--help"]},
+    help="Tag Bulk FHIR data with Gen3 compatible authorization tags",
+)
+@click.argument(
+    "input_file",
+    type=click.Path(exists=True, dir_okay=False, readable=True),
+    metavar="input_file",
+)
+@click.argument(
+    "output_file", type=click.Path(dir_okay=False, writable=True), metavar="output_file"
+)
+@click.argument(
+    "config",
+    type=click.Path(exists=True, dir_okay=False, readable=True),
+    metavar="config",
+)
+@click.option(
+    "-b",
+    "--batch_size",
+    type=click.IntRange(min=1),
+    default=10000,
+    show_default=True,
+    metavar="batch_size",
+    help="batch size for chunking",
+)
+@click.option(
+    "-w",
+    "--workers",
+    type=click.IntRange(min=1),
+    default=8,
+    show_default=True,
+    metavar="workers",
+    help="number of parallel processes",
+)
+@click.option(
+    "--force",
+    is_flag=True,
+    help="Remove all intermediate files for this run before exiting even if run crashes",
+)
+def cli(
+    input_file: str | os.PathLike[str],
+    output_file: str | os.PathLike[str],
+    config: str | os.PathLike[str],
+    workers: int,
+    batch_size: int,
+    force: bool,
+):
+    """
+    CLI implementation of fhir_tagger.
+
+    Args:
+        input_file (str): Input .ndjson file
+        output_file (str): Output file name
+        config (str): .yaml file with authorization rules
+        batch_size (int): numb er of lines per chunk
+        workers (int): number of parallel processes
+        force (bool): remove all intermediate files for this run before exiting even if it crashes
+    """
+    fhir_tagger(input_file, output_file, config, workers, batch_size, force)
+
+
+@click.command(
+    context_settings={"help_option_names": ["-h", "--help"]},
+    help="Remove all intermediate files in the tmp folder from previous runs",
+)
+@click.option(
+    "--dry-run",
+    is_flag=True,
+    help="Used with --cleanup, report what would be deleted with --cleanup without deleting the files",
+)
+@click.option(
+    "--force",
+    is_flag=True,
+    help="Remove temporary directory ignoring status of each directory",
+)
+def cleanup(dry_run: bool, force: bool):
+    """
+    Remove all intermediate files in the tmp folder from previous runs
+
+    Args:
+        dry_run (bool): If True, list the files that would be removed, but not actually remove them
+        force (bool): Delete all intermediate directories disregarding the status
+    """
+
+    cleanup_fhir_transform_artifacts(dry_run=dry_run, force=force)
+
+
+fhir.add_command(cli, name="transform")
+fhir.add_command(cleanup, name="cleanup")