mirror of
https://github.com/GSA/notifications-api.git
synced 2025-12-22 00:11:16 -05:00
Add s3 method to remove transformed dvla files
This commit is contained in:
@@ -26,3 +26,10 @@ def remove_job_from_s3(service_id, job_id):
|
|||||||
file_location = FILE_LOCATION_STRUCTURE.format(service_id, job_id)
|
file_location = FILE_LOCATION_STRUCTURE.format(service_id, job_id)
|
||||||
obj = get_s3_object(bucket_name, file_location)
|
obj = get_s3_object(bucket_name, file_location)
|
||||||
return obj.delete()
|
return obj.delete()
|
||||||
|
|
||||||
|
|
||||||
|
def remove_transformed_dvla_file(job_id):
|
||||||
|
bucket_name = current_app.config['DVLA_UPLOAD_BUCKET_NAME']
|
||||||
|
file_location = '{}-dvla-job.text'.format(job_id)
|
||||||
|
obj = get_s3_object(bucket_name, file_location)
|
||||||
|
return obj.delete()
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ from app.v2.notifications.notification_schemas import get_notifications_request
|
|||||||
def get_notification_by_id(id):
|
def get_notification_by_id(id):
|
||||||
try:
|
try:
|
||||||
casted_id = uuid.UUID(id)
|
casted_id = uuid.UUID(id)
|
||||||
except ValueError or AttributeError:
|
except (ValueError, AttributeError):
|
||||||
abort(404)
|
abort(404)
|
||||||
notification = notifications_dao.get_notification_with_personalisation(
|
notification = notifications_dao.get_notification_with_personalisation(
|
||||||
authenticated_service.id, casted_id, key_type=None
|
authenticated_service.id, casted_id, key_type=None
|
||||||
|
|||||||
@@ -1,7 +1,11 @@
|
|||||||
from app.aws.s3 import get_s3_file
|
from unittest.mock import call
|
||||||
|
|
||||||
|
from flask import current_app
|
||||||
|
|
||||||
|
from app.aws.s3 import get_s3_file, remove_transformed_dvla_file
|
||||||
|
|
||||||
|
|
||||||
def test_get_s3_file_makes_correct_call(sample_service, sample_job, mocker):
|
def test_get_s3_file_makes_correct_call(notify_api, mocker):
|
||||||
get_s3_mock = mocker.patch('app.aws.s3.get_s3_object')
|
get_s3_mock = mocker.patch('app.aws.s3.get_s3_object')
|
||||||
get_s3_file('foo-bucket', 'bar-file.txt')
|
get_s3_file('foo-bucket', 'bar-file.txt')
|
||||||
|
|
||||||
@@ -9,3 +13,15 @@ def test_get_s3_file_makes_correct_call(sample_service, sample_job, mocker):
|
|||||||
'foo-bucket',
|
'foo-bucket',
|
||||||
'bar-file.txt'
|
'bar-file.txt'
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
def test_remove_transformed_dvla_file_makes_correct_call(notify_api, mocker):
|
||||||
|
s3_mock = mocker.patch('app.aws.s3.get_s3_object')
|
||||||
|
fake_uuid = '5fbf9799-6b9b-4dbb-9a4e-74a939f3bb49'
|
||||||
|
|
||||||
|
remove_transformed_dvla_file(fake_uuid)
|
||||||
|
|
||||||
|
s3_mock.assert_has_calls([
|
||||||
|
call(current_app.config['DVLA_UPLOAD_BUCKET_NAME'], '{}-dvla-job.text'.format(fake_uuid)),
|
||||||
|
call().delete()
|
||||||
|
])
|
||||||
|
|||||||
Reference in New Issue
Block a user