feat(kosync): push KOReader reading progress to Hardcover after status update

* Push reading progress from koreader to Hardcover

* Remove commented out code

* Revert debug logging changes to hardcover client

Author: frbncis

cps/kobo.py

@@ -975,7 +975,7 @@ def HandleStateRequest(book_uuid):
             ub.session.rollback()
             abort(400, description="Malformed request data is missing 'ReadingStates' key")
 
-        push_reading_state_to_hardcover(book, request_bookmark)
+        push_reading_state_to_hardcover(current_user, book, request_bookmark['ProgressPercent'])
 
         ub.session.merge(kobo_reading_state)
         ub.session_commit()
@@ -985,15 +985,15 @@ def HandleStateRequest(book_uuid):
         })
 
 
-def push_reading_state_to_hardcover(book: db.Books, request_bookmark: dict):
+def push_reading_state_to_hardcover(user, book: db.Books, progress_percentage: int):
     """
     Sync reading progress to Hardcover if enabled for the user and book is not blacklisted.
 
     Most exceptions are caught and logged so that issues with Hardcover do not prevent
     the Kobo from clearing its reading state sync queue.
 
     :param book: The book for which to sync reading progress.
-    :param request_bookmark: The bookmark data from the Kobo request.
+    :param progress_percentage: Reading progress percentage.
     :return: None
     """
 
@@ -1009,16 +1009,16 @@ def push_reading_state_to_hardcover(book: db.Books, request_bookmark: dict):
         return
 
     try:
-        hardcoverClient = hardcover.HardcoverClient(current_user.hardcover_token)
+        hardcoverClient = hardcover.HardcoverClient(user.hardcover_token)
     except hardcover.MissingHardcoverToken:
-        log.info(f"User {current_user.name} has no Hardcover token, not syncing reading progress to Hardcover")
+        log.info(f"User {user.name} has no Hardcover token, not syncing reading progress to Hardcover")
         return
     except Exception as e:
-        log.error(f"Failed to create Hardcover client for user {current_user.name}: {e}")
+        log.error(f"Failed to create Hardcover client for user {user.name}: {e}")
         return
 
     try:
-        hardcoverClient.update_reading_progress(book.identifiers, request_bookmark["ProgressPercent"])
+        hardcoverClient.update_reading_progress(book.identifiers, progress_percentage)
     except Exception as e:
         log.error(f"Failed to update reading progress for book {book.id} in Hardcover: {e}")
 

cps/progress_syncing/protocols/kosync.py

@@ -40,6 +40,9 @@
 from datetime import datetime, timezone
 from typing import Dict, Optional, Any, Tuple
 
+from ...services import SyncToken as SyncToken, hardcover
+from ...kobo import push_reading_state_to_hardcover
+
 from flask import Blueprint, request, jsonify
 from flask_babel import gettext as _
 from werkzeug.security import check_password_hash
@@ -190,7 +193,7 @@ def authenticate_user() -> Optional[ub.User]:
         if login_result:
             log.info(f"authenticate_user: Successfully authenticated user via LDAP: {user.name}")
             return user
-        
+
         # Log LDAP failure but continue to local check (fallback)
         # We use debug level here because failure is expected if the user is using a local password
         if error:
@@ -326,7 +329,7 @@ def enrich_response_with_book_info(response_data: Dict[str, Any], document_check
     return response_data, book_id, book_format, book_title, checksum_version
 
 
-def update_book_read_status(user_id: int, book_id: int, percentage: float) -> None:
+def update_book_read_status(user, book_id: int, percentage: float) -> None:
     """
     Update the user's ReadBook status based on reading progress percentage.
 
@@ -360,6 +363,8 @@ def update_book_read_status(user_id: int, book_id: int, percentage: float) -> No
     else:
         new_status = ub.ReadBook.STATUS_UNREAD
 
+    user_id = user.id
+
     log.debug(f"update_book_read_status: user {user_id}, book {book_id}, "
               f"percentage {percentage:.2f}% -> status {new_status}")
 
@@ -717,10 +722,21 @@ def update_progress():
         # This is done AFTER kosync_progress is committed, so sync location is always safe
         if book_id:
             try:
-                update_book_read_status(user.id, book_id, percentage_float)
+                update_book_read_status(user, book_id, percentage_float)
                 ub.session.commit()
                 log.info(f"Updated ReadBook status: user={user.id}, book={book_id} "
                         f"({book_title}), status based on {percentage_float:.1f}%")
+
+                # Push to Hardcover
+                from ... import calibre_db
+                book = calibre_db.get_book(book_id)
+
+                if user is not None:
+                    log.debug(f"Going to sync book {book_id} to Hardcover.")
+                    push_reading_state_to_hardcover(user, book, int(percentage_float))
+                else:
+                    log.debug(f"Book {book_id} not syncing to Hardcover, no matched user.")
+
             except SQLAlchemyError as e:
                 log.error(f"Failed to update ReadBook status for book {book_id}: {e}")
                 # Rollback only affects the failed ReadBook update