|
| 1 | +from unittest.mock import Mock, patch |
| 2 | + |
| 3 | +import pytest |
| 4 | + |
| 5 | +from DIRAC.DataManagementSystem.Client.FTS3Job import get_scitag |
| 6 | + |
| 7 | + |
| 8 | +@pytest.fixture |
| 9 | +def sample_json_response(): |
| 10 | + """Sample JSON response for testing.""" |
| 11 | + return { |
| 12 | + "experiments": [ |
| 13 | + { |
| 14 | + "expName": "default", |
| 15 | + "expId": 1, |
| 16 | + "activities": [ |
| 17 | + {"activityName": "default", "activityId": 1}, |
| 18 | + {"activityName": "Data Challenge", "activityId": 4}, |
| 19 | + ], |
| 20 | + }, |
| 21 | + { |
| 22 | + "expName": "atlas", |
| 23 | + "expId": 100, |
| 24 | + "activities": [ |
| 25 | + {"activityName": "default", "activityId": 1}, |
| 26 | + {"activityName": "analysis", "activityId": 2}, |
| 27 | + {"activityName": "production", "activityId": 3}, |
| 28 | + ], |
| 29 | + }, |
| 30 | + { |
| 31 | + "expName": "cms", |
| 32 | + "expId": 200, |
| 33 | + "activities": [{"activityName": "default", "activityId": 1}, {"activityName": "mc", "activityId": 4}], |
| 34 | + }, |
| 35 | + ] |
| 36 | + } |
| 37 | + |
| 38 | + |
| 39 | +@pytest.fixture |
| 40 | +def mock_requests_success(sample_json_response): |
| 41 | + """Mock successful HTTP request.""" |
| 42 | + with patch("requests.get") as mock_get: |
| 43 | + mock_response = Mock() |
| 44 | + mock_response.json.return_value = sample_json_response |
| 45 | + mock_response.raise_for_status.return_value = None |
| 46 | + mock_get.return_value = mock_response |
| 47 | + yield mock_get |
| 48 | + |
| 49 | + |
| 50 | +class TestGetScitag: |
| 51 | + def test_valid_vo_and_activity(self, mock_requests_success): |
| 52 | + """Test get_scitag with valid VO and activity.""" |
| 53 | + result = get_scitag("atlas", "analysis") |
| 54 | + expected = 100 << 6 | 2 # atlas expId=100, analysis activityId=2 |
| 55 | + assert result == expected |
| 56 | + |
| 57 | + def test_valid_vo_no_activity(self, mock_requests_success): |
| 58 | + """Test get_scitag with valid VO but no specific activity (should use default).""" |
| 59 | + result = get_scitag("cms") |
| 60 | + expected = 200 << 6 | 1 # cms expId=200, default activityId=1 |
| 61 | + assert result == expected |
| 62 | + |
| 63 | + def test_invalid_vo(self, mock_requests_success): |
| 64 | + """Test get_scitag with invalid VO (should use default vo_id=1).""" |
| 65 | + result = get_scitag("nonexistent") |
| 66 | + expected = 1 << 6 | 1 # default vo_id=1, default activity_id=1 |
| 67 | + assert result == expected |
| 68 | + |
| 69 | + def test_valid_vo_invalid_activity(self, mock_requests_success): |
| 70 | + """Test get_scitag with valid VO but invalid activity.""" |
| 71 | + result = get_scitag("atlas", "nonexistent_activity") |
| 72 | + expected = 100 << 6 | 1 # atlas expId=100, default activity_id=1 |
| 73 | + assert result == expected |
| 74 | + |
| 75 | + def test_case_insensitive_vo(self, mock_requests_success): |
| 76 | + """Test that VO matching is case insensitive.""" |
| 77 | + result = get_scitag("ATLAS", "production") |
| 78 | + expected = 100 << 6 | 3 # atlas expId=100, production activityId=3 |
| 79 | + assert result == expected |
| 80 | + |
| 81 | + |
| 82 | +@pytest.mark.parametrize( |
| 83 | + "vo,activity,expected_vo_id,expected_activity_id", |
| 84 | + [ |
| 85 | + ("atlas", "analysis", 100, 2), |
| 86 | + ("atlas", "production", 100, 3), |
| 87 | + ("cms", "mc", 200, 4), |
| 88 | + ("cms", "default", 200, 1), |
| 89 | + ("nonexistent", "any", 1, 1), # defaults |
| 90 | + ("atlas", "nonexistent", 100, 1), # valid vo, invalid activity |
| 91 | + ], |
| 92 | +) |
| 93 | +def test_parametrized_scenarios(mock_requests_success, vo, activity, expected_vo_id, expected_activity_id): |
| 94 | + """Parametrized test for various VO and activity combinations.""" |
| 95 | + result = get_scitag(vo, activity) |
| 96 | + expected = expected_vo_id << 6 | expected_activity_id |
| 97 | + assert result == expected |
| 98 | + |
| 99 | + |
| 100 | +@pytest.mark.parametrize( |
| 101 | + "vo,expected_result", |
| 102 | + [ |
| 103 | + ("atlas", 100 << 6 | 1), # Should use default activity |
| 104 | + ("cms", 200 << 6 | 1), # Should use default activity |
| 105 | + ("unknown", 1 << 6 | 1), # Should use all defaults |
| 106 | + ], |
| 107 | +) |
| 108 | +def test_no_activity_parameter(mock_requests_success, vo, expected_result): |
| 109 | + """Test behavior when no activity parameter is provided.""" |
| 110 | + result = get_scitag(vo) |
| 111 | + assert result == expected_result |
0 commit comments