dacaaf5b27
- rewrote and/or optimized all service modules - rewrote matching and processing modules to optimize readability and performance - added support for reddit gifs - fixed various issues with twitter error explanations - code optimizations and enhancements (such as finally getting rid of ==, prettier and more readable formatting, etc) - added branch information - all functions in currentCommit submodule run only once and cache received data - added a test script. only twitter and soundcloud are 100% covered and tested atm, will add tests (and probably fixes) for the rest of services in next commits - changed some localization strings for russian - added more clarity to rate limit message - moved services folder into processing folder
59 lines
2.1 KiB
JavaScript
59 lines
2.1 KiB
JavaScript
import NodeCache from "node-cache";
|
|
|
|
import { sha256 } from "../sub/crypto.js";
|
|
import { streamLifespan } from "../config.js";
|
|
|
|
const streamCache = new NodeCache({ stdTTL: streamLifespan/1000, checkperiod: 10, deleteOnExpire: true });
|
|
const salt = process.env.streamSalt;
|
|
|
|
streamCache.on("expired", (key) => {
|
|
streamCache.del(key);
|
|
});
|
|
|
|
export function createStream(obj) {
|
|
let streamID = sha256(`${obj.ip},${obj.service},${obj.filename},${obj.audioFormat},${obj.mute}`, salt),
|
|
exp = Math.floor(new Date().getTime()) + streamLifespan,
|
|
ghmac = sha256(`${streamID},${obj.service},${obj.ip},${exp}`, salt);
|
|
|
|
if (!streamCache.has(streamID)) {
|
|
streamCache.set(streamID, {
|
|
id: streamID,
|
|
service: obj.service,
|
|
type: obj.type,
|
|
urls: obj.u,
|
|
filename: obj.filename,
|
|
hmac: ghmac,
|
|
ip: obj.ip,
|
|
exp: exp,
|
|
isAudioOnly: !!obj.isAudioOnly,
|
|
audioFormat: obj.audioFormat,
|
|
time: obj.time ? obj.time : false,
|
|
copy: !!obj.copy,
|
|
mute: !!obj.mute,
|
|
metadata: obj.fileMetadata ? obj.fileMetadata : false
|
|
});
|
|
} else {
|
|
let streamInfo = streamCache.get(streamID);
|
|
exp = streamInfo.exp;
|
|
ghmac = streamInfo.hmac;
|
|
}
|
|
return `${process.env.selfURL}api/stream?t=${streamID}&e=${exp}&h=${ghmac}`;
|
|
}
|
|
|
|
export function verifyStream(ip, id, hmac, exp) {
|
|
try {
|
|
let streamInfo = streamCache.get(id);
|
|
if (!streamInfo) {
|
|
return { error: 'this stream token does not exist', status: 400 };
|
|
}
|
|
let ghmac = sha256(`${id},${streamInfo.service},${ip},${exp}`, salt);
|
|
if (String(hmac) === ghmac && String(exp) === String(streamInfo.exp) && ghmac === String(streamInfo.hmac)
|
|
&& String(ip) === streamInfo.ip && Number(exp) > Math.floor(new Date().getTime())) {
|
|
return streamInfo;
|
|
}
|
|
return { error: 'Unauthorized', status: 401 };
|
|
} catch (e) {
|
|
return { status: 500, body: { status: "error", text: "Internal Server Error" } };
|
|
}
|
|
}
|