New: [AEA-6045] - Extract interaction worker logic

.gitignore

@@ -23,3 +23,6 @@ cover/
 # Build
 dist/
 __pycache__/
+
+# Temp
+agents.md

pyproject.toml

@@ -11,7 +11,15 @@ authors = [
 ]
 readme = "README.md"
 requires-python = "==3.10.12"
-dependencies = ["boto3 (>=1.26.159,<2.0.0)", "botocore (>=1.29.159,<1.30.0)", "simplejson (>=3.17.2,<4.0.0)", "python-dateutil (>=2.7.0.post0,<3.0.0)", "six (>=1.5,<2.0.0)"]
+dependencies = [
+    "boto3 (>=1.26.159,<2.0.0)",
+    "botocore (>=1.29.159,<1.30.0)",
+    "lxml (==4.6.3)",
+    "python-dateutil (>=2.7.0.post0,<3.0.0)",
+    "pytz (==2020.4)",
+    "simplejson (>=3.17.2,<4.0.0)",
+    "six (>=1.5,<2.0.0)"
+]
 
 [tool.poetry]
 packages = [{include = "eps_spine_shared", from = "src"}]

src/eps_spine_shared/common/checksum_util.py

@@ -0,0 +1,64 @@
+from string import ascii_uppercase
+
+LONGIDLENGTH_WITH_CHECKDIGIT = 37
+SHORTIDLENGTH_WITH_CHECKDIGIT = 20
+
+
+def calculate_checksum(prescription_id):
+    """
+    Generate a checksum for either R1 or R2 prescription
+    """
+    prsc_id = prescription_id.replace("-", "")
+    prsc_id_length = len(prsc_id)
+
+    running_total = 0
+    for string_position in range(prsc_id_length - 1):
+        char_mod36 = int(prsc_id[string_position], 36)
+        running_total += char_mod36 * (2 ** (prsc_id_length - string_position - 1))
+
+    check_value = (38 - running_total % 37) % 37
+    if check_value == 36:
+        check_value = "+"
+    elif check_value > 9:
+        check_value = ascii_uppercase[check_value - 10]
+    else:
+        check_value = str(check_value)
+
+    return check_value
+
+
+def check_checksum(prescription_id, internal_id, log_object):
+    """
+    Check the checksum of a Prescription ID
+    :prescription_id the prescription to check
+    :log_object invalid checksums will be logged
+    """
+    check_character = prescription_id[-1:]
+    check_value = calculate_checksum(prescription_id)
+
+    if check_value == check_character:
+        return True
+
+    log_object.write_log(
+        "MWS0042",
+        None,
+        {
+            "internalID": internal_id,
+            "prescriptionID": prescription_id,
+            "checkValue": check_value,
+        },
+    )
+
+    return False
+
+
+def remove_check_digit(prescription_id):
+    """
+    Takes the passed in id and determines, by its length, if it contains a checkdigit,
+    returns an id without the check digit
+    """
+    prescription_key = prescription_id
+    id_length = len(prescription_id)
+    if id_length in [LONGIDLENGTH_WITH_CHECKDIGIT, SHORTIDLENGTH_WITH_CHECKDIGIT]:
+        prescription_key = prescription_id[:-1]
+    return prescription_key

src/eps_spine_shared/common/dynamodb_datastore.py

@@ -25,7 +25,7 @@
 )
 from eps_spine_shared.common.dynamodb_index import EpsDynamoDbIndex, PrescriptionStatus
 from eps_spine_shared.logger import EpsLogger
-from eps_spine_shared.nhsfundamentals.timeutilities import (
+from eps_spine_shared.nhsfundamentals.time_utilities import (
     TimeFormats,
     convert_spine_date,
     time_now_as_string,

src/eps_spine_shared/common/dynamodb_index.py

@@ -17,7 +17,7 @@
 )
 from eps_spine_shared.common.prescription.record import PrescriptionStatus
 from eps_spine_shared.logger import EpsLogger
-from eps_spine_shared.nhsfundamentals.timeutilities import TimeFormats
+from eps_spine_shared.nhsfundamentals.time_utilities import TimeFormats
 
 
 class EpsDynamoDbIndex:

src/eps_spine_shared/common/indexes.py

@@ -1,6 +1,6 @@
 from eps_spine_shared.errors import EpsSystemError
 from eps_spine_shared.logger import EpsLogger
-from eps_spine_shared.nhsfundamentals.timeutilities import time_now_as_string
+from eps_spine_shared.nhsfundamentals.time_utilities import time_now_as_string
 
 INDEX_NHSNUMBER_DATE = "nhsNumberDate_bin"
 INDEX_NHSNUMBER_PRDATE = "nhsNumberPrescriberDate_bin"

src/eps_spine_shared/common/prescription/issue.py

@@ -4,7 +4,7 @@
 from eps_spine_shared.common.prescription.claim import PrescriptionClaim
 from eps_spine_shared.common.prescription.line_item import PrescriptionLineItem
 from eps_spine_shared.common.prescription.statuses import PrescriptionStatus
-from eps_spine_shared.nhsfundamentals.timeutilities import TimeFormats
+from eps_spine_shared.nhsfundamentals.time_utilities import TimeFormats
 
 
 class PrescriptionIssue(object):
@@ -73,7 +73,6 @@ def expire(self, expired_at_time, parent_prescription):
         :type expired_at_time: datetime.datetime
         :type parent_prescription: PrescriptionRecord
         """
-
         currentStatus = self.status
 
         # update the issue status, if appropriate

src/eps_spine_shared/common/prescription/next_activity_generator.py

@@ -3,7 +3,7 @@
 from eps_spine_shared.common.prescription import fields
 from eps_spine_shared.common.prescription.statuses import PrescriptionStatus
 from eps_spine_shared.logger import EpsLogger
-from eps_spine_shared.nhsfundamentals.timeutilities import TimeFormats
+from eps_spine_shared.nhsfundamentals.time_utilities import TimeFormats
 
 
 class NextActivityGenerator(object):