From e0408d1aaa9d90d71995ca961321f2344a887004 Mon Sep 17 00:00:00 2001
From: "scott.fullerton1" <scott.fullerton1@nhs.net>
Date: Fri, 20 Feb 2026 19:29:08 +0000
Subject: [PATCH] CCM-12034: Added new sms nudge views

---
 ...icy_document_sso_read_only_table_access.tf |  3 +++
 .../iam_instance_profile_powerbi_gateway.tf   |  3 +++
 .../terraform/components/reporting/locals.tf  |  2 ++
 ..._request_item_plan_status_smsnudge_view.tf | 20 +++++++++++++++++++
 ...quest_item_status_smsnudge_staging_view.tf | 19 ++++++++++++++++++
 ...ource_request_item_status_smsnudge_view.tf | 19 ++++++++++++++++++
 .../request_item_plan_status_smsnudge.sql     | 15 ++++++++++++++
 .../views/request_item_status_smsnudge.sql    |  7 +++++++
 .../request_item_status_smsnudge_staging.sql  | 10 ++++++++++
 .../components/reporting/variables.tf         |  6 ++++++
 10 files changed, 104 insertions(+)
 create mode 100644 infrastructure/terraform/components/reporting/null_resource_request_item_plan_status_smsnudge_view.tf
 create mode 100644 infrastructure/terraform/components/reporting/null_resource_request_item_status_smsnudge_staging_view.tf
 create mode 100644 infrastructure/terraform/components/reporting/null_resource_request_item_status_smsnudge_view.tf
 create mode 100644 infrastructure/terraform/components/reporting/scripts/sql/views/request_item_plan_status_smsnudge.sql
 create mode 100644 infrastructure/terraform/components/reporting/scripts/sql/views/request_item_status_smsnudge.sql
 create mode 100644 infrastructure/terraform/components/reporting/scripts/sql/views/request_item_status_smsnudge_staging.sql

diff --git a/infrastructure/terraform/components/reporting/data_iam_policy_document_sso_read_only_table_access.tf b/infrastructure/terraform/components/reporting/data_iam_policy_document_sso_read_only_table_access.tf
index 6aa21525..250edf3e 100644
--- a/infrastructure/terraform/components/reporting/data_iam_policy_document_sso_read_only_table_access.tf
+++ b/infrastructure/terraform/components/reporting/data_iam_policy_document_sso_read_only_table_access.tf
@@ -32,6 +32,9 @@ data "aws_iam_policy_document" "sso_read_only_table_access" {
         "arn:aws:glue:${var.region}:${var.aws_account_id}:table/${var.project}-*-reporting-database/request_item_plan_completed_summary_all",
         "arn:aws:glue:${var.region}:${var.aws_account_id}:table/${var.project}-*-reporting-database/request_item_status_summary_all",
         "arn:aws:glue:${var.region}:${var.aws_account_id}:table/${var.project}-*-reporting-database/request_item_status_summary_all_email_filter",
+        "arn:aws:glue:${var.region}:${var.aws_account_id}:table/${var.project}-*-reporting-database/request_item_status_smsnudge_staging",
+        "arn:aws:glue:${var.region}:${var.aws_account_id}:table/${var.project}-*-reporting-database/request_item_plan_status_smsnudge",
+        "arn:aws:glue:${var.region}:${var.aws_account_id}:table/${var.project}-*-reporting-database/request_item_status_smsnudge",
         "arn:aws:glue:${var.region}:${var.aws_account_id}:table/${var.project}-*-reporting-database/dates",
         "arn:aws:glue:${var.region}:${var.aws_account_id}:table/${var.project}-*-reporting-database/letters_invoice_units_monthly",
         "arn:aws:glue:${var.region}:${var.aws_account_id}:table/${var.project}-*-reporting-database/letters_invoice_units_weekly",
diff --git a/infrastructure/terraform/components/reporting/iam_instance_profile_powerbi_gateway.tf b/infrastructure/terraform/components/reporting/iam_instance_profile_powerbi_gateway.tf
index b777ea45..b642ab8e 100644
--- a/infrastructure/terraform/components/reporting/iam_instance_profile_powerbi_gateway.tf
+++ b/infrastructure/terraform/components/reporting/iam_instance_profile_powerbi_gateway.tf
@@ -184,6 +184,9 @@ data "aws_iam_policy_document" "powerbi_gateway_permissions_policy" {
         "arn:aws:glue:${var.region}:${local.this_account}:table/${aws_glue_catalog_database.reporting.name}/request_item_plan_completed_summary_all",
         "arn:aws:glue:${var.region}:${local.this_account}:table/${aws_glue_catalog_database.reporting.name}/request_item_status_summary_all",
         "arn:aws:glue:${var.region}:${local.this_account}:table/${aws_glue_catalog_database.reporting.name}/request_item_status_summary_all_email_filter",
+        "arn:aws:glue:${var.region}:${local.this_account}:table/${aws_glue_catalog_database.reporting.name}/request_item_status_smsnudge_staging",
+        "arn:aws:glue:${var.region}:${local.this_account}:table/${aws_glue_catalog_database.reporting.name}/request_item_plan_status_smsnudge",
+        "arn:aws:glue:${var.region}:${local.this_account}:table/${aws_glue_catalog_database.reporting.name}/request_item_status_smsnudge",
         "arn:aws:glue:${var.region}:${local.this_account}:table/${aws_glue_catalog_database.reporting.name}/dates",
         "arn:aws:glue:${var.region}:${local.this_account}:table/${aws_glue_catalog_database.reporting.name}/letters_invoice_units_monthly",
         "arn:aws:glue:${var.region}:${local.this_account}:table/${aws_glue_catalog_database.reporting.name}/letters_invoice_units_weekly",
diff --git a/infrastructure/terraform/components/reporting/locals.tf b/infrastructure/terraform/components/reporting/locals.tf
index c111b733..3d4c48ab 100644
--- a/infrastructure/terraform/components/reporting/locals.tf
+++ b/infrastructure/terraform/components/reporting/locals.tf
@@ -84,5 +84,7 @@ locals {
     ]
   ]) : []
 
