Mirror/SponsorBlockServer
1
0
Fork 0
mirror of https://github.com/ajayyy/SponsorBlockServer.git synced 2025-12-11 14:07:09 +03:00
Code Issues Packages Projects Releases Wiki Activity

routes/deleteLockCategories: Run Queries in Parallel

Browse Source
This commit is contained in:
Nishant Arora
2021-10-22 00:17:43 -06:00
parent 28dc0fb512
commit 05072f5d22
1 changed files with 39 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

61
src/routes/deleteLockCategories.ts
View File

@@ -6,19 +6,32 @@ import { Category, Service, VideoID } from "../types/segments.model";
import { UserID } from "../types/user.model"; import { UserID } from "../types/user.model";
import { getService } from "../utils/getService"; import { getService } from "../utils/getService";
export async function deleteLockCategoriesEndpoint(req: Request, res: Response): Promise<Response> { interface DeleteLockCategoriesRequest extends Request {
body: {
categories: Category[];
service: string;
userID: UserID;
videoID: VideoID;
};
}
export async function deleteLockCategoriesEndpoint(req: DeleteLockCategoriesRequest, res: Response): Promise<Response> {
// Collect user input data // Collect user input data
const videoID = req.body.videoID as VideoID; const {
const userID = req.body.userID as UserID; body: {
const categories = req.body.categories as Category[]; videoID,
const service = getService(req.body.service); userID,
categories,
service
}
} = req;
// Check input data is valid // Check input data is valid
if (!videoID if (!videoID ||
|| !userID !userID ||
|| !categories !categories ||
|| !Array.isArray(categories) !Array.isArray(categories) ||
|| categories.length === 0 categories.length === 0
) { ) {
return res.status(400).json({ return res.status(400).json({
message: "Bad Format", message: "Bad Format",
@@ -35,9 +48,9 @@ export async function deleteLockCategoriesEndpoint(req: Request, res: Response):
}); });
} }
await deleteLockCategories(videoID, categories, service); await deleteLockCategories(videoID, categories, getService(service));
return res.status(200).json({ message: `Removed lock categories entrys for video ${videoID}` }); return res.status(200).json({ message: `Removed lock categories entries for video ${videoID}` });
} }
/** /**
@@ -47,17 +60,21 @@ export async function deleteLockCategoriesEndpoint(req: Request, res: Response):
* @param service * @param service
*/ */
export async function deleteLockCategories(videoID: VideoID, categories: Category[], service: Service): Promise<void> { export async function deleteLockCategories(videoID: VideoID, categories: Category[], service: Service): Promise<void> {
const entries = ( type DBEntry = { category: Category };
await db.prepare("all", 'SELECT * FROM "lockCategories" WHERE "videoID" = ? AND "service" = ?', [videoID, service])) const dbEntries = await db.prepare(
.filter((entry: any) => { "all",
return categories === null || categories.indexOf(entry.category) !== -1; 'SELECT * FROM "lockCategories" WHERE "videoID" = ? AND "service" = ?',
}); [videoID, service]
) as Array<DBEntry>;
for (const entry of entries) { const entries = dbEntries.filter(
await db.prepare( ({ category }: DBEntry) => categories === null || categories.indexOf(category) !== -1);
await Promise.all(
entries.map(({ category }: DBEntry) => db.prepare(
"run", "run",
'DELETE FROM "lockCategories" WHERE "videoID" = ? AND "service" = ? AND "category" = ?', 'DELETE FROM "lockCategories" WHERE "videoID" = ? AND "service" = ? AND "category" = ?',
[videoID, service, entry.category] [videoID, service, category]
); ))
} );
} }