Backup_Repos/calibre
1
0
Fork 0
mirror of git://github.com/kovidgoyal/calibre.git synced 2026-04-28 14:43:04 +02:00
Code Issues Projects Releases Wiki Activity

Handle errors in the worker

Browse source
This commit is contained in:
Kovid Goyal 2021-05-17 17:06:00 +05:30
parent a365ac1862
commit 9f1d9a9781
No known key found for this signature in database
GPG key ID: 06BC317B515ACE7C
2 changed files with 22 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
src/pyj/read_book/search.pyj
View file

@ -8,9 +8,12 @@
from complete import create_search_bar
from dom import add_extra_css, build_rule, svgicon
from gettext import gettext as _
from modals import error_dialog
from read_book.globals import ui_operations
from read_book.search_worker import worker_main
from read_book.resources import text_from_serialized_html
from read_book.search_worker import (
CONNECT_FAILED, DB_ERROR, GET_SPINE_FAILED, UNHANDLED_ERROR, worker_main
)
from read_book.shortcuts import shortcut_for_key_event
from worker import start_worker
@ -67,10 +70,23 @@ def queue_search(self, query, book, current_name):
def on_worker_message(self, evt):
msg = evt.data
if msg.type is 'error':
pass
details = msg.msg
emsg = _('Unknown error')
if msg.code is GET_SPINE_FAILED:
emsg = _('Loading text from the book failed.')
elif msg.code is CONNECT_FAILED:
emsg = _('Connecting to database storing the local copy of the book failed in the worker thread.')
elif msg.code is UNHANDLED_ERROR:
emsg = _('There was an unhandled error while searching.')
elif msg.code is DB_ERROR:
emsg = msg.error.msg
details = msg.error.details
error_dialog(_('Could not search'), emsg, details)
elif msg.id is self.search_in_flight_id:
if msg.type is 'search_complete':
self.search_in_flight_id = None
elif msg.type is 'search_result':
pass
def clear_caches(self):
if self._worker:

6
src/pyj/read_book/search_worker.pyj
View file

@ -4,6 +4,7 @@
from read_book.db import DB
from read_book.resources import text_from_serialized_html
from traceback import format_exception
GET_SPINE_FAILED = 1
CONNECT_FAILED = 2
@ -200,5 +201,6 @@ def worker_main():
elif e.data.type is 'clear_caches':
wc.clear_caches()
self.onerror = def(e):
send_error(UNHANDLED_ERROR, f'{e.line}:{e.message}')
self.addEventListener('error', def (e):
send_error(UNHANDLED_ERROR, f'{e.lineno}:{e.message}' + '\n\n' + format_exception(e.error).join(''))
)