constants.py

import os

from datetime import datetime, timezone
from clients import logger

env_value = os.environ.get("ENV", "internal-dev")
environment_value = os.environ.get("ENVIRONMENT", "")
logger.info("Environment : %s", env_value)
logger.info("Build Env   : %s", environment_value)

env_internal_dev = environment_value == "internal-dev"

SOURCE_BUCKET = f"immunisation-batch-{env_value}-data-sources"
INPUT_PREFIX = ""
ACK_BUCKET = (
    "immunisation-batch-ref-data-destinations"
    if env_value == "ref"
    else "immunisation-batch-internal-dev-data-destinations"
)

FORWARDEDFILE_PREFIX = "forwardedFile/"
PRE_VALIDATION_ERROR = "Validation errors: doseQuantity.value must be a number"
POST_VALIDATION_ERROR = "Validation errors: contained[?(@.resourceType=='Patient')].name[0].given is a mandatory field"
DUPLICATE = "The provided identifier:"
ACK_PREFIX = "ack/"
HEADER_RESPONSE_CODE_COLUMN = "HEADER_RESPONSE_CODE"
FILE_NAME_VAL_ERROR = "Infrastructure Level Response Value - Processing Error"
CONFIG_BUCKET = "imms-internal-dev-supplier-config"
PERMISSIONS_CONFIG_FILE_KEY = "permissions_config.json"


def create_row(unique_id, fore_name, dose_amount, action_flag, header):
    """Helper function to create a single row with the specified UNIQUE_ID and ACTION_FLAG."""

    return {
        header: "9732928395",
        "PERSON_FORENAME": fore_name,
        "PERSON_SURNAME": "James",
        "PERSON_DOB": "20080217",
        "PERSON_GENDER_CODE": "0",
        "PERSON_POSTCODE": "WD25 0DZ",
        "DATE_AND_TIME": datetime.now(timezone.utc).strftime("%Y%m%dT%H%M%S"),
        "SITE_CODE": "RVVKC",
        "SITE_CODE_TYPE_URI": "https://fhir.nhs.uk/Id/ods-organization-code",
        "UNIQUE_ID": unique_id,
        "UNIQUE_ID_URI": "https://www.ravs.england.nhs.uk/",
        "ACTION_FLAG": action_flag,
        "PERFORMING_PROFESSIONAL_FORENAME": "PHYLIS",
        "PERFORMING_PROFESSIONAL_SURNAME": "James",
        "RECORDED_DATE": datetime.now(timezone.utc).strftime("%Y%m%d"),
        "PRIMARY_SOURCE": "TRUE",
        "VACCINATION_PROCEDURE_CODE": "956951000000104",
        "VACCINATION_PROCEDURE_TERM": "RSV vaccination in pregnancy (procedure)",
        "DOSE_SEQUENCE": "1",
        "VACCINE_PRODUCT_CODE": "42223111000001107",
        "VACCINE_PRODUCT_TERM": "Quadrivalent influenza vaccine (Sanofi Pasteur)",
        "VACCINE_MANUFACTURER": "Sanofi Pasteur",
        "BATCH_NUMBER": "BN92478105653",
        "EXPIRY_DATE": "20240915",
        "SITE_OF_VACCINATION_CODE": "368209003",
        "SITE_OF_VACCINATION_TERM": "Right arm",
        "ROUTE_OF_VACCINATION_CODE": "1210999013",
        "ROUTE_OF_VACCINATION_TERM": "Intradermal use",
        "DOSE_AMOUNT": dose_amount,
        "DOSE_UNIT_CODE": "2622896019",
        "DOSE_UNIT_TERM": "Inhalation - unit of product usage",
        "INDICATION_CODE": "1037351000000105",
        "LOCATION_CODE": "RJC02",
        "LOCATION_CODE_TYPE_URI": "https://fhir.nhs.uk/Id/ods-organization-code",
    }


def create_permissions_json(value):
    return {
        "all_permissions": {
            "DPSFULL": ["RSV_FULL", "COVID19_FULL", "FLU_FULL", "MMR_FULL"],
            "DPSREDUCED": ["COVID19_FULL", "FLU_FULL", "MMR_FULL"],
            "EMIS": [value, "RSV_FULL"],
            "PINNACLE": ["COVID19_UPDATE", "RSV_FULL"],
            "SONAR": "",
            "TPP": [""],
            "AGEM-NIVS": [""],
            "NIMS": [""],
            "EVA": [""],
            "RAVS": [""],
            "MEDICAL_DIRECTOR": [""],
            "WELSH_DA_1": [""],
            "WELSH_DA_2": [""],
            "NORTHERN_IRELAND_DA": [""],
            "SCOTLAND_DA": [""],
            "COVID19_VACCINE_RESOLUTION_SERVICEDESK": [""],
        },
        "definitions:": {
            "FULL": "Full permissions to create, update and delete a batch record",
            "CREATE": "Permission to create a batch record",
            "UPDATE": "Permission to update a batch record",
            "DELETE": "Permission to delete a batch record",
        },
    }