mirror of
https://github.com/wukko/cobalt.git
synced 2025-01-12 11:52:12 +01:00
core/api: don't trigger verifyStream on premature probe
This commit is contained in:
parent
70a79fdedd
commit
78288b8fac
1 changed files with 5 additions and 5 deletions
|
@ -131,14 +131,14 @@ export function runAPI(express, app, gitCommit, gitBranch, __dirname) {
|
||||||
const checkBaseLength = q.t.length === 21 && q.e.length === 13;
|
const checkBaseLength = q.t.length === 21 && q.e.length === 13;
|
||||||
const checkSafeLength = q.h.length === 43 && q.s.length === 43 && q.i.length === 22;
|
const checkSafeLength = q.h.length === 43 && q.s.length === 43 && q.i.length === 22;
|
||||||
if (checkQueries && checkBaseLength && checkSafeLength) {
|
if (checkQueries && checkBaseLength && checkSafeLength) {
|
||||||
let streamInfo = verifyStream(q.t, q.h, q.e, q.s, q.i);
|
|
||||||
if (streamInfo.error) {
|
|
||||||
return res.status(streamInfo.status).json(apiJSON(0, { t: streamInfo.error }).body);
|
|
||||||
}
|
|
||||||
if (q.p) {
|
if (q.p) {
|
||||||
return res.status(200).json({
|
return res.status(200).json({
|
||||||
status: "continue"
|
status: "continue"
|
||||||
});
|
})
|
||||||
|
}
|
||||||
|
let streamInfo = verifyStream(q.t, q.h, q.e, q.s, q.i);
|
||||||
|
if (streamInfo.error) {
|
||||||
|
return res.status(streamInfo.status).json(apiJSON(0, { t: streamInfo.error }).body);
|
||||||
}
|
}
|
||||||
return stream(res, streamInfo);
|
return stream(res, streamInfo);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue