Skip to content

Commit 5b5daf6

Browse files
committed
pass minio_client into get validation from minio
1 parent ba62fc8 commit 5b5daf6

2 files changed

Lines changed: 4 additions & 8 deletions

File tree

app/utils/minio_utils.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -109,11 +109,12 @@ def update_validation_status_in_minio(minio_client: object, minio_bucket: str, c
109109
)
110110

111111

112-
def get_validation_status_from_minio(minio_bucket: str, crate_id: str, root_path: str) -> dict:
112+
def get_validation_status_from_minio(minio_client: object, minio_bucket: str, crate_id: str, root_path: str) -> dict:
113113
"""
114114
Checks for the existence of a validation report for the given RO-Crate in the MinIO bucket.
115115
Returns validation message if it exists, or notification that it is missing if not.
116116
117+
:param minio_client: The MinIO client
117118
:param minio_bucket: The MinIO bucket containing the RO-Crate.
118119
:param crate_id: The ID of the RO-Crate in MinIO
119120
:return validation_status: Either the validation status, or note that this does not exist
@@ -129,9 +130,6 @@ def get_validation_status_from_minio(minio_bucket: str, crate_id: str, root_path
129130
logging.info(f"Getting object {object_name}")
130131

131132
try:
132-
133-
minio_client = get_minio_client()
134-
135133
response = minio_client.get_object(
136134
minio_bucket,
137135
object_name,

tests/test_minio.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -283,10 +283,9 @@ def test_download_s3error(
283283
def test_successful_retrieval(mocker, mock_minio_response):
284284
mock_client = MagicMock()
285285
mock_client.get_object.return_value = mock_minio_response
286-
mocker.patch("app.utils.minio_utils.get_minio_client", return_value=mock_client)
287286

288287
from app.utils.minio_utils import get_validation_status_from_minio
289-
result = get_validation_status_from_minio("test_bucket", "crate123", None)
288+
result = get_validation_status_from_minio(mock_client, "test_bucket", "crate123", None)
290289

291290
assert result == {"status": "valid"}
292291
mock_minio_response.close.assert_called_once()
@@ -325,11 +324,10 @@ def test_get_validation_error_raised(
325324
):
326325
mock_client = MagicMock()
327326
mock_client.get_object.side_effect = get_side_effect
328-
mocker.patch("app.utils.minio_utils.get_minio_client", return_value=mock_client)
329327

330328
from app.utils.minio_utils import get_validation_status_from_minio, InvalidAPIUsage
331329
with pytest.raises(InvalidAPIUsage) as exc:
332-
get_validation_status_from_minio(bucket, crateid, root_path)
330+
get_validation_status_from_minio(mock_client, bucket, crateid, root_path)
333331

334332
assert exc.value.status_code == status_code
335333
assert error_check in str(exc.value.message)

0 commit comments

Comments
 (0)