From fd54de34a8783f7a2af5e4297bf1324a1e0e67a0 Mon Sep 17 00:00:00 2001
From: Max Alexander <malexander2@mbta.com>
Date: Tue, 26 May 2026 17:08:49 -0400
Subject: [PATCH] Chore: Adding tables 26-05-26

---
 .../20260526120000_adding-tables-20260526.exs | 71 +++++++++++++++++++
 1 file changed, 71 insertions(+)
 create mode 100644 ex_cubic_ingestion/priv/repo/migrations/20260526120000_adding-tables-20260526.exs

diff --git a/ex_cubic_ingestion/priv/repo/migrations/20260526120000_adding-tables-20260526.exs b/ex_cubic_ingestion/priv/repo/migrations/20260526120000_adding-tables-20260526.exs
new file mode 100644
index 0000000..c451db2
--- /dev/null
+++ b/ex_cubic_ingestion/priv/repo/migrations/20260526120000_adding-tables-20260526.exs
@@ -0,0 +1,71 @@
+defmodule ExCubicIngestion.Repo.Migrations.AddingTables20260526 do
+  use Ecto.Migration
+
+  alias ExCubicIngestion.Repo
+  alias ExCubicIngestion.Schema.CubicTable
+  alias ExCubicIngestion.Schema.CubicOdsTableSnapshot
+
+  @ods_tables [
+    %{
+      name: "cubic_ods_qlik__edw_card_action",
+      s3_prefix: "cubic/ods_qlik/EDW.CARD_ACTION/"
+    },
+    %{
+      name: "cubic_ods_qlik__edw_card_action_reason_dimension",
+      s3_prefix: "cubic/ods_qlik/EDW.CARD_ACTION_REASON_DIMENSION/"
+    },
+    %{
+      name: "cubic_ods_qlik__edw_card_action_type_dimension",
+      s3_prefix: "cubic/ods_qlik/EDW.CARD_ACTION_TYPE_DIMENSION/"
+    },
+    %{
+      name: "cubic_ods_qlik__edw_fraud_alert_type_dimension",
+      s3_prefix: "cubic/ods_qlik/EDW.FRAUD_ALERT_TYPE_DIMENSION/"
+    },
+    %{
+      name: "cubic_ods_qlik__edw_fraud_summary_by_account",
+      s3_prefix: "cubic/ods_qlik/EDW.FRAUD_SUMMARY_BY_ACCOUNT/"
+    },
+    %{
+      name: "cubic_ods_qlik__edw_fraud_summary_by_day",
+      s3_prefix: "cubic/ods_qlik/EDW.FRAUD_SUMMARY_BY_DAY/"
+    },
+    %{
+      name: "cubic_ods_qlik__edw_ifdm_fraud_alert",
+      s3_prefix: "cubic/ods_qlik/EDW.IFDM_FRAUD_ALERT/"
+    },
+    %{
+      name: "cubic_ods_qlik__edw_ifdm_fraud_alert_action",
+      s3_prefix: "cubic/ods_qlik/EDW.IFDM_FRAUD_ALERT_ACTION/"
+    },
+  ]
+
+  def up do
+    Repo.transaction(fn ->
+      Enum.each(@ods_tables, fn ods_table ->
+        ods_table_rec =
+          Repo.insert!(%CubicTable{
+            name: ods_table[:name],
+            s3_prefix: ods_table[:s3_prefix],
+            is_active: true,
+            is_raw: true
+          })
+
+        Repo.insert!(%CubicOdsTableSnapshot{
+          table_id: ods_table_rec.id,
+          snapshot_s3_key: "#{ods_table[:s3_prefix]}LOAD00000001.csv.gz"
+        })
+      end)
+    end)
+  end
+
+  def down do
+    Repo.transaction(fn ->
+      Enum.each(@ods_tables, fn ods_table ->
+        ods_table_rec = CubicTable.get_by!(name: ods_table[:name])
+        Repo.delete!(CubicOdsTableSnapshot.get_by!(table_id: ods_table_rec.id))
+        Repo.delete!(ods_table_rec)
+      end)
+    end)
+  end
+end