adding in webhook

Author: mrlockstar

infrastructure/modules/container-apps/jobs.tf

@@ -74,6 +74,7 @@ module "scheduled_jobs" {
   )
   secret_variables = merge(
     # { APPLICATIONINSIGHTS_CONNECTION_STRING = var.app_insights_connection_string },
+    { SLACK_WEBHOOK_URL = var.slack_webhook_url },
     var.deploy_database_as_container ? { DATABASE_PASSWORD = resource.random_password.admin_password[0].result } : {}
   )
 

infrastructure/modules/container-apps/variables.tf

@@ -196,6 +196,11 @@ variable "infra_key_vault_rg" {
   type        = string
 }
 
+variable "slack_webhook_url" {
+  description = "slack_webhook_url is the URL used to send alerts to Slack. It should be stored as a secret in the infra key vault with the name 'slack-webhook-url'."
+  type        = string
+}
+
 locals {
   resource_group_name = "rg-${var.app_short_name}-${var.environment}-container-app-uks"
 

infrastructure/modules/infra/data.tf

@@ -21,8 +21,3 @@ data "azurerm_key_vault_secret" "infra" {
   name         = "monitoring-email-address"
   key_vault_id = data.azurerm_key_vault.infra.id
 }
-
-data "azurerm_key_vault_secret" "slack_webhook_url" {
-  name         = "slack-webhook-url"
-  key_vault_id = data.azurerm_key_vault.infra.id
-}

infrastructure/modules/infra/logic_app.tf

@@ -6,7 +6,7 @@ module "logic_app_slack_alert" {
   name                = "logic-${var.app_short_name}-${var.environment}-slack-alerts"
   resource_group_name = azurerm_resource_group.main.name
   location            = var.region
-  slack_webhook_url   = data.azurerm_key_vault_secret.slack_webhook_url.value
+  slack_webhook_url   = var.slack_webhook_url
 }
 
 resource "azurerm_monitor_action_group" "slack" {

infrastructure/modules/infra/variables.tf

@@ -73,6 +73,11 @@ variable "enable_alerting" {
   type        = bool
 }
 
+variable "slack_webhook_url" {
+  description = "slack_webhook_url is the URL used to send alerts to Slack. It should be stored as a secret in the infra key vault with the name 'slack-webhook-url'."
+  type        = string
+}
+
 locals {
   hub_vnet_rg_name = "rg-hub-${var.hub}-uks-bootstrap"
   hub_vnet_name    = "vnet-hub-${var.hub}-uks"

infrastructure/terraform/spoke/data.tf

@@ -49,3 +49,17 @@ data "azurerm_application_insights" "app_insights" {
   name                = "appi-${var.env_config}-uks-${var.app_short_name}"
   resource_group_name = local.resource_group_name
 }
+
+data "azurerm_key_vault" "infra" {
+  provider = azurerm.hub
+
+  name                = local.infra_key_vault_name
+  resource_group_name = local.infra_key_vault_rg
+}
+
+data "azurerm_key_vault_secret" "slack_webhook_url" {
+  name         = "slack-webhook-url"
+  key_vault_id = data.azurerm_key_vault.infra.id
+}
+
+# git-sha-a85180497c23d742b5f92262b3b43069e44a4110

infrastructure/terraform/spoke/main.tf

@@ -22,6 +22,7 @@ module "infra" {
   vnet_address_space               = var.vnet_address_space
   cae_zone_redundancy_enabled      = var.cae_zone_redundancy_enabled
   enable_alerting                  = var.enable_alerting
+  slack_webhook_url                = data.azurerm_key_vault_secret.slack_webhook_url.value
 }
 
 module "container-apps" {
@@ -69,4 +70,5 @@ module "container-apps" {
   use_apex_domain                       = var.use_apex_domain
   container_memory                      = var.container_memory
   min_replicas                          = var.min_replicas
+  slack_webhook_url                     = data.azurerm_key_vault_secret.slack_webhook_url.value
 }

lung_cancer_screening/questions/management/commands/request_summary.py

@@ -1,5 +1,8 @@
+import json
 import logging
+import os
 
+import requests
 from django.core.management.base import BaseCommand, CommandError
 from lung_cancer_screening.questions.services.request_summary import RequestSummary
 
@@ -9,13 +12,33 @@ class Command(BaseCommand):
     help = "Counts the number of submitted requests."
 
     def handle(self, *args, **options):
-        logger.info("Command: SubmittedCount.")
+
+        logger.info("Command: Request Summary.")
         try:
             rs = RequestSummary()
             summary = rs.get_summary()
 
             self.stdout.write(str(summary))
 
+            slack_webhook_url = os.environ.get("SLACK_WEBHOOK_URL")
+
+            if not slack_webhook_url:
+                logger.warning("SLACK_WEBHOOK_URL is not set; skipping Slack notification.")
+                return
+
+            payload = {
+                "text": f"*Request summary*\n```{json.dumps(summary, indent=2, default=str)}```"
+            }
+
+            response = requests.post(
+                slack_webhook_url,
+                json=payload,
+                timeout=10,
+            )
+            response.raise_for_status()
+
+            logger.info("Request summary sent to Slack.")
+
         except Exception as e:
             logger.error(e, exc_info=True)
             raise CommandError(e)