Replicate file path change

Author: dlzhry2nhs

lambdas/filenameprocessor/src/constants.py

@@ -27,7 +27,7 @@
 # Currently only COVID extended attributes files are supported, might be extended in future for other vaccine types
 EXTENDED_ATTRIBUTES_VACC_TYPE = "COVID"
 
-DPS_DESTINATION_PREFIX = "dps_destination"
+DPS_DESTINATION_PREFIX = "generic/EXTENDED_ATTRIBUTES_DAILY_1"
 EXTENDED_ATTRIBUTES_ARCHIVE_PREFIX = "extended-attributes-archive"
 VALID_EA_VERSIONS = ["V1_5"]
 ERROR_TYPE_TO_STATUS_CODE_MAP = {

lambdas/filenameprocessor/tests/test_lambda_handler.py

@@ -292,8 +292,8 @@ def test_lambda_handler_extended_attributes_success(self, mock_get_redis_client)
         archived_obj = s3_client.get_object(Bucket=BucketNames.SOURCE, Key=archived_key)
         self.assertIsNotNone(archived_obj)
 
-        # Also verify file copied to DPS destination bucket under dps_destination/<file_key>
-        dps_key = f"dps_destination/{test_cases[0].file_key}"
+        # Also verify file copied to DPS destination bucket under generic/EXTENDED_ATTRIBUTES_DAILY_1/<file_key>
+        dps_key = f"generic/EXTENDED_ATTRIBUTES_DAILY_1/{test_cases[0].file_key}"
         copied_obj = s3_client.get_object(Bucket=BucketNames.DPS_DESTINATION, Key=dps_key)
         self.assertIsNotNone(copied_obj)
 
@@ -467,7 +467,7 @@ def test_lambda_handler_extended_attributes_extension_checks(self, mock_get_redi
         # Ensure processed path hit by checking archive move in source bucket
         s3_client.get_object(Bucket=BucketNames.SOURCE, Key=f"extended-attributes-archive/{csv_key}")
         # And verify copy to DPS destination
-        s3_client.get_object(Bucket=BucketNames.DPS_DESTINATION, Key=f"dps_destination/{csv_key}")
+        s3_client.get_object(Bucket=BucketNames.DPS_DESTINATION, Key=f"generic/EXTENDED_ATTRIBUTES_DAILY_1/{csv_key}")
 
         # .DAT accepted
         dat_key = MockFileDetails.extended_attributes_file.file_key[:-3] + "dat"
@@ -478,7 +478,7 @@ def test_lambda_handler_extended_attributes_extension_checks(self, mock_get_redi
         ):
             lambda_handler(self.make_event([self.make_record(dat_key)]), None)
         s3_client.get_object(Bucket=BucketNames.SOURCE, Key=f"extended-attributes-archive/{dat_key}")
-        s3_client.get_object(Bucket=BucketNames.DPS_DESTINATION, Key=f"dps_destination/{dat_key}")
+        s3_client.get_object(Bucket=BucketNames.DPS_DESTINATION, Key=f"generic/EXTENDED_ATTRIBUTES_DAILY_1/{dat_key}")
 
         # Invalid extension fails
         bad_ext_key = csv_key[:-3] + "txt"