pr0nstar

XV.V

...@@ -28,16 +28,13 @@ def fetch_search( ...@@ -28,16 +28,13 @@ def fetch_search(
28 'hits': [], 28 'hits': [],
29 } 29 }
30 30
31 + try:
31 return search.do_search( 32 return search.do_search(
32 query.q, query.page, query.is_class, query.class_, query.order 33 query.q, query.page, query.is_class, query.class_, query.order
33 ) 34 )
34 - # try: 35 + except search.SearchUnavailable as exc:
35 - # return search.do_search( 36 + raise HTTPException(
36 - # query.q, query.page, query.is_class, query.class_, query.order 37 + status_code=503,
37 - # ) 38 + detail='Search temporarily unavailable',
38 - # except search.SearchUnavailable as exc: 39 + headers={'Retry-After': str(exc.retry_after)},
39 - # raise HTTPException( 40 + ) from exc
40 - # status_code=503,
41 - # detail='Search temporarily unavailable',
42 - # headers={'Retry-After': str(exc.retry_after)},
43 - # ) from exc
......
...@@ -8,9 +8,9 @@ from typesense import exceptions as typesense_exceptions ...@@ -8,9 +8,9 @@ from typesense import exceptions as typesense_exceptions
8 TYPESENSE_API = open('./docs/typesense').read().strip() 8 TYPESENSE_API = open('./docs/typesense').read().strip()
9 TYPESENSE_API, TYPESENSE_HOST = TYPESENSE_API.split(':') 9 TYPESENSE_API, TYPESENSE_HOST = TYPESENSE_API.split(':')
10 client = typesense.Client({ 10 client = typesense.Client({
11 - 'api_key': TYPESENSE_API, 11 + 'api_key': TYPESENSE_API.strip(),
12 'nodes': [{ 12 'nodes': [{
13 - 'host': TYPESENSE_HOST, 13 + 'host': TYPESENSE_HOST.strip(),
14 'port': '8108', 14 'port': '8108',
15 'protocol': 'http' 15 'protocol': 'http'
16 }], 16 }],
...@@ -127,12 +127,12 @@ def do_search(query, page, is_class, class_=None, order=None): ...@@ -127,12 +127,12 @@ def do_search(query, page, is_class, class_=None, order=None):
127 if order == 'asc': 127 if order == 'asc':
128 search_parameters_['sort_by'] = 'devengado:asc' 128 search_parameters_['sort_by'] = 'devengado:asc'
129 129
130 - # try: 130 + try:
131 response = client.collections[COLLECTION].documents.search( 131 response = client.collections[COLLECTION].documents.search(
132 search_parameters_ 132 search_parameters_
133 ) 133 )
134 - # except BACKEND_ERRORS: 134 + except BACKEND_ERRORS:
135 - # raise SearchUnavailable(search_guard.record_failure()) 135 + raise SearchUnavailable(search_guard.record_failure())
136 136
137 search_guard.record_success() 137 search_guard.record_success()
138 return response 138 return response
......