fix a few issues and refresh db connection func

Author: Rajdave69

pybpsapi.py

@@ -141,7 +141,8 @@ def __init__(self, category, url: str = "https://bpsapi.rajtech.me/v1/", cache_m
                 self._con = sqlite3.connect(self.db_path + f"/{self.db_name}.db")
                 self._cur = self._con.cursor()
 
-                self._cur.execute("CREATE TABLE IF NOT EXISTS ? (title TEXT, category TEXT, data BLOB)", (self.db_table,))
+                self._cur.execute("CREATE TABLE IF NOT EXISTS ? (title TEXT, category TEXT, data BLOB)",
+                                  (self.db_table,))
                 self._cur.execute("INSERT INTO ? VALUES (?, ?, ?)",
                                   (self.db_table, "circular_list", self.category, pickle.dumps([])))
                 self._con.commit()
@@ -167,11 +168,18 @@ def __init__(self, category, url: str = "https://bpsapi.rajtech.me/v1/", cache_m
             else:
                 raise ValueError("Invalid Cache Method")
 
-        else:
-            pass
+    def refresh_db_con(self):
+        if not self.cache_method == "database":
+            return
+
+        import sqlite3
+
+        self._con = sqlite3.connect(self.db_path + f"/{self.db_name}.db")
+        self._cur = self._con.cursor()
 
     def get_cache(self) -> list[list]:
         if self.cache_method == "database":
+            self.refresh_db_con()
             self._cur.execute("SELECT * FROM ? WHERE category = ?", (self.db_table, self.category))
             res = self._cur.fetchone()
             if res is None:
@@ -189,8 +197,10 @@ def get_cache(self) -> list[list]:
 
     def _set_cache(self, data, title: str = "circular_list"):
         if self.cache_method == "database":
+            self.refresh_db_con()
             self._cur.execute("DELETE FROM ? WHERE category = ?", (self.db_table, self.category,))
-            self._cur.execute("INSERT INTO ? VALUES (?, ?, ?)", (self.db_table, title, self.category, pickle.dumps(data)))
+            self._cur.execute("INSERT INTO ? VALUES (?, ?, ?)",
+                              (self.db_table, title, self.category, pickle.dumps(data)))
             self._con.commit()
 
         elif self.cache_method == "pickle":
@@ -203,10 +213,12 @@ def _set_cache(self, data, title: str = "circular_list"):
     def _refresh_cache(self):
         request = requests.get(self.url + "list", params=self._params)
         json = request.json()
+
         try:
             json['http_status']
         except KeyError:
             raise ValueError("Invalid API Response")
+
         if json['http_status'] == 200:
             self._set_cache(json['data'])
 
@@ -237,13 +249,10 @@ def check(self) -> list[dict] or list[None]:
 
 
 class CircularCheckerGroup:
-    def __init__(self, *args, **kwargs):
+    def __init__(self, *args, debug: bool = False):
         self._checkers = []
 
-        if kwargs.get("debug"):
-            self.debug = True
-        else:
-            self.debug = False
+        self.debug = debug
 
         for arg in args:
             if type(arg) != CircularChecker:
@@ -260,7 +269,8 @@ def add(self, checker: CircularChecker, *args: CircularChecker):
                 raise ValueError("Invalid CircularChecker Object")
             self._checkers.append(arg)
 
-    def create(self, category, url: str = "https://bpsapi.rajtech.me/v1/", cache_method=None, debug: bool = False, **kwargs):
+    def create(self, category, url: str = "https://bpsapi.rajtech.me/v1/", cache_method=None, debug: bool = False,
+               **kwargs):
         checker = CircularChecker(category, url, cache_method, debug, **kwargs)
         self._checkers.append(checker)