Merge branch 'master' into PLT-136

common/src/main/resources/db/changelog/db.changelog-master.yaml

@@ -156,4 +156,14 @@ databaseChangeLog:
   - include:
       file: db/changelog/v2023/add_columns_to_coverage.sql
   - include:
-      file: db/changelog/v2023/add_optout_property.sql
+      file: db/changelog/v2023/add_optout_property.sql
+  - include:
+      file: db/changelog/v2023/extend_coverage_partition.sql
+  - include:
+      file: db/changelog/v2023/create_current_mbi_table.sql
+  - include:
+      file: db/changelog/v2023/create_current_mbi_procedure.sql
+#  - include:
+#      file: db/changelog/v2023/create_pg_cron_extension.sql
+#  - include:
+#      file: db/changelog/v2024/create_current_mbi_procedure.sql

common/src/main/resources/db/changelog/test_only/coverage-fake-partitions.sql

@@ -19,4 +19,10 @@ create table if not exists tst_2022 partition of tst
     for values in (2022);
 
 create table if not exists tst_2023 partition of tst
-    for values in (2023);
+    for values in (2023);
+
+create table if not exists tst_2024 partition of tst
+    for values in (2024);
+
+create table if not exists tst_2025 partition of tst
+    for values in (2025);

common/src/main/resources/db/changelog/v2023/create_current_mbi_procedure.sql

@@ -0,0 +1,35 @@
+CREATE OR REPLACE PROCEDURE update_current_mbi_2023()
+LANGUAGE plpgsql
+AS $$
+begin
+INSERT INTO current_mbi
+SELECT DISTINCT current_mbi from coverage_anthem_united_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_bcbs_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_centene_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_cigna1_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_cigna2_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_cvs_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_centene_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_humana_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_misc_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_mutual_dean_clear_cambia_rite_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_united1_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_united_2023
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_default
+UNION DISTINCT
+SELECT DISTINCT current_mbi from sandbox_2023
+ON CONFLICT DO NOTHING;
+end;
+$$;

common/src/main/resources/db/changelog/v2023/create_current_mbi_table.sql

@@ -0,0 +1,32 @@
+CREATE TABLE IF NOT EXISTS public.current_mbi (mbi VARCHAR(32) NOT NULL);
+CREATE UNIQUE INDEX unique_mbi ON public.current_mbi(mbi);
+
+INSERT INTO public.current_mbi
+SELECT DISTINCT current_mbi from coverage_anthem_united
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_bcbs
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_centene
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_cigna1
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_cigna2
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_cvs
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_centene
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_humana
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_misc
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_mutual_dean_clear_cambia_rite
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_united1
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_united2
+UNION DISTINCT
+SELECT DISTINCT current_mbi from coverage_default
+UNION DISTINCT
+SELECT DISTINCT current_mbi from sandbox
+ON CONFLICT DO NOTHING

common/src/main/resources/db/changelog/v2023/create_pg_cron_extension.sql

@@ -0,0 +1,4 @@
+create extension if not exists pg_cron;
+
+-- run job every night at 1:00 am
+SELECT cron.schedule ('update_current_mbis','*/2 * * *','call update_current_mbi()');

common/src/main/resources/db/changelog/v2023/extend_coverage_partition.sql

@@ -0,0 +1,59 @@
+create table sandbox_2024 partition of sandbox
+    for values in (2024);
+create table sandbox_2025 partition of sandbox
+    for values in (2025);
+
+create table coverage_anthem_united_2024 partition of coverage_anthem_united
+    for values in (2024);
+create table coverage_anthem_united_2025 partition of coverage_anthem_united
+    for values in (2025);
+
+create table coverage_bcbs_2024 partition of coverage_bcbs
+    for values in (2024);
+create table coverage_bcbs_2025 partition of coverage_bcbs
+    for values in (2025);
+
+create table coverage_centene_2024 partition of coverage_centene
+    for values in (2024);
+create table coverage_centene_2025 partition of coverage_centene
+    for values in (2025);
+
+create table coverage_cigna1_2024 partition of coverage_cigna1
+    for values in (2024);
+create table coverage_cigna1_2025 partition of coverage_cigna1
+    for values in (2025);
+
+create table coverage_cigna2_2024 partition of coverage_cigna2
+    for values in (2024);
+create table coverage_cigna2_2025 partition of coverage_cigna2
+    for values in (2025);
+
+create table coverage_cvs_2024 partition of coverage_cvs
+    for values in (2024);
+create table coverage_cvs_2025 partition of coverage_cvs
+    for values in (2025);
+
+create table coverage_humana_2024 partition of coverage_humana
+    for values in (2024);
+create table coverage_humana_2025 partition of coverage_humana
+    for values in (2025);
+
+create table coverage_united1_2024 partition of coverage_united1
+    for values in (2024);
+create table coverage_united1_2025 partition of coverage_united1
+    for values in (2025);
+
+create table coverage_united_2024 partition of coverage_united2
+    for values in (2024);
+create table coverage_united_2025 partition of coverage_united2
+    for values in (2025);
+
+create table coverage_mutual_dean_clear_cambia_rite_2024 partition of coverage_mutual_dean_clear_cambia_rite
+    for values in (2024);
+create table coverage_mutual_dean_clear_cambia_rite_2025 partition of coverage_mutual_dean_clear_cambia_rite
+    for values in (2025);
+
+create table coverage_misc_2024 partition of coverage_misc
+    for values in (2024);
+create table coverage_misc_2025 partition of coverage_misc
+    for values in (2025);

common/src/main/resources/db/changelog/v2024/create_current_mbi_procedure.sql

@@ -0,0 +1,35 @@
+CREATE OR REPLACE PROCEDURE update_current_mbi_2024()
+    LANGUAGE plpgsql
+AS $$
+begin
+    INSERT INTO current_mbi
+    SELECT DISTINCT current_mbi from coverage_anthem_united_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_bcbs_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_centene_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_cigna1_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_cigna2_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_cvs_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_centene_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_humana_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_misc_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_mutual_dean_clear_cambia_rite_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_united1_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_united_2024
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from coverage_default
+    UNION DISTINCT
+    SELECT DISTINCT current_mbi from sandbox_2024
+    ON CONFLICT DO NOTHING;
+end;
+$$;

worker/src/test/java/gov/cms/ab2d/worker/processor/coverage/check/CoverageCheckPredicatesIntegrationTest.java

@@ -239,7 +239,7 @@ void whenCoverageUnstable_failCoverageStabilityCheck() {
 
         assertFalse(stableCheck.test(contract));
 
-        int expectedIssues =  2;
+        int expectedIssues =  1;
 
         assertEquals(expectedIssues, issues.size());
         issues.forEach(issue -> assertTrue(issue.contains("enrollment changed")));

worker/src/test/java/gov/cms/ab2d/worker/processor/coverage/check/CoverageCheckPredicatesUnitTest.java

@@ -198,7 +198,7 @@ void whenCoverageUnstable_failCoverageStabilityCheck() {
 
         assertFalse(stableCheck.test(contract));
 
-        int expectedIssues = 2;
+        int expectedIssues = 1;
 
         assertEquals(expectedIssues, issues.size());
         issues.forEach(issue -> assertTrue(issue.contains("enrollment changed")));