mirror of
https://github.com/ajayyy/SponsorBlockServer.git
synced 2025-12-10 13:37:01 +03:00
add explit param
This commit is contained in:
@@ -1,37 +1,55 @@
|
|||||||
import {db} from '../databases/databases';
|
import {db} from '../databases/databases';
|
||||||
import {Logger} from '../utils/logger';
|
|
||||||
import {Request, Response} from 'express';
|
import {Request, Response} from 'express';
|
||||||
|
import {UserID} from '../types/user.model';
|
||||||
|
|
||||||
export async function getUserID(req: Request, res: Response) {
|
function getFuzzyUserID(userName: String): Promise<[{userName: String, userID: UserID }]> {
|
||||||
let userName = req.query.username as string;
|
|
||||||
|
|
||||||
if (userName == undefined || userName.length > 64 || userName.length < 3) {
|
|
||||||
//invalid request
|
|
||||||
res.sendStatus(400);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// escape [_ % \] to avoid ReDOS
|
// escape [_ % \] to avoid ReDOS
|
||||||
userName = userName.replace(/\\/g, '\\\\')
|
userName = userName.replace(/\\/g, '\\\\')
|
||||||
.replace(/_/g, '\\_')
|
.replace(/_/g, '\\_')
|
||||||
.replace(/%/g, '\\%');
|
.replace(/%/g, '\\%');
|
||||||
|
userName = `%${userName}%`; // add wildcard to username
|
||||||
// add wildcard to variable
|
// LIMIT to reduce overhead | ESCAPE to escape LIKE wildcards
|
||||||
userName = `%${userName}%`;
|
|
||||||
// LIMIT to reduce overhead
|
|
||||||
// ESCAPE to escape LIKE wildcards
|
|
||||||
try {
|
try {
|
||||||
let rows = await db.prepare('all', `SELECT "userName", "userID" FROM "userNames"
|
return db.prepare('all', `SELECT "userName", "userID" FROM "userNames" WHERE "userName"
|
||||||
WHERE "userName" LIKE ? ESCAPE '\\' LIMIT 10`, [userName]);
|
LIKE ? ESCAPE '\\' LIMIT 10`, [userName])
|
||||||
if (rows.length === 0) {
|
|
||||||
res.sendStatus(404);
|
|
||||||
return;
|
|
||||||
} else {
|
|
||||||
res.send(rows);
|
|
||||||
}
|
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
Logger.error(err);
|
return null;
|
||||||
res.sendStatus(500);
|
}
|
||||||
return;
|
}
|
||||||
|
|
||||||
|
function getExactUserID(userName: String): Promise<[{userName: String, userID: UserID }]> {
|
||||||
|
try {
|
||||||
|
return db.prepare('all', `SELECT "userName", "userID" from "userNames" WHERE "userName" = ? LIMIT 10`, [userName]);
|
||||||
|
} catch (err) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function getUserID(req: Request, res: Response) {
|
||||||
|
let userName = req.query.username as string;
|
||||||
|
const exactSearch = req.query.exact
|
||||||
|
? req.query.exact == "true"
|
||||||
|
: false as Boolean;
|
||||||
|
|
||||||
|
// if not exact and length is 1, also skip
|
||||||
|
if (userName == undefined || userName.length > 64 ||
|
||||||
|
(!exactSearch && userName.length < 3)) {
|
||||||
|
// invalid request
|
||||||
|
res.sendStatus(400);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
const results = exactSearch
|
||||||
|
? await getExactUserID(userName)
|
||||||
|
: await getFuzzyUserID(userName);
|
||||||
|
|
||||||
|
if (results === undefined || results === null) {
|
||||||
|
res.sendStatus(500);
|
||||||
|
return false;
|
||||||
|
} else if (results.length as number === 0) {
|
||||||
|
res.sendStatus(404);
|
||||||
|
return false;
|
||||||
|
} else {
|
||||||
|
res.send(results);
|
||||||
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -17,6 +17,7 @@ describe('getUserID', () => {
|
|||||||
await db.prepare("run", insertUserNameQuery, [getHash("getuserid_user_09"), '_redos_']);
|
await db.prepare("run", insertUserNameQuery, [getHash("getuserid_user_09"), '_redos_']);
|
||||||
await db.prepare("run", insertUserNameQuery, [getHash("getuserid_user_10"), 'redos\\%']);
|
await db.prepare("run", insertUserNameQuery, [getHash("getuserid_user_10"), 'redos\\%']);
|
||||||
await db.prepare("run", insertUserNameQuery, [getHash("getuserid_user_11"), '\\\\\\']);
|
await db.prepare("run", insertUserNameQuery, [getHash("getuserid_user_11"), '\\\\\\']);
|
||||||
|
await db.prepare("run", insertUserNameQuery, [getHash("getuserid_user_12"), 'a']);
|
||||||
});
|
});
|
||||||
|
|
||||||
it('Should be able to get a 200', (done: Done) => {
|
it('Should be able to get a 200', (done: Done) => {
|
||||||
@@ -201,6 +202,31 @@ describe('getUserID', () => {
|
|||||||
.catch(err => ("couldn't call endpoint"));
|
.catch(err => ("couldn't call endpoint"));
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it('Should be able to get repeating fuzzy username', (done: Done) => {
|
||||||
|
fetch(getbaseURL() + '/api/userID?username=peat')
|
||||||
|
.then(async res => {
|
||||||
|
if (res.status !== 200) {
|
||||||
|
done("non 200");
|
||||||
|
} else {
|
||||||
|
const data = await res.json();
|
||||||
|
if (data.length !== 2) {
|
||||||
|
done('Returned incorrect number of users "' + data.length + '"');
|
||||||
|
} else if (data[0].userName !== "repeating") {
|
||||||
|
done('Returned incorrect username "' + data.userName + '"');
|
||||||
|
} else if (data[0].userID !== getHash("getuserid_user_04")) {
|
||||||
|
done('Returned incorrect userID "' + data.userID + '"');
|
||||||
|
} else if (data[1].userName !== "repeating") {
|
||||||
|
done('Returned incorrect username "' + data.userName + '"');
|
||||||
|
} else if (data[1].userID !== getHash("getuserid_user_05")) {
|
||||||
|
done('Returned incorrect userID "' + data.userID + '"');
|
||||||
|
} else {
|
||||||
|
done(); // pass
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.catch(err => ("couldn't call endpoint"));
|
||||||
|
});
|
||||||
|
|
||||||
it('should avoid ReDOS with _', (done: Done) => {
|
it('should avoid ReDOS with _', (done: Done) => {
|
||||||
fetch(getbaseURL() + '/api/userID?username=_redos_')
|
fetch(getbaseURL() + '/api/userID?username=_redos_')
|
||||||
.then(async res => {
|
.then(async res => {
|
||||||
@@ -299,4 +325,79 @@ describe('getUserID', () => {
|
|||||||
})
|
})
|
||||||
.catch(err => ("couldn't call endpoint"));
|
.catch(err => ("couldn't call endpoint"));
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it('should allow exact match', (done: Done) => {
|
||||||
|
fetch(getbaseURL() + '/api/userID?username=a&exact=true')
|
||||||
|
.then(async res => {
|
||||||
|
if (res.status !== 200) {
|
||||||
|
done("non 200");
|
||||||
|
} else {
|
||||||
|
const data = await res.json();
|
||||||
|
if (data.length !== 1) {
|
||||||
|
done('Returned incorrect number of users "' + data.length + '"');
|
||||||
|
} else if (data[0].userName !== "a") {
|
||||||
|
done('Returned incorrect username "' + data.userName + '"');
|
||||||
|
} else if (data[0].userID !== getHash("getuserid_user_12")) {
|
||||||
|
done('Returned incorrect userID "' + data.userID + '"');
|
||||||
|
} else {
|
||||||
|
done(); // pass
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.catch(err => ("couldn't call endpoint"));
|
||||||
|
});
|
||||||
|
|
||||||
|
it('Should be able to get repeating username with exact username', (done: Done) => {
|
||||||
|
fetch(getbaseURL() + '/api/userID?username=repeating&exact=true')
|
||||||
|
.then(async res => {
|
||||||
|
if (res.status !== 200) {
|
||||||
|
done("non 200");
|
||||||
|
} else {
|
||||||
|
const data = await res.json();
|
||||||
|
if (data.length !== 2) {
|
||||||
|
done('Returned incorrect number of users "' + data.length + '"');
|
||||||
|
} else if (data[0].userName !== "repeating") {
|
||||||
|
done('Returned incorrect username "' + data.userName + '"');
|
||||||
|
} else if (data[0].userID !== getHash("getuserid_user_04")) {
|
||||||
|
done('Returned incorrect userID "' + data.userID + '"');
|
||||||
|
} else if (data[1].userName !== "repeating") {
|
||||||
|
done('Returned incorrect username "' + data.userName + '"');
|
||||||
|
} else if (data[1].userID !== getHash("getuserid_user_05")) {
|
||||||
|
done('Returned incorrect userID "' + data.userID + '"');
|
||||||
|
} else {
|
||||||
|
done(); // pass
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.catch(err => ("couldn't call endpoint"));
|
||||||
|
});
|
||||||
|
|
||||||
|
it('Should not get exact unless explicitly set to true', (done: Done) => {
|
||||||
|
fetch(getbaseURL() + '/api/userID?username=user&exact=1')
|
||||||
|
.then(async res => {
|
||||||
|
if (res.status !== 200) {
|
||||||
|
done("non 200");
|
||||||
|
} else {
|
||||||
|
const data = await res.json();
|
||||||
|
if (data.length !== 3) {
|
||||||
|
done('Returned incorrect number of users "' + data.length + '"');
|
||||||
|
} else if (data[0].userName !== "fuzzy user 01") {
|
||||||
|
done('Returned incorrect username "' + data.userName + '"');
|
||||||
|
} else if (data[0].userID !== getHash("getuserid_user_01")) {
|
||||||
|
done('Returned incorrect userID "' + data.userID + '"');
|
||||||
|
} else if (data[1].userName !== "fuzzy user 02") {
|
||||||
|
done('Returned incorrect username "' + data.userName + '"');
|
||||||
|
} else if (data[1].userID !== getHash("getuserid_user_02")) {
|
||||||
|
done('Returned incorrect userID "' + data.userID + '"');
|
||||||
|
} else if (data[2].userName !== "specific user 03") {
|
||||||
|
done('Returned incorrect username "' + data.userName + '"');
|
||||||
|
} else if (data[2].userID !== getHash("getuserid_user_03")) {
|
||||||
|
done('Returned incorrect userID "' + data.userID + '"');
|
||||||
|
} else {
|
||||||
|
done(); // pass
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.catch(err => ("couldn't call endpoint"));
|
||||||
|
});
|
||||||
});
|
});
|
||||||
|
|||||||
Reference in New Issue
Block a user