Merge pull request #48 from NHSDigital/AMB-1743-complete-delete-endpoint

Amb 1743 complete delete endpoint

Author: artronics

dynamodb/.gitignore devtools/.gitignoredynamodb/.gitignore renamed to devtools/.gitignore

@@ -0,0 +1,16 @@
+test:
+	python -m unittest
+
+test-debug:
+	./.venv/bin/pytest -s -v --color=yes -m debug
+
+init:
+	terraform init
+apply:
+	terraform apply -auto-approve
+
+
+localstack:
+	docker run --rm -it -p 4566:4566 -p 4510-4559:4510-4559 localstack/localstack:latest
+
+.PHONY: test test-debug localstack apply init

dynamodb/.terraform.lock.hcl devtools/.terraform.lock.hcldynamodb/.terraform.lock.hcl renamed to devtools/.terraform.lock.hcl

@@ -11,7 +11,7 @@ terraform {
 }
 
 provider "aws" {
-    region                 = "localhost"
+    region = "us-east-1"
     skip_region_validation = true
 
     endpoints {
@@ -21,7 +21,7 @@ provider "aws" {
 }
 
 locals {
-    short_prefix = "jaho3"
+    short_prefix = "local"
 }
 
 resource "aws_dynamodb_table" "test-dynamodb-table" {
@@ -33,21 +33,6 @@ resource "aws_dynamodb_table" "test-dynamodb-table" {
         name = "PK"
         type = "S"
     }
-    attribute {
-        name = "PatientPK"
-        type = "S"
-    }
-    attribute {
-        name = "PatientSK"
-        type = "S"
-    }
 
-    global_secondary_index {
-        name               = "PatientGSI"
-        hash_key           = "PatientPK"
-        range_key          = "PatientSK"
-        projection_type    = "INCLUDE"
-        non_key_attributes = ["Event"]
-    }
 }
 

devtools/Makefile

@@ -0,0 +1,71 @@
+import copy
+import json
+import os
+import random
+import uuid
+from datetime import datetime
+
+# generate reproducible random UUIDs
+rd = random.Random()
+rd.seed(0)
+
+
+def make_rand_id():
+    return uuid.UUID(int=rd.getrandbits(128))
+
+
+patient_pool = [
+    {"nhs_number": "9999999999", "dob": "1952-05-06"},
+    {"nhs_number": "1111111111", "dob": "1987-02-23"},
+    {"nhs_number": "1212233445", "dob": "1990-11-15"},
+]
+suppliers = [
+    "https://supplierABC/ODSCode145", "https://supplierSDF/ODSCode123", "https://supplierXYZ/ODSCode735"
+]
+disease_type = ["covid", "flu", "mmr", "hpv", "polio"]
+vaccine_code = ["covidVaccine", "fluVaccine", "mmrVaccine", "hpvVaccine", "polioVaccine"]
+vaccine_procedure = ["vac_procedure-oral", "vac_procedure-injection", "vac_procedure-123"]
+local_patient_pool = [
+    {"code": "ACME-Patient12345", "system": "https://supplierABC/identifiers/patient"},
+    {"code": "ACME-Patient23455", "system": "https://supplierCSB/identifiers/patient"},
+    {"code": "ACME-Patient35623", "system": "https://supplierXYZ/identifiers/patient"},
+]
+action_flag = ["flagA", "flagB"]
+
+
+def pick_rand(pool):
+    idx = random.randint(0, len(pool) - 1)
+    return pool[idx]
+
+
+def generate_immunisation(num):
+    with open("sample_imms.json", "r") as template:
+        imms = json.loads(template.read())
+
+    all_imms = []
+    for _ in range(num):
+        _imms = copy.deepcopy(imms)
+        # ID
+        _imms["id"] = str(make_rand_id())
+        _imms["identifier"][0]["system"] = pick_rand(suppliers)
+        _imms["identifier"][0]["value"] = str(make_rand_id())
+
+        all_imms.append(_imms)
+
+    return all_imms
+
+
+def write(_data, resource_type):
+    path = "sample_data"
+    if not os.path.exists(path):
+        os.makedirs(path)
+
+    name = f"{datetime.today().strftime('%Y-%m-%dT%H:%M:%S')}_{resource_type}-{len(_data)}.json"
+    with open(f"{path}/{name}", "w") as sample_file:
+        json_events = json.dumps(_data, indent=2)
+        sample_file.write(json_events)
+
+
+if __name__ == '__main__':
+    imms = generate_immunisation(30)
+    write(imms, resource_type="immunisation")