Feature/ab2d 1211 e2e opt out (#269)

adaykin · web-flow · commit 3605742d0c9b · 2020-04-01T11:57:06.000-05:00
Add an e2e test for opt out that will check to see if a user that has opted out remains in the data download. Add environment variables for connecting to AWS and update the BFD hash so that it will be able to work with the BFD sandbox we are connecting to.
diff --git a/.travis.yml b/.travis.yml
@@ -5,6 +5,8 @@ env:
   - DOCKER_COMPOSE_VERSION: 1.24.1
   - secure: n1NNXk+OkWTys5pLxwH+o1m0LT53HYBMxJz0negjampyLjPg0xPhdnGqdFITejHQ/fUYDdAFfkoJ/2sX2EZppya8B+X8YovqfxVms2F18e3/3zQhutmw3vxFgVuy/Lp5NkzQYDVoggzQOPNLfSJrCCSIo2FVdaKNjLnjCx3V1IFPq2HzFuUoFNliOpgiox6PICgg0HSysifRjhZygnSnlS0t7yTs5F3hipmPyQOhdyos/f7ut0x0ugW6cENDL8Bk+nR2znXzLqsdC6Y/+xjrpOubTdhQQyOHGTgdsHFTYSgfqBgTNiMzh8OorKfHs1gALnGjUtd4zzJg7lXqnHCkAM8RlFGg1aq7AMxLvuNYz+q84xNIfAxdpRjU2xukdMFke0+c2wR4x2eJHit691wMcezoaiJ5py7D3slmsdhEzyWLNOd86fWPpbebS7S18/p9kOwFpvS73YhGPKD/8M7ot/k78ota/2prBRih94RknXYnDj49HGLLzJu5UbXwf/juLdJK4t3ItapsmHef7hoZnrsPt9Nj0ZkWDI1ePVremFfQWbNGBPwIh/mQ4P+V44FAn3gkAjyPkklgC9slpfqZ254djsfejmMCc2QZTqVzJ1lMxrjxU0K1leVQNnvJFDafWgfVTIguhlgeLW7CC1IXB8bp3aJTp0GnbwikExVPOWs=
   - secure: XHSp3OzOdu54rD01RuYmOTsgwby7N4cc2GaUyUar3CfogvqBZBlD0rE1Ntu4msq6MhCxJxAaPy0ef7rIGz4ikVscyyvV2BJj5d+8Or1ILBNky9KCgHexe0+U5ZqGfeKwOu9NpfOChYZXhhpxemheXhGkkP4odaXt4VuYeCRv2oLgT0Vjr+D/rsQ3eP7dfqqc/7mKhLdZbrFUeEQe5anXfdswVyHBJeDb5Cm3YcqHK3cCk9kxoKazKUmadBSFS5vNSUuIl21t5T1Y7wTgLnZHvNMdZFHw0e2ziTYNCy4HGaoBk7CLdXWJob2mPwNNz2EBDnezRVjwlwWr534YN+AvlwIgtuKjOAGjhfGibKLUn4TOzmxEAI79gHtp03DHY7r2gtsFLhhor2chtownEx9EO0AB4X/ER2+JKVlm6d6PNQNFsI501ANfotKEnOlfINfVaUdRMCZiB2pds/qQUXHK5xXChVKNofb7JZjY856Ckt9hv8hcGLTGlnm55DiXFUKZ6xpLFiQdUZT89gDA1P0f8c1wpL8cI05mloF1Fkv2fsPG/FBjd0ug3iI/ZrUimOrg33Eg+Df1Q159Cf3ci00wHwfdVVwEMN69TRner+Gc0Zj2fIRRcOumezfE+3cWbLfLhtkOT515Y+PsEZewQMEhe8FGbQW8cZKiGLDwe/nMFgo=
+  - secure: AUnRb6K9675dTJKL8arl7NpNAAxQZniqgNHBL+8IysNu015t/hAHtIqe33ENclc9SebdaHHHZkNdeCNQ+4AehOUwaeooJjDQXJeF7xglp+jQ6wYEZlO+yVuvKciTT6nTQ0mx/O9pneI22xENYHN8z0tKhiuJl7jgJXg/oNspUw1QDlaGyHTbH0crA5qZPcsTsK6Xy/ytv4lK7oKBScU1EwimUlFOhMNeTRh3k+csCA5Jhw0blbpQyp3wM2PmG0Xn7zJ+R2p6m26xERAOxVFaUSmKKIxedu8uG1SXpI/+7MPypCI0peVai38qiRurUVU3dGd+9U7KnHEGCw1tmYmTafOmyO8tYgx1xuD6PsSYz9BLEnTPSvFb47QfskwNk8gDwoxY3t2rieaCsyYReP0VOdYMW5WlBEkUmfGQa37ghPSDdL0K5+sTQSSF7o21PpDFS8rPIYNn2WxrdsnI/xahzO58Y64mxYhV4TcwkKkbqyPeKEEsplMjLsOWIZF2a0qE8FQgosJsZQOq15Aii43ICoKa0iyW2esIzwZbzWEj0bAyyBo/g23dgPZTyi35LC9pJOsO/JxRBpsZEwhRlDLl+sgYCPvApkTRDRZwRZLP1uzLotr+M4DHmODMjO4hvK1E9qJ/fmvOuTBfaW4XLi/cgvuFw9DTsz77V+npZDZR/Q4=
+  - secure: SnaFCT0mJK1/ePgrhKzQuYgYHLY7ZAQvLA0aiUO3cEOvSeB//jU7t3091Zch0vJH/h/qSR/FU+rbbMSeu8JcIPVsNnh4OSMslQGtDwBwB89CbCwidhk0hOVm/j1ExJmrhtZZ8kerF3Ka/m1ax8n1ztJVvg4lhw7fvXcHy3ujQCsLUYvefNLhUIU8gq2awpULxEybXgoTtkL9AzutiZcTbwhbAbBELM/IIFkGe8bZ2Vlao0xIgFX17wGj65/mpX04ThsdAgHF5A6e+oTu51KGD5JN4l9B8nTVVp3soFEDn0ajW4pDQlBvReZcw/Uda82nrtqpN1+gQ8fBODB1bVDLCpNtZhzZIZJsxcY5BvGVTLTVzNrYJCmB5R/lxzpjJpc9cdqBipWyDxuNHgjafZvnU0e/0dnMh22IDe0AIshed53RuV2010K2vnUdhweV6iuDnncuVy8gUjohzF1YaHnW/CMZMZrOt/NSXSrt9FcK/fuzhiynq0rpJ/315hAjI9CjCEPtBLLzwoh++rTlbJGfAY26S9Q3++iMnXALUZC+lzQvmeEZvTKjbKNTBeVxFIOj2gL4Y9oWIUAs6ukqhcORlwVEQVza73a6uXwUm5Y8c03Yez/W5UchElJx02qdejRUlQxP9GmEdYpSBoSScNBLrz7/QFERsCsDKSG+icuVZ08=
 dist: bionic
 language: java
 jdk:
@@ -13,6 +15,8 @@ cache:
   directories:
   - "$HOME/.m2"
 before_install:
+- openssl aes-256-cbc -K $encrypted_cb979db88957_key -iv $encrypted_cb979db88957_iv
+  -in bfd_sbx_hash_pepper.enc -out bfd_sbx_hash_pepper -d
 - mkdir -p /opt/ab2d
 - openssl aes-256-cbc -K $encrypted_27e3c48779c8_key -iv $encrypted_27e3c48779c8_iv
   -in ab2d_dev_keystore.enc -out /opt/ab2d/ab2d_dev_keystore -d
@@ -32,6 +36,9 @@ before_install:
 - export OKTA_CLIENT_PASSWORD=HHduWG6LogIvDIQuWgp3Zlo9OYMValTtH5OBcuHw
 - export SECONDARY_USER_OKTA_CLIENT_ID=0oa2t0lc65ErV8OmY297
 - export SECONDARY_USER_OKTA_CLIENT_PASSWORD=1Bl3HGO6eglkXUDtjVjto3L-3C0offzTMk2qlz9r
+- export AB2D_OPT_OUT_JOB_SCHEDULE='*/15 * * * * ?'
+- export AB2D_HICN_HASH_PEPPER=`cat bfd_sbx_hash_pepper`
+- export AB2D_HICN_HASH_ITER=1000
 install: true
 before_script:
 - curl -L https://codeclimate.com/downloads/test-reporter/test-reporter-latest-linux-amd64
diff --git a/bfd_sbx_hash_pepper.enc b/bfd_sbx_hash_pepper.enc
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -52,6 +52,11 @@ services:
       - AB2D_BFD_KEYSTORE_LOCATION=${AB2D_BFD_KEYSTORE_LOCATION}
       - NEW_RELIC_LICENSE_KEY="${NEW_RELIC_LICENSE_KEY}"
       - NEW_RELIC_APP_NAME="${NEW_RELIC_APP_NAME}"
+      - AB2D_OPT_OUT_JOB_SCHEDULE=${AB2D_OPT_OUT_JOB_SCHEDULE}
+      - AWS_ACCESS_KEY_ID=${AWS_ACCESS_KEY_ID}
+      - AWS_SECRET_ACCESS_KEY=${AWS_SECRET_ACCESS_KEY}
+      - AB2D_HICN_HASH_PEPPER=${AB2D_HICN_HASH_PEPPER}
+      - AB2D_HICN_HASH_ITER=${AB2D_HICN_HASH_ITER}
     depends_on:
       - db
     volumes:
diff --git a/e2e-test/src/test/java/gov/cms/ab2d/e2etest/TestRunner.java b/e2e-test/src/test/java/gov/cms/ab2d/e2etest/TestRunner.java
@@ -11,8 +11,11 @@
 import org.json.JSONException;
 import org.json.JSONObject;
 import org.junit.Assert;
+import org.junit.jupiter.api.MethodOrderer;
+import org.junit.jupiter.api.Order;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;
+import org.junit.jupiter.api.TestMethodOrder;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.springframework.data.util.Pair;
 import org.testcontainers.containers.DockerComposeContainer;
@@ -38,6 +41,7 @@
 import java.time.OffsetDateTime;
 import java.time.temporal.ChronoUnit;
 import java.util.*;
+import java.util.stream.Collectors;
 import java.util.zip.GZIPInputStream;
 import java.util.zip.ZipEntry;
 import java.util.zip.ZipInputStream;
@@ -47,7 +51,6 @@
 import static gov.cms.ab2d.e2etest.APIClient.PATIENT_EXPORT_PATH;
 import static java.time.format.DateTimeFormatter.ISO_DATE_TIME;
 import static java.time.temporal.ChronoUnit.SECONDS;
-import static org.hamcrest.Matchers.greaterThan;
 import static org.hamcrest.Matchers.matchesPattern;
 
 // Unit tests here can be run from the IDE and will use LOCAL as the default, they can also be run from the TestLauncher
@@ -56,6 +59,7 @@
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 @ExtendWith(TestRunnerParameterResolver.class)
 @Slf4j
+@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
 public class TestRunner {
     private static final String FHIR_TYPE = "application/fhir+ndjson";
 
@@ -214,48 +218,62 @@ private Pair<String, JSONArray> verifyJsonFromStatusResponse(HttpResponse<String
         return Pair.of(url, extension);
     }
 
-    private void verifyJsonFromfileDownload(String fileContent, JSONArray extension, OffsetDateTime since) throws JSONException {
+    private void verifyJsonFromfileDownload(String fileContent, JSONArray extension, OffsetDateTime since, String optOut) throws JSONException {
         // Some of the data that is returned will be variable and will change from request to request, so not every
         // JSON object can be verified
-        final JSONObject fileJson = new JSONObject(fileContent);
-        Assert.assertTrue(validFields(fileJson));
-        Assert.assertEquals("ExplanationOfBenefit", fileJson.getString("resourceType"));
-        Assert.assertEquals(0, fileJson.getInt("precedence"));
-        String idString = fileJson.getString("id");
-
-        boolean found = false;
-        for(String acceptableIdString : acceptableIdStrings) {
-            if(idString.startsWith(acceptableIdString)) {
-                found = true;
-                break;
+        String[] jsonLines = fileContent.split("\n");
+        for (String str : jsonLines) {
+            if (str.isEmpty()) {
+                continue;
             }
-        }
 
-        if(!found) {
-            Assert.fail("No acceptable ID string was found, received " + idString);
-        }
+            JSONObject jsonObject = new JSONObject(str);
+
+            Assert.assertTrue(validFields(jsonObject));
+            Assert.assertEquals("ExplanationOfBenefit", jsonObject.getString("resourceType"));
+            Assert.assertEquals(0, jsonObject.getInt("precedence"));
+            String idString = jsonObject.getString("id");
+
+            boolean found = false;
+            for (String acceptableIdString : acceptableIdStrings) {
+                if (idString.startsWith(acceptableIdString)) {
+                    found = true;
+                    break;
+                }
+            }
+
+            if (!found) {
+                Assert.fail("No acceptable ID string was found, received " + idString);
+            }
+
+            final JSONObject patientJson = jsonObject.getJSONObject("patient");
+            String referenceString = patientJson.getString("reference");
+            Assert.assertTrue(referenceString.startsWith("Patient"));
+
+            String patientId = referenceString.substring(referenceString.indexOf('-') + 1);
+            if(optOut != null && patientId.equals(optOut)) {
+                Assert.fail("Patient ID opted out, but showed up in the download");
+            }
 
-        final JSONObject patientJson = fileJson.getJSONObject("patient");
-        String referenceString = patientJson.getString("reference");
-        Assert.assertTrue(referenceString.startsWith("Patient"));
-        final JSONObject typeJson = fileJson.getJSONObject("type");
-        Assert.assertNotNull(typeJson);
-        final JSONArray codingJson = typeJson.getJSONArray("coding");
-        Assert.assertNotNull(codingJson);
-        Assert.assertTrue(codingJson.length() >= 4);
-        final JSONArray identifierJson = fileJson.getJSONArray("identifier");
-        Assert.assertNotNull(identifierJson);
-        Assert.assertEquals(2, identifierJson.length());
-        final JSONArray diagnosisJson = fileJson.getJSONArray("diagnosis");
-        Assert.assertNotNull(diagnosisJson);
-        final JSONArray itemJson = fileJson.getJSONArray("item");
-        Assert.assertNotNull(itemJson);
-
-        final JSONObject metaJson = fileJson.getJSONObject("meta");
-        final String lastUpdated = metaJson.getString("lastUpdated");
-        Instant lastUpdatedInstant = Instant.parse(lastUpdated);
-        if(since != null) {
-            Assert.assertTrue(lastUpdatedInstant.isAfter(since.toInstant()));
+            final JSONObject typeJson = jsonObject.getJSONObject("type");
+            Assert.assertNotNull(typeJson);
+            final JSONArray codingJson = typeJson.getJSONArray("coding");
+            Assert.assertNotNull(codingJson);
+            Assert.assertTrue(codingJson.length() >= 4);
+            final JSONArray identifierJson = jsonObject.getJSONArray("identifier");
+            Assert.assertNotNull(identifierJson);
+            Assert.assertEquals(2, identifierJson.length());
+            final JSONArray diagnosisJson = jsonObject.getJSONArray("diagnosis");
+            Assert.assertNotNull(diagnosisJson);
+            final JSONArray itemJson = jsonObject.getJSONArray("item");
+            Assert.assertNotNull(itemJson);
+
+            final JSONObject metaJson = jsonObject.getJSONObject("meta");
+            final String lastUpdated = metaJson.getString("lastUpdated");
+            Instant lastUpdatedInstant = Instant.parse(lastUpdated);
+            if (since != null) {
+                Assert.assertTrue(lastUpdatedInstant.isAfter(since.toInstant()));
+            }
         }
 
         JSONObject checkSumObject = extension.getJSONObject(0);
@@ -308,7 +326,7 @@ private boolean validFields(JSONObject jsonObject) {
         return true;
     }
 
-    private void downloadFile(Pair<String, JSONArray> downloadDetails, OffsetDateTime since) throws IOException, InterruptedException, JSONException {
+    private void downloadFile(Pair<String, JSONArray> downloadDetails, OffsetDateTime since, String optOut) throws IOException, InterruptedException, JSONException {
         HttpResponse<InputStream> downloadResponse = apiClient.fileDownloadRequest(downloadDetails.getFirst());
 
         Assert.assertEquals(200, downloadResponse.statusCode());
@@ -320,7 +338,7 @@ private void downloadFile(Pair<String, JSONArray> downloadDetails, OffsetDateTim
             downloadString = IOUtils.toString(gzipInputStream, Charset.defaultCharset());
         }
 
-        verifyJsonFromfileDownload(downloadString, downloadDetails.getSecond(), since);
+        verifyJsonFromfileDownload(downloadString, downloadDetails.getSecond(), since, optOut);
     }
 
     private void downloadZipFile(String url, JSONArray extension, OffsetDateTime since) throws IOException, InterruptedException, JSONException {
@@ -333,7 +351,7 @@ private void downloadZipFile(String url, JSONArray extension, OffsetDateTime sin
             zipIn.closeEntry();
             entry = zipIn.getNextEntry();
         }
-        verifyJsonFromfileDownload(downloadString.toString(), extension, since);
+        verifyJsonFromfileDownload(downloadString.toString(), extension, since, null);
     }
 
     public static String extractZipFileData(ZipEntry entry, ZipInputStream zipIn) throws IOException {
@@ -376,16 +394,18 @@ private Pair<String, JSONArray> performStatusRequests(List<String> contentLocati
     }
 
     @Test
+    @Order(1)
     public void runSystemWideExport() throws IOException, InterruptedException, JSONException {
         HttpResponse<String> exportResponse = apiClient.exportRequest(FHIR_TYPE, null);
         Assert.assertEquals(202, exportResponse.statusCode());
         List<String> contentLocationList = exportResponse.headers().map().get("content-location");
 
         Pair<String, JSONArray> downloadDetails = performStatusRequests(contentLocationList, false, "S0000");
-        downloadFile(downloadDetails, null);
+        downloadFile(downloadDetails, null, null);
     }
 
     @Test
+    @Order(2)
     public void runSystemWideExportSince() throws IOException, InterruptedException, JSONException {
         HttpResponse<String> exportResponse = apiClient.exportRequest(FHIR_TYPE, earliest);
         System.out.println(earliest);
@@ -394,11 +414,12 @@ public void runSystemWideExportSince() throws IOException, InterruptedException,
 
         Pair<String, JSONArray> downloadDetails = performStatusRequests(contentLocationList, false, "S0000");
         if (downloadDetails != null) {
-            downloadFile(downloadDetails, earliest);
+            downloadFile(downloadDetails, earliest, null);
         }
     }
 
     @Test
+    @Order(3)
     public void runErrorSince() throws IOException, InterruptedException {
         OffsetDateTime timeBeforeEarliest = earliest.minus(1, ChronoUnit.MINUTES);
         HttpResponse<String> exportResponse = apiClient.exportRequest(FHIR_TYPE, timeBeforeEarliest);
@@ -410,30 +431,34 @@ public void runErrorSince() throws IOException, InterruptedException {
     }
 
     @Test
+    @Order(4)
     public void runSystemWideZipExport() throws IOException, InterruptedException, JSONException {
         HttpResponse<String> exportResponse = apiClient.exportRequest(ZIPFORMAT, null);
         Assert.assertEquals(400, exportResponse.statusCode());
     }
 
     @Test
+    @Order(5)
     public void runContractNumberExport() throws IOException, InterruptedException, JSONException {
         String contractNumber = "S0000";
         HttpResponse<String> exportResponse = apiClient.exportByContractRequest(contractNumber, FHIR_TYPE, null);
         Assert.assertEquals(202, exportResponse.statusCode());
         List<String> contentLocationList = exportResponse.headers().map().get("content-location");
 
         Pair<String, JSONArray> downloadDetails = performStatusRequests(contentLocationList, true, contractNumber);
-        downloadFile(downloadDetails, null);
+        downloadFile(downloadDetails, null, null);
     }
 
     @Test
+    @Order(6)
     void runContractNumberZipExport() throws IOException, InterruptedException, JSONException {
         String contractNumber = "S0000";
         HttpResponse<String> exportResponse = apiClient.exportByContractRequest(contractNumber, ZIPFORMAT, null);
         Assert.assertEquals(400, exportResponse.statusCode());
     }
 
     @Test
+    @Order(7)
     public void testDelete() throws IOException, InterruptedException {
         HttpResponse<String> exportResponse = apiClient.exportRequest(FHIR_TYPE, null);
 
@@ -447,6 +472,7 @@ public void testDelete() throws IOException, InterruptedException {
     }
 
     @Test
+    @Order(8)
     public void testUserCannotDownloadOtherUsersJob() throws IOException, InterruptedException, JSONException {
         String contractNumber = "S0000";
         HttpResponse<String> exportResponse = apiClient.exportByContractRequest(contractNumber, FHIR_TYPE, null);
@@ -462,6 +488,7 @@ public void testUserCannotDownloadOtherUsersJob() throws IOException, Interrupte
     }
 
     @Test
+    @Order(9)
     public void testUserCannotDeleteOtherUsersJob() throws IOException, InterruptedException, JSONException {
         HttpResponse<String> exportResponse = apiClient.exportRequest(FHIR_TYPE, null);
 
@@ -481,6 +508,7 @@ public void testUserCannotDeleteOtherUsersJob() throws IOException, InterruptedE
     }
 
     @Test
+    @Order(10)
     public void testUserCannotCheckStatusOtherUsersJob() throws IOException, InterruptedException, JSONException {
         HttpResponse<String> exportResponse = apiClient.exportRequest(FHIR_TYPE, null);
 
@@ -508,6 +536,7 @@ private APIClient createSecondUserClient() throws InterruptedException, JSONExce
     }
 
     @Test
+    @Order(11)
     public void testUserCannotMakeRequestWithoutToken() throws IOException, InterruptedException {
         HttpRequest exportRequest = HttpRequest.newBuilder()
                 .uri(URI.create(AB2D_API_URL + PATIENT_EXPORT_PATH))
@@ -522,6 +551,7 @@ public void testUserCannotMakeRequestWithoutToken() throws IOException, Interrup
     }
 
     @Test
+    @Order(12)
     public void testUserCannotMakeRequestWithSelfSignedToken() throws IOException, InterruptedException, JSONException {
         String clientSecret = "wefikjweglkhjwelgkjweglkwegwegewg";
         SecretKey sharedSecret = Keys.hmacShaKeyFor(clientSecret.getBytes(StandardCharsets.UTF_8));
@@ -558,6 +588,7 @@ public void testUserCannotMakeRequestWithSelfSignedToken() throws IOException, I
     }
 
     @Test
+    @Order(13)
     public void testBadQueryParameterResource() throws IOException, InterruptedException {
         var params = new HashMap<>(){{
             put("_type", "BadParam");
@@ -568,6 +599,7 @@ public void testBadQueryParameterResource() throws IOException, InterruptedExcep
     }
 
     @Test
+    @Order(14)
     public void testBadQueryParameterOutputFormat() throws IOException, InterruptedException {
         var params = new HashMap<>(){{
             put("_outputFormat", "BadParam");
@@ -578,9 +610,22 @@ public void testBadQueryParameterOutputFormat() throws IOException, InterruptedE
     }
 
     @Test
+    @Order(15)
     public void testHealthEndPoint() throws IOException, InterruptedException {
         HttpResponse<String> healthCheckResponse = apiClient.healthCheck();
 
         Assert.assertEquals(200, healthCheckResponse.statusCode());
     }
+
+    @Test
+    @Order(16)
+    public void testOptOut() throws IOException, InterruptedException, JSONException {
+        HttpResponse<String> exportResponse = apiClient.exportRequest(FHIR_TYPE, null);
+
+        Assert.assertEquals(202, exportResponse.statusCode());
+        List<String> contentLocationList = exportResponse.headers().map().get("content-location");
+
+        Pair<String, JSONArray> downloadDetails = performStatusRequests(contentLocationList, false, "S0000");
+        downloadFile(downloadDetails, null, "19990000002906");
+    }
 }
diff --git a/optout/src/main/resources/application.optout.properties b/optout/src/main/resources/application.optout.properties
@@ -19,9 +19,11 @@ spring.quartz.properties.org.quartz.jobStore.driverDelegateClass=org.quartz.impl
 spring.quartz.properties.org.quartz.jobStore.acquireTriggersWithinLock=true
 
 # Every hour at minute 0, second 0 ------------------------------------------------------------ CRON SCHEDULE
-cron.schedule=0 0 * * * ?
+cron.schedule=${AB2D_OPT_OUT_JOB_SCHEDULE:#{'0 0 * * * ?'}}
 
 s3.region=${AB2D_S3_REGION:us-east-1}
 s3.bucket=${AB2D_S3_OPTOUT_BUCKET:ab2d-optout-data-dev}
 
 
+
+
