From 4f305e05f05fcb76e5b349ac48467724d018a040 Mon Sep 17 00:00:00 2001
From: Kegan Maher <kegan@compiler.la>
Date: Thu, 10 Oct 2024 17:41:07 +0000
Subject: [PATCH] feat(benefits): add new enrollment_method cols

default to 'digital' for historical events
---
 .../models/mart/benefits/_mart_benefits.yml      |  4 ++++
 .../models/mart/benefits/fct_benefits_events.sql | 16 ++++++++++++++++
 2 files changed, 20 insertions(+)

diff --git a/warehouse/models/mart/benefits/_mart_benefits.yml b/warehouse/models/mart/benefits/_mart_benefits.yml
index a0190772a3..bcbd727c58 100644
--- a/warehouse/models/mart/benefits/_mart_benefits.yml
+++ b/warehouse/models/mart/benefits/_mart_benefits.yml
@@ -55,6 +55,8 @@ models:
         description: UUID
       - name: processed_time
         description: UTC ISO-8601 timestamp
+      - name: event_properties_enrollment_method
+        description: The `enrollment_method` value from the `event_properties` column
       - name: event_properties_auth_provider
         description: The `claims_provider` value from the `event_properties` column
         deprecated:
@@ -103,6 +105,8 @@ models:
           date: "2024-09-19"
       - name: event_properties_enrollment_flows
         description: A semi-colon delimited list of `enrollment_flows` values from the `event_properties` column
+      - name: user_properties_enrollment_method
+        description: The `enrollment_method` value from the `user_properties` column
       - name: user_properties_eligibility_verifier
         description: The `eligibility_verifier` value from the `user_properties` column
       - name: user_properties_initial_referrer
diff --git a/warehouse/models/mart/benefits/fct_benefits_events.sql b/warehouse/models/mart/benefits/fct_benefits_events.sql
index 104d10a433..56a7e6f844 100644
--- a/warehouse/models/mart/benefits/fct_benefits_events.sql
+++ b/warehouse/models/mart/benefits/fct_benefits_events.sql
@@ -51,6 +51,13 @@ WITH fct_benefits_events AS (
         {{ json_extract_column('event_properties', 'status') }},
         {{ json_extract_column('event_properties', 'transit_agency') }},
 
+        -- New column `enrollment_method`, historical values should be set to "digital"
+        -- https://github.com/cal-itp/benefits/pull/2402
+        COALESCE(
+          {{ json_extract_column('event_properties', 'enrollment_method', no_alias = true) }},
+          "digital"
+        ) AS event_properties_enrollment_method,
+
         -- Historical data existed in `auth_provider` but new data is in `claims_provider`
         -- https://github.com/cal-itp/benefits/pull/2401
         COALESCE(
@@ -94,6 +101,13 @@ WITH fct_benefits_events AS (
         {{ json_extract_column('user_properties', 'referring_domain') }},
         {{ json_extract_column('user_properties', 'user_agent') }},
 
+        -- New column `enrollment_method`, historical values should be set to "digital"
+        -- https://github.com/cal-itp/benefits/pull/2402
+        COALESCE(
+          {{ json_extract_column('user_properties', 'enrollment_method', no_alias = true) }},
+          "digital"
+        ) AS user_properties_enrollment_method,
+
         -- Historical data existed in `eligibility_types` but new data is in `enrollment_flows`
         -- https://github.com/cal-itp/benefits/pull/2379
         COALESCE(
@@ -132,6 +146,7 @@ fct_old_enrollments AS (
     start_version,
     uuid,
     processed_time,
+    "digital" as event_properties_enrollment_method,
     CASE
       WHEN client_event_time < '2022-08-12T07:00:00Z'
         THEN "ca-dmv"
@@ -160,6 +175,7 @@ fct_old_enrollments AS (
     "Monterey-Salinas Transit" as event_properties_transit_agency,
     "senior" as event_properties_enrollment_flows,
     event_properties_enrollment_flows as event_properties_eligibility_types,
+    "digital" as user_properties_enrollment_method,
     CASE
       WHEN client_event_time < '2022-08-12T07:00:00Z'
         THEN "ca-dmv"