Cutlery/calibre
1
0
Fork 0
mirror of https://github.com/kovidgoyal/calibre.git synced 2025-07-09 03:04:10 -04:00
Code Issues Packages Projects Releases Wiki Activity

Also add the library id when dispatching events

Browse Source
This commit is contained in:
Kovid Goyal 2021-08-10 12:09:14 +05:30
parent 559d467556
commit d3681ca528
No known key found for this signature in database
GPG Key ID: 06BC317B515ACE7C
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/calibre/db/cache.py
View File

@ -427,10 +427,10 @@ class Cache(object):
def add_listener(self, event_callback_function): def add_listener(self, event_callback_function):
''' '''
Register a callback function that will be called after certain actions are Register a callback function that will be called after certain actions are
taken on this database. The function must take two arguments, the first of taken on this database. The function must take three arguments:
which is the event type (:class:`EventType`) and the second is a tuple (:class:`EventType`, library_id, event_type_specific_data)
containing event type specific data.
''' '''
self.event_dispatcher.library_id = getattr(self, 'server_library_id', self.library_id)
self.event_dispatcher.add_listener(event_callback_function) self.event_dispatcher.add_listener(event_callback_function)
@write_api @write_api

3
src/calibre/db/listeners.py
View File

@ -46,6 +46,7 @@ class EventDispatcher:
self.refs = [] self.refs = []
self.queue = Queue() self.queue = Queue()
self.activated = False self.activated = False
self.library_id = ''
def add_listener(self, callback): def add_listener(self, callback):
# note that we intentionally leak dead weakrefs. To not do so would # note that we intentionally leak dead weakrefs. To not do so would
@ -66,7 +67,7 @@ class EventDispatcher:
def __call__(self, event_name, *args): def __call__(self, event_name, *args):
if self.activated: if self.activated:
self.queue.put((event_name, args)) self.queue.put((event_name, self.library_id, args))
def close(self): def close(self):
if self.activated: if self.activated: