|
14 | 14 | logger = logging.getLogger(__name__) |
15 | 15 |
|
16 | 16 |
|
17 | | -def search(url=STAC_URL, matched=False, save=None, **kwargs): |
| 17 | +def search(url=STAC_URL, matched=False, save=None, headers=None, **kwargs): |
18 | 18 | """ Main function for performing a search """ |
19 | 19 |
|
20 | 20 | try: |
21 | | - catalog = Client.open(url) |
| 21 | + catalog = Client.open(url, headers=headers) |
22 | 22 | search = catalog.search(**kwargs) |
23 | 23 |
|
24 | 24 | if matched: |
@@ -51,7 +51,7 @@ def parse_args(args): |
51 | 51 | parent.add_argument('--url', help='Root Catalog URL', default=os.getenv('STAC_URL', None)) |
52 | 52 | parent.add_argument('--limit', help='Page size limit', type=int, default=500) |
53 | 53 | parent.add_argument('--headers', |
54 | | - help='Additional request headers (JSON file or string)', |
| 54 | + help='Additional request headers (JSON string)', |
55 | 55 | default=None) |
56 | 56 |
|
57 | 57 | subparsers = parser0.add_subparsers(dest='command') |
@@ -106,6 +106,10 @@ def parse_args(args): |
106 | 106 | else: |
107 | 107 | parsed_args['intersects'] = data |
108 | 108 |
|
| 109 | + # if headers provided, parse it |
| 110 | + if 'headers' in parsed_args: |
| 111 | + parsed_args['headers'] = json.loads(parsed_args['headers']) |
| 112 | + |
109 | 113 | return parsed_args |
110 | 114 |
|
111 | 115 |
|
|
0 commit comments