Add purge all segments of VideoId

src/app.ts

@@ -31,6 +31,7 @@ import dumpDatabase, {redirectLink} from './routes/dumpDatabase';
 import {endpoint as getSegmentInfo} from './routes/getSegmentInfo';
 import {postClearCache} from './routes/postClearCache';
 import { addUnlistedVideo } from './routes/addUnlistedVideo';
+import {postPurgeAllSegments} from './routes/postPurgeAllSegments';
 
 export function createServer(callback: () => void) {
     // Create a service (the app object is just a callback).
@@ -139,7 +140,7 @@ function setupRoutes(app: Express) {
     app.get('/api/segmentInfo', getSegmentInfo);
 
     //clear cache as VIP
-    app.post('/api/clearCache', postClearCache)
+    app.post('/api/clearCache', postClearCache);
 
     app.post('/api/unlistedVideo', addUnlistedVideo)
 
@@ -152,4 +153,7 @@ function setupRoutes(app: Express) {
             res.sendFile("./databases/sponsorTimes.db", {root: "./"});
         });
     }
+
+    //purge all segments for VIP
+    app.post('/api/purgeAllSegments', postPurgeAllSegments);
 }

src/routes/postPurgeAllSegments.ts

@@ -0,0 +1,41 @@
+import {Logger} from '../utils/logger';
+import {getHash} from '../utils/getHash';
+import {isUserVIP} from '../utils/isUserVIP';
+import {Request, Response} from 'express';
+import {HashedUserID, UserID} from '../types/user.model';
+import {VideoID} from "../types/segments.model";
+import {db} from '../databases/databases';
+
+export async function postPurgeAllSegments(req: Request, res: Response): Promise<void> {
+    const userID = req.body.userID as UserID;
+    const videoID = req.body.videoID as VideoID;
+
+    if (userID == undefined) {
+        //invalid request
+        res.sendStatus(400);
+        return;
+    }
+
+    //hash the userID
+    const hashedUserID: HashedUserID = getHash(userID);
+
+    try {
+        let vipState = await isUserVIP(hashedUserID);
+        if (!vipState) {
+            res.status(403).json({
+                message: 'Must be a VIP to perform this action.',
+            });
+            return;
+        }
+
+        await db.prepare('run', `UPDATE "sponsorTimes" SET "hidden" = 1 WHERE "videoID" = ?`, [videoID]);
+    
+    } catch (err) {
+        Logger.error(err);
+        res.sendStatus(500);
+
+        return;
+    }
+
+    res.sendStatus(200);
+}