Started on #483

PlexRequests.Store/Repository/BaseGenericRepository.cs

@@ -327,5 +327,22 @@ namespace PlexRequests.Store.Repository
                 throw;
             }
         }
+        public async Task DeleteAllAsync(string tableName)
+        {
+            try
+            {
+                ResetCache();
+                using (var db = Config.DbConnection())
+                {
+                    db.Open();
+                    await db.ExecuteAsync($"delete from {tableName}");
+                }
+            }
+            catch (SqliteException e) when (e.ErrorCode == SQLiteErrorCode.Corrupt)
+            {
+                Log.Fatal(CorruptMessage);
+                throw;
+            }
+        }
     }
 }

PlexRequests.Store/Repository/IRepository.cs

@@ -85,5 +85,6 @@ namespace PlexRequests.Store.Repository
         IEnumerable<T> Custom(Func<IDbConnection, IEnumerable<T>> func);
         Task<IEnumerable<T>> CustomAsync(Func<IDbConnection, Task<IEnumerable<T>>> func);
         void DeleteAll(string tableName);
+        Task DeleteAllAsync(string tableName);
     }
 }