Add bulk delete, bulk archive/unarchive, and bulk metadata edit buttons in books table page

cps/editbooks.py

@@ -214,6 +214,76 @@ def table_get_custom_enum(c_id):
 @edit_required
 def edit_list_book(param):
     vals = request.form.to_dict()
+    return edit_book_param(param, vals)
+
+@editbook.route("/ajax/editselectedbooks", methods=['POST'])
+@login_required_if_no_ano
+@edit_required
+def edit_selected_books():
+    d = request.get_json()
+    selections = d.get('selections')
+    title = d.get('title')
+    title_sort = d.get('title_sort')
+    author_sort = d.get('author_sort')
+    authors = d.get('authors')
+    categories = d.get('categories')
+    series = d.get('series')
+    languages = d.get('languages')
+    publishers = d.get('publishers')
+    comments = d.get('comments')
+    checkA = d.get('checkA')
+
+    if len(selections) != 0:
+        for book_id in selections:
+            vals = {
+                "pk": book_id,
+                "value": None,
+                "checkA": checkA,
+            }
+            if title:
+                vals['value'] = title
+                edit_book_param('title', vals)
+            if title_sort:
+                vals['value'] = title_sort
+                edit_book_param('sort', vals)
+            if author_sort:
+                vals['value'] = author_sort
+                edit_book_param('author_sort', vals)
+            if authors:
+                vals['value'] = authors
+                edit_book_param('authors', vals)
+            if categories:
+                vals['value'] = categories
+                edit_book_param('tags', vals)
+            if series:
+                vals['value'] = series
+                edit_book_param('series', vals)
+            if languages:
+                vals['value'] = languages
+                edit_book_param('languages', vals)
+            if publishers:
+                vals['value'] = publishers
+                edit_book_param('publishers', vals)
+            if comments:
+                vals['value'] = comments
+                edit_book_param('comments', vals)
+        return json.dumps({'success': True})
+    return ""
+
+# Separated from /editbooks so that /editselectedbooks can also use this
+#
+# param: the property of the book to be changed
+# vals - JSON Object:
+#   { 
+#       'pk': "the book id",
+#       'value': "changes value of param to what's passed here"
+#       'checkA': "Optional. Used to check if autosort author is enabled. Assumed as true if not passed"
+#       'checkT': "Optional. Used to check if autotitle author is enabled. Assumed as true if not passed"
+#   }
+#
+@login_required_if_no_ano
+@edit_required
+def edit_book_param(param, vals):
     book = calibre_db.get_book(vals['pk'])
     sort_param = ""
     ret = ""
@@ -336,7 +406,6 @@ def get_sorted_entry(field, bookid):
                 return json.dumps({'authors': " & ".join([a.name for a in calibre_db.order_authors([book])])})
     return ""
 
-
 @editbook.route("/ajax/simulatemerge", methods=['POST'])
 @user_login_required
 @edit_required
@@ -352,6 +421,64 @@ def simulate_merge_list_book():
             return json.dumps({'to': to_book, 'from': from_book})
     return ""
 
+@editbook.route("/ajax/displayselectedbooks", methods=['POST'])
+@user_login_required
+@edit_required
+def display_selected_books():
+    vals = request.get_json().get('selections')
+    books = []
+    if vals:
+        for book_id in vals:
+            books.append(calibre_db.get_book(book_id).title)
+        return json.dumps({'books': books})
+    return ""
+
+@editbook.route("/ajax/archiveselectedbooks", methods=['POST'])
+@login_required_if_no_ano
+@edit_required
+def archive_selected_books():
+    vals = request.get_json().get('selections')
+    state = request.get_json().get('archive')
+    if vals:
+        for book_id in vals:
+            is_archived = change_archived_books(book_id, state,
+                                                message="Book {} archive bit set to: {}".format(book_id, state))
+            if is_archived:
+                kobo_sync_status.remove_synced_book(book_id)
+        return json.dumps({'success': True})
+    return ""
+
+@editbook.route("/ajax/deleteselectedbooks", methods=['POST'])
+@user_login_required
+@edit_required
+def delete_selected_books():
+    vals = request.get_json().get('selections')
+    if vals:
+        for book_id in vals:
+            delete_book_from_table(book_id, "", True)
+        return json.dumps({'success': True})
+    return ""
+
+@editbook.route("/ajax/readselectedbooks", methods=['POST'])
+@user_login_required
+@edit_required
+def read_selected_books():
+    vals = request.get_json().get('selections')
+    markAsRead = request.get_json().get('markAsRead')
+    if vals:
+        try:
+            for book_id in vals:
+                ret = helper.edit_book_read_status(book_id, markAsRead)
+
+        except (OperationalError, IntegrityError, StaleDataError) as e:
+            calibre_db.session.rollback()
+            log.error_or_exception("Database error: {}".format(e))
+            ret = Response(json.dumps({'success': False,
+                    'msg': 'Database error: {}'.format(e.orig if hasattr(e, "orig") else e)}),
+                    mimetype='application/json')
+
+        return json.dumps({'success': True})
+    return ""
 
 @editbook.route("/ajax/mergebooks", methods=['POST'])
 @user_login_required

cps/helper.py

@@ -314,7 +314,7 @@ def edit_book_read_status(book_id, read_status=None):
                 else:
                     book.read_status = ub.ReadBook.STATUS_FINISHED
             else:
-                book.read_status = ub.ReadBook.STATUS_FINISHED if read_status else ub.ReadBook.STATUS_UNREAD
+                book.read_status = ub.ReadBook.STATUS_FINISHED if read_status == True else ub.ReadBook.STATUS_UNREAD
         else:
             read_book = ub.ReadBook(user_id=current_user.id, book_id=book_id)
             read_book.read_status = ub.ReadBook.STATUS_FINISHED

cps/kobo_sync_status.py

@@ -51,13 +51,15 @@ def remove_synced_book(book_id, all=False, session=None):
         ub.session_commit(_session=session)
 
 
+# If state == none, it will toggle the archive state of the passed book_id. 
+# state = true archives it, state = false unarchives it
 def change_archived_books(book_id, state=None, message=None):
     archived_book = ub.session.query(ub.ArchivedBook).filter(and_(ub.ArchivedBook.user_id == int(current_user.id),
                                                                   ub.ArchivedBook.book_id == book_id)).first()
-    if not archived_book:
+    if not archived_book and (state == True or state == None):
         archived_book = ub.ArchivedBook(user_id=current_user.id, book_id=book_id)
 
-    archived_book.is_archived = state if state else not archived_book.is_archived
+    archived_book.is_archived = state if state != None else not archived_book.is_archived
     archived_book.last_modified = datetime.now(timezone.utc)        # toDo. Check utc timestamp
 
     ub.session.merge(archived_book)