+  sms_nudge_client_id = format("'%s'", var.sms_nudge_client_id)
+
   log_destination_arn = "arn:aws:logs:${var.region}:${var.shared_infra_account_id}:destination:nhs-main-obs-firehose-logs"
 }
diff --git a/infrastructure/terraform/components/reporting/null_resource_request_item_plan_status_smsnudge_view.tf b/infrastructure/terraform/components/reporting/null_resource_request_item_plan_status_smsnudge_view.tf
new file mode 100644
index 00000000..c384cf47
--- /dev/null
+++ b/infrastructure/terraform/components/reporting/null_resource_request_item_plan_status_smsnudge_view.tf
@@ -0,0 +1,20 @@
+resource "null_resource" "request_item_plan_status_smsnudge_view" {
+  triggers = {
+    sql = filesha256("${path.module}/scripts/sql/views/request_item_plan_status_smsnudge.sql")
+  }
+
+  provisioner "local-exec" {
+    command = <<EOT
+      ${path.module}/scripts/create_replace_view.sh \
+        ${aws_athena_workgroup.setup.name} \
+        ${aws_glue_catalog_database.reporting.name} \
+        request_item_plan_status_smsnudge \
+        sms_nudge_client_id "${local.sms_nudge_client_id}"
+    EOT
+  }
+
+  depends_on = [
+    null_resource.request_item_plan_status_table,
+    null_resource.request_item_status_smsnudge_staging_view
+  ]
+}
diff --git a/infrastructure/terraform/components/reporting/null_resource_request_item_status_smsnudge_staging_view.tf b/infrastructure/terraform/components/reporting/null_resource_request_item_status_smsnudge_staging_view.tf
new file mode 100644
index 00000000..4d2cb669
--- /dev/null
+++ b/infrastructure/terraform/components/reporting/null_resource_request_item_status_smsnudge_staging_view.tf
@@ -0,0 +1,19 @@
+resource "null_resource" "request_item_status_smsnudge_staging_view" {
+  triggers = {
+    sql = filesha256("${path.module}/scripts/sql/views/request_item_status_smsnudge_staging.sql")
+  }
+
+  provisioner "local-exec" {
+    command = <<EOT
+      ${path.module}/scripts/create_replace_view.sh \
+        ${aws_athena_workgroup.setup.name} \
+        ${aws_glue_catalog_database.reporting.name} \
+        request_item_status_smsnudge_staging \
+        sms_nudge_client_id "${local.sms_nudge_client_id}"
+    EOT
+  }
+
+  depends_on = [
+    null_resource.request_item_status_table
+  ]
+}
diff --git a/infrastructure/terraform/components/reporting/null_resource_request_item_status_smsnudge_view.tf b/infrastructure/terraform/components/reporting/null_resource_request_item_status_smsnudge_view.tf
new file mode 100644
index 00000000..cd3b2097
--- /dev/null
+++ b/infrastructure/terraform/components/reporting/null_resource_request_item_status_smsnudge_view.tf
@@ -0,0 +1,19 @@
+resource "null_resource" "request_item_status_smsnudge_view" {
+  triggers = {
+    sql = filesha256("${path.module}/scripts/sql/views/request_item_status_smsnudge.sql")
+  }
+
+  provisioner "local-exec" {
+    command = <<EOT
+      ${path.module}/scripts/create_replace_view.sh \
+        ${aws_athena_workgroup.setup.name} \
+        ${aws_glue_catalog_database.reporting.name} \
+        request_item_status_smsnudge
+    EOT
+  }
+
+  depends_on = [
+    null_resource.request_item_status_smsnudge_staging_view,
+    null_resource.request_item_plan_status_smsnudge_view
+  ]
+}
diff --git a/infrastructure/terraform/components/reporting/scripts/sql/views/request_item_plan_status_smsnudge.sql b/infrastructure/terraform/components/reporting/scripts/sql/views/request_item_plan_status_smsnudge.sql
new file mode 100644
index 00000000..6a0df0ce
--- /dev/null
+++ b/infrastructure/terraform/components/reporting/scripts/sql/views/request_item_plan_status_smsnudge.sql
@@ -0,0 +1,15 @@
+CREATE OR REPLACE VIEW ${view_name} AS
+SELECT
+  rip.*,
+  ris.originatingclientid,
+  ris.originatingcampaignid,
+  ris.originatingbillingrefid,
+  ris.originatingrequestitemid,
+  ris.originatingrequestitemplanid,
+  original_ri.sendinggroupid AS originalsendinggroupid
+FROM request_item_plan_status rip
+LEFT JOIN request_item_status_smsnudge_staging ris
+  ON rip.requestitemid = ris.requestitemid
+LEFT JOIN request_item_status original_ri
+  ON original_ri.requestitemid = ris.originatingrequestitemid
+WHERE rip.clientid = ${sms_nudge_client_id}
diff --git a/infrastructure/terraform/components/reporting/scripts/sql/views/request_item_status_smsnudge.sql b/infrastructure/terraform/components/reporting/scripts/sql/views/request_item_status_smsnudge.sql
new file mode 100644
index 00000000..e44a02d8
--- /dev/null
+++ b/infrastructure/terraform/components/reporting/scripts/sql/views/request_item_status_smsnudge.sql
@@ -0,0 +1,7 @@
+CREATE OR REPLACE VIEW ${view_name} AS
+SELECT
+  ris.*,
+  rips.originalsendinggroupid
+FROM request_item_status_smsnudge_staging ris
+LEFT JOIN request_item_plan_status_smsnudge rips
+  ON ris.requestitemid = rips.requestitemid
diff --git a/infrastructure/terraform/components/reporting/scripts/sql/views/request_item_status_smsnudge_staging.sql b/infrastructure/terraform/components/reporting/scripts/sql/views/request_item_status_smsnudge_staging.sql
new file mode 100644
index 00000000..52048ba5
--- /dev/null
+++ b/infrastructure/terraform/components/reporting/scripts/sql/views/request_item_status_smsnudge_staging.sql
@@ -0,0 +1,10 @@
+CREATE OR REPLACE VIEW ${view_name} AS
+SELECT
+  ris.*,
+  NULLIF(split_part(ris.billingref, '|', 1), '') AS originatingclientid,
+  NULLIF(split_part(ris.billingref, '|', 2), '') AS originatingcampaignid,
+  NULLIF(split_part(ris.billingref, '|', 3), '') AS originatingbillingrefid,
+  NULLIF(split_part(ris.requestitemrefid, '_', 1), '') AS originatingrequestitemid,
+  NULLIF(split_part(ris.requestitemrefid, '_', 2), '') AS originatingrequestitemplanid
+FROM request_item_status ris
+WHERE ris.clientid = ${sms_nudge_client_id}
diff --git a/infrastructure/terraform/components/reporting/variables.tf b/infrastructure/terraform/components/reporting/variables.tf
index fccc5200..3a1c983a 100644
--- a/infrastructure/terraform/components/reporting/variables.tf
+++ b/infrastructure/terraform/components/reporting/variables.tf
@@ -193,6 +193,12 @@ variable "email_filter_client_ids" {
   default     = ["NULL"]
 }
 
+variable "sms_nudge_client_id" {
+  description = "Client id for the SMS Nudge umbrella client used to filter smsnudge views"
+  type        = string
+  default     = "NULL"
+}
+
 variable "enable_s3_backup" {
   type        = bool
   description = "Enable AWS S3 Backup of the data bucket"