zaclys/searxng
1
0
Fork 1
mirror of https://github.com/searxng/searxng synced 2024-01-01 18:24:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

[mod] checker: add status and timestamp to the result

Browse Source 
for each engine: replace status by success
This commit is contained in:
Alexandre Flament 2021-01-11 18:43:12 +01:00
parent f3e1bd308f
commit 87bafbc32b
1 changed files with 21 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
searx/search/checker/background.py
View File

@ -35,28 +35,39 @@ def _get_every():
def get_result(): def get_result():
serialized_result = storage.get_str('CHECKER_RESULT') serialized_result = storage.get_str(CHECKER_RESULT)
if serialized_result is not None: if serialized_result is not None:
return json.loads(serialized_result) return json.loads(serialized_result)
def _set_result(result):
result['timestamp'] = int(time.time() / 3600) * 3600
storage.set_str(CHECKER_RESULT, json.dumps(result))
def run(): def run():
if not running.acquire(blocking=False): if not running.acquire(blocking=False):
return return
try: try:
logger.info('Starting checker') logger.info('Starting checker')
result = {} result = {
'status': 'ok',
'engines': {}
}
for name, processor in processors.items(): for name, processor in processors.items():
logger.debug('Checking %s engine', name) logger.debug('Checking %s engine', name)
checker = Checker(processor) checker = Checker(processor)
checker.run() checker.run()
if checker.test_results.succesfull: if checker.test_results.succesfull:
result[name] = {'status': True} result['engines'][name] = {'success': True}
else: else:
result[name] = {'status': False, 'errors': checker.test_results.errors} result['engines'][name] = {'success': False, 'errors': checker.test_results.errors}
storage.set_str('CHECKER_RESULT', json.dumps(result)) _set_result(result)
logger.info('Check done') logger.info('Check done')
except Exception:
_set_result({'status': 'error'})
logger.exception('Error while running the checker')
finally: finally:
running.release() running.release()
@ -85,6 +96,9 @@ def initialize():
logger.info('Send SIGUSR1 signal to pid %i to start the checker', os.getpid()) logger.info('Send SIGUSR1 signal to pid %i to start the checker', os.getpid())
signal.signal(signal.SIGUSR1, _signal_handler) signal.signal(signal.SIGUSR1, _signal_handler)
# disabled by default
_set_result({'status': 'disabled'})
# special case when debug is activate # special case when debug is activate
if searx_debug and settings.get('checker', {}).get('off_when_debug', True): if searx_debug and settings.get('checker', {}).get('off_when_debug', True):
logger.info('debug mode: checker is disabled') logger.info('debug mode: checker is disabled')
@ -97,6 +111,8 @@ def initialize():
return return
# #
_set_result({'status': 'unknow'})
start_after = scheduling.get('start_after', (300, 1800)) start_after = scheduling.get('start_after', (300, 1800))
start_after = _get_interval(start_after, 'checker.scheduling.start_after is not a int or list') start_after = _get_interval(start_after, 'checker.scheduling.start_after is not a int or list')
delay = random.randint(start_after[0], start_after[1]) delay = random.randint(start_after[0], start_after[1])