|
25 | 25 | from ..constants import PLANET_BASE_URL |
26 | 26 | from ..http import Session |
27 | 27 | from ..models import Paged, StreamingBody |
| 28 | +from ..specs import validate_item_type |
28 | 29 |
|
29 | 30 | BASE_URL = f'{PLANET_BASE_URL}/data/v1/' |
30 | 31 | SEARCHES_PATH = '/searches' |
@@ -146,7 +147,7 @@ async def search(self, |
146 | 147 |
|
147 | 148 | search_filter = search_filter or empty_filter() |
148 | 149 |
|
149 | | - # TODO: validate item_types |
| 150 | + item_types = [validate_item_type(item) for item in item_types] |
150 | 151 | request_json = {'filter': search_filter, 'item_types': item_types} |
151 | 152 | if name: |
152 | 153 | request_json['name'] = name |
@@ -203,7 +204,7 @@ async def create_search(self, |
203 | 204 | """ |
204 | 205 | url = self._searches_url() |
205 | 206 |
|
206 | | - # TODO: validate item_types |
| 207 | + item_types = [validate_item_type(item) for item in item_types] |
207 | 208 | request = { |
208 | 209 | 'name': name, |
209 | 210 | 'filter': search_filter, |
@@ -236,6 +237,7 @@ async def update_search(self, |
236 | 237 | """ |
237 | 238 | url = f'{self._searches_url()}/{search_id}' |
238 | 239 |
|
| 240 | + item_types = [validate_item_type(item) for item in item_types] |
239 | 241 | request = { |
240 | 242 | 'name': name, |
241 | 243 | 'filter': search_filter, |
@@ -394,6 +396,7 @@ async def get_stats(self, |
394 | 396 |
|
395 | 397 | url = f'{self._base_url}{STATS_PATH}' |
396 | 398 |
|
| 399 | + item_types = [validate_item_type(item) for item in item_types] |
397 | 400 | request = { |
398 | 401 | 'interval': interval, |
399 | 402 | 'filter': search_filter, |
|
0 commit comments