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

Add a listener event for notes changing

Browse Source
This commit is contained in:
Kovid Goyal 2025-04-03 08:00:23 +05:30
parent b868167d50
commit 6359c0593f
No known key found for this signature in database
GPG Key ID: 06BC317B515ACE7C
2 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -716,7 +716,9 @@ class Cache:
references resources their hashes must be present in resource_hashes. Set remove_unused_resources to True to cleanup unused
resources, note that updating a note automatically cleans up resources pertaining to that note anyway.
'''
return self.backend.set_notes_for(field, item_id, doc, searchable_text, resource_hashes, remove_unused_resources)
ans = self.backend.set_notes_for(field, item_id, doc, searchable_text, resource_hashes, remove_unused_resources)
self.event_dispatcher(EventType.notes_changed, field, item_id)
return ans
@write_api
def add_notes_resource(self, path_or_stream_or_data, name: str, mtime: float = None) -> int:
@ -736,7 +738,9 @@ class Cache:
@write_api
def unretire_note_for(self, field, item_id) -> int:
' Unretire a previously retired note for the specified item. Notes are retired when an item is removed from the database '
return self.backend.unretire_note_for(field, item_id)
ans = self.backend.unretire_note_for(field, item_id)
self.event_dispatcher(EventType.notes_changed, field, item_id)
return ans
@read_api
def export_note(self, field, item_id) -> str:
@ -756,7 +760,9 @@ class Cache:
st = os.stat(f.fileno())
ctime, mtime = st.st_ctime, st.st_mtime
basedir = os.path.dirname(os.path.abspath(path_to_html_file))
return self.backend.import_note(field, item_id, html, basedir, ctime, mtime)
ans = self.backend.import_note(field, item_id, html, basedir, ctime, mtime)
self.event_dispatcher(EventType.notes_changed, field, item_id)
return ans
@write_api # we need to use write locking as SQLITE gives a locked table error if multiple FTS queries are made at the same time
def search_notes(

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

@ -43,6 +43,9 @@ class EventType(Enum):
#: When the indexing progress changes
indexing_progress_changed = auto()
#: When the notes associated with an item are changed, with arguments: (field_name, item_id)
notes_changed = auto()
class EventDispatcher(Thread):