mirror of
https://github.com/ajayyy/SponsorBlockServer.git
synced 2025-12-16 08:26:59 +03:00
@@ -37,6 +37,7 @@ import {getLockCategories} from "./routes/getLockCategories";
|
|||||||
import {getLockCategoriesByHash} from "./routes/getLockCategoriesByHash";
|
import {getLockCategoriesByHash} from "./routes/getLockCategoriesByHash";
|
||||||
import {endpoint as getSearchSegments } from "./routes/getSearchSegments";
|
import {endpoint as getSearchSegments } from "./routes/getSearchSegments";
|
||||||
import {getStatus } from "./routes/getStatus";
|
import {getStatus } from "./routes/getStatus";
|
||||||
|
import { getLockReason } from "./routes/getLockReason";
|
||||||
import {getUserStats} from "./routes/getUserStats";
|
import {getUserStats} from "./routes/getUserStats";
|
||||||
import ExpressPromiseRouter from "express-promise-router";
|
import ExpressPromiseRouter from "express-promise-router";
|
||||||
import { Server } from "http";
|
import { Server } from "http";
|
||||||
@@ -179,6 +180,8 @@ function setupRoutes(router: Router) {
|
|||||||
// get user category stats
|
// get user category stats
|
||||||
router.get("/api/userStats", getUserStats);
|
router.get("/api/userStats", getUserStats);
|
||||||
|
|
||||||
|
router.get("/api/lockReason", getLockReason);
|
||||||
|
|
||||||
if (config.postgres) {
|
if (config.postgres) {
|
||||||
router.get("/database", (req, res) => dumpDatabase(req, res, true));
|
router.get("/database", (req, res) => dumpDatabase(req, res, true));
|
||||||
router.get("/database.json", (req, res) => dumpDatabase(req, res, false));
|
router.get("/database.json", (req, res) => dumpDatabase(req, res, false));
|
||||||
|
|||||||
70
src/routes/getLockReason.ts
Normal file
70
src/routes/getLockReason.ts
Normal file
@@ -0,0 +1,70 @@
|
|||||||
|
import {db} from "../databases/databases";
|
||||||
|
import {Logger} from "../utils/logger";
|
||||||
|
import {Request, Response} from "express";
|
||||||
|
import { Category, VideoID } from "../types/segments.model";
|
||||||
|
import {config} from "../config";
|
||||||
|
|
||||||
|
const possibleCategoryList = config.categoryList;
|
||||||
|
interface lockArray {
|
||||||
|
category: Category;
|
||||||
|
locked: number,
|
||||||
|
reason: string
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function getLockReason(req: Request, res: Response): Promise<Response> {
|
||||||
|
const videoID = req.query.videoID as VideoID;
|
||||||
|
let categories: Category[] = [];
|
||||||
|
try {
|
||||||
|
categories = req.query.categories
|
||||||
|
? JSON.parse(req.query.categories as string)
|
||||||
|
: req.query.category
|
||||||
|
? Array.isArray(req.query.category)
|
||||||
|
? req.query.category
|
||||||
|
: [req.query.category]
|
||||||
|
: []; // default to empty, will be set to all
|
||||||
|
if (!Array.isArray(categories)) {
|
||||||
|
return res.status(400).send("Categories parameter does not match format requirements.");
|
||||||
|
}
|
||||||
|
} catch(error) {
|
||||||
|
return res.status(400).send("Bad parameter: categories (invalid JSON)");
|
||||||
|
}
|
||||||
|
// only take valid categories
|
||||||
|
const searchCategories = (categories.length === 0 ) ? possibleCategoryList : categories.filter(x => possibleCategoryList.includes(x));
|
||||||
|
|
||||||
|
if (videoID == undefined) {
|
||||||
|
//invalid request
|
||||||
|
return res.sendStatus(400);
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Get existing lock categories markers
|
||||||
|
const row = await db.prepare("all", 'SELECT "category", "reason" from "lockCategories" where "videoID" = ?', [videoID]) as {category: Category, reason: string}[];
|
||||||
|
// map to object array
|
||||||
|
const locks = [];
|
||||||
|
const lockedCategories = [] as string[];
|
||||||
|
// get all locks for video, check if requested later
|
||||||
|
for (const lock of row) {
|
||||||
|
locks.push({
|
||||||
|
category: lock.category,
|
||||||
|
locked: 1,
|
||||||
|
reason: lock.reason
|
||||||
|
} as lockArray);
|
||||||
|
lockedCategories.push(lock.category);
|
||||||
|
}
|
||||||
|
// add empty locks for categories requested but not locked
|
||||||
|
const noLockCategories = searchCategories.filter(x => !lockedCategories.includes(x));
|
||||||
|
for (const noLock of noLockCategories) {
|
||||||
|
locks.push({
|
||||||
|
category: noLock,
|
||||||
|
locked: 0,
|
||||||
|
reason: ""
|
||||||
|
} as lockArray);
|
||||||
|
}
|
||||||
|
// return real and fake locks that were requested
|
||||||
|
const filtered = locks.filter(lock => searchCategories.includes(lock.category));
|
||||||
|
return res.send(filtered);
|
||||||
|
} catch (err) {
|
||||||
|
Logger.error(err as string);
|
||||||
|
return res.sendStatus(500);
|
||||||
|
}
|
||||||
|
}
|
||||||
119
test/cases/getLockReason.ts
Normal file
119
test/cases/getLockReason.ts
Normal file
@@ -0,0 +1,119 @@
|
|||||||
|
import fetch from "node-fetch";
|
||||||
|
import {Done, getbaseURL} from "../utils";
|
||||||
|
import {getHash} from "../../src/utils/getHash";
|
||||||
|
import {db} from "../../src/databases/databases";
|
||||||
|
import assert from "assert";
|
||||||
|
|
||||||
|
const endpoint = `${getbaseURL()}/api/lockReason`;
|
||||||
|
|
||||||
|
describe("getLockReason", () => {
|
||||||
|
before(async () => {
|
||||||
|
const vipUserID = "getLockReasonVIP";
|
||||||
|
const vipUserHash = getHash(vipUserID);
|
||||||
|
const insertVipUserQuery = 'INSERT INTO "vipUsers" ("userID") VALUES (?)';
|
||||||
|
await db.prepare("run", insertVipUserQuery, [vipUserHash]);
|
||||||
|
await db.prepare("run", insertVipUserQuery, [vipUserHash]);
|
||||||
|
|
||||||
|
const insertLockCategoryQuery = 'INSERT INTO "lockCategories" ("userID", "videoID", "category", "reason") VALUES (?, ?, ?, ?)';
|
||||||
|
await db.prepare("run", insertLockCategoryQuery, [vipUserHash, "getLockReason", "sponsor", "sponsor-reason"]);
|
||||||
|
await db.prepare("run", insertLockCategoryQuery, [vipUserHash, "getLockReason", "interaction", "interaction-reason"]);
|
||||||
|
await db.prepare("run", insertLockCategoryQuery, [vipUserHash, "getLockReason", "preview", "preview-reason"]);
|
||||||
|
await db.prepare("run", insertLockCategoryQuery, [vipUserHash, "getLockReason", "music_offtopic", "nonmusic-reason"]);
|
||||||
|
});
|
||||||
|
|
||||||
|
it("Should update the database version when starting the application", async () => {
|
||||||
|
const version = (await db.prepare("get", "SELECT key, value FROM config where key = ?", ["version"])).value;
|
||||||
|
if (version > 20) return;
|
||||||
|
else return `Version isn't greater than 20. Version is ${version}`;
|
||||||
|
});
|
||||||
|
|
||||||
|
it("Should be able to get single reason", (done: Done) => {
|
||||||
|
fetch(`${endpoint}?videoID=getLockReason&category=sponsor`)
|
||||||
|
.then(async res => {
|
||||||
|
assert.strictEqual(res.status, 200);
|
||||||
|
const data = await res.json();
|
||||||
|
const expected = [
|
||||||
|
{ category: "sponsor", locked: 1, reason: "sponsor-reason" }
|
||||||
|
];
|
||||||
|
assert.deepStrictEqual(data, expected);
|
||||||
|
done();
|
||||||
|
})
|
||||||
|
.catch(err => done(err));
|
||||||
|
});
|
||||||
|
|
||||||
|
it("Should be able to get empty locks", (done: Done) => {
|
||||||
|
fetch(`${endpoint}?videoID=getLockReason&category=intro`)
|
||||||
|
.then(async res => {
|
||||||
|
assert.strictEqual(res.status, 200);
|
||||||
|
const data = await res.json();
|
||||||
|
const expected = [
|
||||||
|
{ category: "intro", locked: 0, reason: "" }
|
||||||
|
];
|
||||||
|
assert.deepStrictEqual(data, expected);
|
||||||
|
done();
|
||||||
|
})
|
||||||
|
.catch(err => done(err));
|
||||||
|
});
|
||||||
|
|
||||||
|
it("should get multiple locks with array", (done: Done) => {
|
||||||
|
fetch(`${endpoint}?videoID=getLockReason&categories=["intro","sponsor"]`)
|
||||||
|
.then(async res => {
|
||||||
|
assert.strictEqual(res.status, 200);
|
||||||
|
const data = await res.json();
|
||||||
|
const expected = [
|
||||||
|
{ category: "sponsor", locked: 1, reason: "sponsor-reason" },
|
||||||
|
{ category: "intro", locked: 0, reason: ""}
|
||||||
|
];
|
||||||
|
assert.deepStrictEqual(data, expected);
|
||||||
|
done();
|
||||||
|
})
|
||||||
|
.catch(err => done(err));
|
||||||
|
});
|
||||||
|
|
||||||
|
it("should get multiple locks with repeated category", (done: Done) => {
|
||||||
|
fetch(`${endpoint}?videoID=getLockReason&category=interaction&category=music_offtopic&category=intro`)
|
||||||
|
.then(async res => {
|
||||||
|
assert.strictEqual(res.status, 200);
|
||||||
|
const data = await res.json();
|
||||||
|
const expected = [
|
||||||
|
{ category: "interaction", locked: 1, reason: "interaction-reason" },
|
||||||
|
{ category: "music_offtopic", locked: 1, reason: "nonmusic-reason" },
|
||||||
|
{ category: "intro", locked: 0, reason: "" }
|
||||||
|
];
|
||||||
|
assert.deepStrictEqual(data, expected);
|
||||||
|
done();
|
||||||
|
})
|
||||||
|
.catch(err => done(err));
|
||||||
|
});
|
||||||
|
|
||||||
|
it("should return all categories if none specified", (done: Done) => {
|
||||||
|
fetch(`${endpoint}?videoID=getLockReason`)
|
||||||
|
.then(async res => {
|
||||||
|
assert.strictEqual(res.status, 200);
|
||||||
|
const data = await res.json();
|
||||||
|
console.log(data);
|
||||||
|
const expected = [
|
||||||
|
{ category: "sponsor", locked: 1, reason: "sponsor-reason" },
|
||||||
|
{ category: "interaction", locked: 1, reason: "interaction-reason" },
|
||||||
|
{ category: "preview", locked: 1, reason: "preview-reason" },
|
||||||
|
{ category: "music_offtopic", locked: 1, reason: "nonmusic-reason" },
|
||||||
|
{ category: "selfpromo", locked: 0, reason: "" },
|
||||||
|
{ category: "intro", locked: 0, reason: "" },
|
||||||
|
{ category: "outro", locked: 0, reason: "" },
|
||||||
|
{ category: "poi_highlight", locked: 0, reason: "" }
|
||||||
|
];
|
||||||
|
assert.deepStrictEqual(data, expected);
|
||||||
|
done();
|
||||||
|
})
|
||||||
|
.catch(err => done(err));
|
||||||
|
});
|
||||||
|
|
||||||
|
it("should return 400 if no videoID specified", (done: Done) => {
|
||||||
|
fetch(endpoint)
|
||||||
|
.then(res => {
|
||||||
|
assert.strictEqual(res.status, 400);
|
||||||
|
done();
|
||||||
|
})
|
||||||
|
.catch(err => done(err));
|
||||||
|
});
|
||||||
|
});
|
||||||
Reference in New Issue
Block a user