Fix for added episodes and movies not being analyzed for existing subtitles or searched for missing.

bazarr/get_episodes.py

@@ -154,7 +154,7 @@ def sync_episodes():
         result = database.execute(
             '''INSERT OR IGNORE INTO table_episodes(''' + query.keys_insert + ''') VALUES(''' + query.question_marks +
             ''')''', query.values)
-        if result:
+        if result > 0:
             altered_episodes.append([added_episode['sonarrEpisodeId'], added_episode['path']])
         else:
             logging.debug('BAZARR unable to insert this episode into the database:',

bazarr/get_movies.py

@@ -238,7 +238,7 @@ def update_movies():
                 result = database.execute(
                     '''INSERT OR IGNORE INTO table_movies(''' + query.keys_insert + ''') VALUES(''' +
                     query.question_marks + ''')''', query.values)
-                if result:
+                if result > 0:
                     altered_movies.append([added_movie['tmdbId'],
                                            added_movie['path'],
                                            added_movie['radarrId'],

libs/sqlite3worker.py

@@ -137,7 +137,11 @@ class Sqlite3Worker(threading.Thread):
         else:
             try:
                 self.sqlite3_cursor.execute(query, values)
+                if query.lower().strip().startswith(("insert", "update")):
+                    self.results[token] = self.sqlite3_cursor.rowcount
             except sqlite3.Error as err:
+                self.results[token] = (
+                        "Query returned error: %s: %s: %s" % (query, values, err))
                 LOGGER.error(
                     "Query returned error: %s: %s: %s", query, values, err)
 
@@ -196,7 +200,7 @@ class Sqlite3Worker(threading.Thread):
         token = str(uuid.uuid4())
         # If it's a select we queue it up with a token to mark the results
         # into the output queue so we know what results are ours.
-        if query.lower().strip().startswith("select"):
+        if query.lower().strip().startswith(("select", "insert", "update")):
             self.sql_queue.put((token, query, values, only_one), timeout=5)
             return self.query_results(token)
         else: