[patch] Added handling of malformed db files

qBitrr/arss.py

@@ -3015,6 +3015,20 @@ def run_request_search(self):
                 except NoConnectionrException as e:
                     self.logger.error(e.message)
                     raise DelayLoopException(length=300, type=e.type)
+                except peewee.DatabaseError as e:
+                    self.logger.error(e.message)
+                    included_extensions = ['db','db-shm', 'db-wal']
+                    relevant_path = "/config"
+                    file_names = [fn for fn in os.listdir(relevant_path) if any(fn.endswith(ext) for ext in included_extensions)]
+                    for f in file_names:
+                        os.remove(relevant_path+f)
+                    relevant_path_2 = "/config"
+                    file_names_2 = [fn for fn in os.listdir(relevant_path) if any(fn.endswith(ext) for ext in included_extensions)]
+                    for f_2 in file_names_2:
+                        os.remove(relevant_path_2+f_2)
+                    cmd = "docker restart qbitrr"
+                    os.system(cmd)
+                    raise DelayLoopException(length=300, type=e.type)
                 except DelayLoopException:
                     raise
                 except Exception as e:
@@ -3095,6 +3109,20 @@ def run_search_loop(self) -> NoReturn:
                         self.logger.error(e.message)
                         self.manager.qbit_manager.should_delay_torrent_scan = True
                         raise DelayLoopException(length=300, type=e.type)
+                    except peewee.DatabaseError as e:
+                        self.logger.error(e.message)
+                        included_extensions = ['db','db-shm', 'db-wal']
+                        relevant_path = "/config"
+                        file_names = [fn for fn in os.listdir(relevant_path) if any(fn.endswith(ext) for ext in included_extensions)]
+                        for f in file_names:
+                            os.remove(relevant_path+f)
+                        relevant_path_2 = "/config"
+                        file_names_2 = [fn for fn in os.listdir(relevant_path) if any(fn.endswith(ext) for ext in included_extensions)]
+                        for f_2 in file_names_2:
+                            os.remove(relevant_path_2+f_2)
+                        cmd = "docker restart qbitrr"
+                        os.system(cmd)
+                        raise DelayLoopException(length=300, type=e.type)
                     except DelayLoopException:
                         raise
                     except ValueError: