|
1 | 1 | from primary.routers.timeseries import router
|
2 | 2 | from primary.routers.timeseries import schemas
|
| 3 | +from sumo.wrapper import SumoClient |
| 4 | + |
| 5 | +from primary.services.utils.authenticated_user import AuthenticatedUser, AccessTokens |
3 | 6 |
|
4 | 7 |
|
5 | 8 | async def test_get_vector_list(test_user, sumo_test_ensemble_ahm):
|
6 | 9 |
|
7 |
| - # vector_list = await router.get_vector_list( |
8 |
| - # None, test_user, sumo_test_ensemble_ahm.case_uuid, sumo_test_ensemble_ahm.ensemble_name |
9 |
| - # ) |
10 |
| - assert test_user.has_sumo_access_token() == True |
11 |
| - assert len(test_user.get_sumo_access_token()) == 537 |
12 |
| - # assert len(vector_list) == 786 |
13 |
| - # assert isinstance(vector_list[0], schemas.VectorDescription) |
| 10 | + client = SumoClient(env="prod") |
| 11 | + token = client.authenticate() |
| 12 | + tokens = AccessTokens(sumo_access_token=token) |
| 13 | + user = AuthenticatedUser(user_id="test_user", username="test_user", access_tokens=tokens) |
| 14 | + assert user.has_sumo_access_token() == True |
| 15 | + assert len(user.get_sumo_access_token()) == 537 |
| 16 | + |
| 17 | + |
| 18 | + |
| 19 | + vector_list = await router.get_vector_list( |
| 20 | + None, user, sumo_test_ensemble_ahm.case_uuid, sumo_test_ensemble_ahm.ensemble_name |
| 21 | + ) |
| 22 | + |
| 23 | + assert len(vector_list) == 786 |
| 24 | + assert isinstance(vector_list[0], schemas.VectorDescription) |
0 commit comments