just a clean up
- moved pattern testers out of match module (thanks you @radkii) - button borders are now easier to see the reason this commit exists is because i tried to implement a language picker and failed to do it properly so here we are
This commit is contained in:
@@ -3,7 +3,7 @@ const config = loadJson("./src/config.json");
|
||||
const packageJson = loadJson("./package.json");
|
||||
|
||||
export const
|
||||
services = loadJson("./src/modules/services/_config.json"),
|
||||
services = loadJson("./src/modules/servicesConfig.json"),
|
||||
appName = packageJson.name,
|
||||
version = packageJson.version,
|
||||
streamLifespan = config.streamLifespan,
|
||||
|
||||
@@ -1,6 +1,8 @@
|
||||
import { apiJSON } from "./sub/utils.js";
|
||||
import { errorUnsupported, genericError } from "./sub/errors.js";
|
||||
|
||||
import { testers } from "./servicesPatternTesters.js";
|
||||
|
||||
import bilibili from "./services/bilibili.js";
|
||||
import reddit from "./services/reddit.js";
|
||||
import twitter from "./services/twitter.js";
|
||||
@@ -12,120 +14,108 @@ import tumblr from "./services/tumblr.js";
|
||||
|
||||
export default async function (host, patternMatch, url, ip, lang, format, quality) {
|
||||
try {
|
||||
if (!testers[host]) return apiJSON(0, { t: errorUnsupported(lang) });
|
||||
if (!(testers[host](patternMatch))) throw Error();
|
||||
|
||||
let r;
|
||||
switch (host) {
|
||||
case "twitter":
|
||||
if (patternMatch["id"] && patternMatch["id"].length < 20) {
|
||||
let r = await twitter({
|
||||
id: patternMatch["id"],
|
||||
lang: lang
|
||||
});
|
||||
return (!r.error) ? apiJSON(1, { u: r.split('?')[0] }) : apiJSON(0, { t: r.error })
|
||||
} else throw Error()
|
||||
r = await twitter({
|
||||
id: patternMatch["id"],
|
||||
lang: lang
|
||||
});
|
||||
return (!r.error) ? apiJSON(1, { u: r.split('?')[0] }) : apiJSON(0, { t: r.error });
|
||||
|
||||
case "vk":
|
||||
if (patternMatch["userId"] && patternMatch["videoId"] &&
|
||||
patternMatch["userId"].length <= 10 && patternMatch["videoId"].length == 9) {
|
||||
let r = await vk({
|
||||
userId: patternMatch["userId"],
|
||||
videoId: patternMatch["videoId"],
|
||||
lang: lang, quality: quality
|
||||
});
|
||||
return (!r.error) ? apiJSON(2,
|
||||
{ type: "bridge", lang: lang, u: r.url, filename:
|
||||
r.filename, service: host, ip: ip, salt: process.env.streamSalt }) : apiJSON(0, { t: r.error });
|
||||
} else throw Error()
|
||||
r = await vk({
|
||||
userId: patternMatch["userId"],
|
||||
videoId: patternMatch["videoId"],
|
||||
lang: lang, quality: quality
|
||||
});
|
||||
return (!r.error) ? apiJSON(2, { type: "bridge", lang: lang, u: r.url, filename: r.filename,
|
||||
service: host, ip: ip, salt: process.env.streamSalt }) : apiJSON(0, { t: r.error });
|
||||
|
||||
case "bilibili":
|
||||
if (patternMatch["id"] && patternMatch["id"].length >= 12) {
|
||||
let r = await bilibili({
|
||||
id: patternMatch["id"].slice(0, 12),
|
||||
lang: lang
|
||||
});
|
||||
return (!r.error) ? apiJSON(2, {
|
||||
type: "render", u: r.urls, lang: lang,
|
||||
service: host, ip: ip,
|
||||
filename: r.filename,
|
||||
salt: process.env.streamSalt, time: r.time
|
||||
}) : apiJSON(0, { t: r.error });
|
||||
} else throw Error()
|
||||
r = await bilibili({
|
||||
id: patternMatch["id"].slice(0, 12),
|
||||
lang: lang
|
||||
});
|
||||
return (!r.error) ? apiJSON(2, {
|
||||
type: "render", u: r.urls, lang: lang,
|
||||
service: host, ip: ip,
|
||||
filename: r.filename,
|
||||
salt: process.env.streamSalt, time: r.time
|
||||
}) : apiJSON(0, { t: r.error });
|
||||
|
||||
case "youtube":
|
||||
if (patternMatch["id"] && patternMatch["id"].length >= 11) {
|
||||
let fetchInfo = {
|
||||
id: patternMatch["id"].slice(0,11),
|
||||
lang: lang, quality: quality,
|
||||
format: "mp4"
|
||||
};
|
||||
if (url.match('music.youtube.com')) {
|
||||
format = "audio"
|
||||
}
|
||||
switch (format) {
|
||||
case "webm":
|
||||
fetchInfo["format"] = "webm";
|
||||
break;
|
||||
case "audio":
|
||||
fetchInfo["format"] = "webm";
|
||||
fetchInfo["isAudioOnly"] = true;
|
||||
fetchInfo["quality"] = "max";
|
||||
break;
|
||||
}
|
||||
let r = await youtube(fetchInfo);
|
||||
return (!r.error) ? apiJSON(2, {
|
||||
type: r.type, u: r.urls, lang: lang, service: host, ip: ip,
|
||||
filename: r.filename, salt: process.env.streamSalt,
|
||||
isAudioOnly: fetchInfo["isAudioOnly"] ? fetchInfo["isAudioOnly"] : false,
|
||||
time: r.time,
|
||||
}) : apiJSON(0, { t: r.error });
|
||||
} else throw Error()
|
||||
let fetchInfo = {
|
||||
id: patternMatch["id"].slice(0,11),
|
||||
lang: lang, quality: quality,
|
||||
format: "mp4"
|
||||
};
|
||||
if (url.match('music.youtube.com')) {
|
||||
format = "audio"
|
||||
}
|
||||
switch (format) {
|
||||
case "webm":
|
||||
fetchInfo["format"] = "webm";
|
||||
break;
|
||||
case "audio":
|
||||
fetchInfo["format"] = "webm";
|
||||
fetchInfo["isAudioOnly"] = true;
|
||||
fetchInfo["quality"] = "max";
|
||||
break;
|
||||
}
|
||||
r = await youtube(fetchInfo);
|
||||
return (!r.error) ? apiJSON(2, {
|
||||
type: r.type, u: r.urls, lang: lang, service: host, ip: ip,
|
||||
filename: r.filename, salt: process.env.streamSalt,
|
||||
isAudioOnly: fetchInfo["isAudioOnly"] ? fetchInfo["isAudioOnly"] : false,
|
||||
time: r.time,
|
||||
}) : apiJSON(0, { t: r.error });
|
||||
|
||||
case "reddit":
|
||||
if (patternMatch["sub"] && patternMatch["id"] && patternMatch["title"] &&
|
||||
patternMatch["sub"].length <= 22 && patternMatch["id"].length <= 10 && patternMatch["title"].length <= 96) {
|
||||
let r = await reddit({
|
||||
sub: patternMatch["sub"],
|
||||
id: patternMatch["id"],
|
||||
title: patternMatch["title"], lang: lang,
|
||||
});
|
||||
return (!r.error) ? apiJSON(r.typeId, {
|
||||
type: r.type, u: r.urls, lang: lang,
|
||||
service: host, ip: ip,
|
||||
filename: r.filename, salt: process.env.streamSalt
|
||||
}) : apiJSON(0, { t: r.error });
|
||||
} else throw Error()
|
||||
r = await reddit({
|
||||
sub: patternMatch["sub"],
|
||||
id: patternMatch["id"],
|
||||
title: patternMatch["title"], lang: lang,
|
||||
});
|
||||
return (!r.error) ? apiJSON(r.typeId, {
|
||||
type: r.type, u: r.urls, lang: lang,
|
||||
service: host, ip: ip,
|
||||
filename: r.filename, salt: process.env.streamSalt
|
||||
}) : apiJSON(0, { t: r.error });
|
||||
|
||||
case "tiktok":
|
||||
if ((patternMatch["user"] && patternMatch["postId"] && patternMatch["postId"].length <= 21) ||
|
||||
(patternMatch["id"] && patternMatch["id"].length <= 13)) {
|
||||
let r = await tiktok({
|
||||
postId: patternMatch["postId"],
|
||||
id: patternMatch["id"], lang: lang,
|
||||
});
|
||||
return (!r.error) ? apiJSON(2, {
|
||||
type: "bridge", u: r.urls, lang: lang,
|
||||
service: host, ip: ip,
|
||||
filename: r.filename, salt: process.env.streamSalt
|
||||
}) : apiJSON(0, { t: r.error });
|
||||
} else throw Error()
|
||||
r = await tiktok({
|
||||
postId: patternMatch["postId"],
|
||||
id: patternMatch["id"], lang: lang,
|
||||
});
|
||||
return (!r.error) ? apiJSON(2, {
|
||||
type: "bridge", u: r.urls, lang: lang,
|
||||
service: host, ip: ip,
|
||||
filename: r.filename, salt: process.env.streamSalt
|
||||
}) : apiJSON(0, { t: r.error });
|
||||
|
||||
case "douyin":
|
||||
if ((patternMatch["postId"] && patternMatch["postId"].length <= 21) ||
|
||||
(patternMatch["id"] && patternMatch["id"].length <= 13)) {
|
||||
let r = await douyin({
|
||||
postId: patternMatch["postId"],
|
||||
id: patternMatch["id"], lang: lang,
|
||||
});
|
||||
return (!r.error) ? apiJSON(2, {
|
||||
type: "bridge", u: r.urls, lang: lang,
|
||||
service: host, ip: ip,
|
||||
filename: r.filename, salt: process.env.streamSalt
|
||||
}) : apiJSON(0, { t: r.error });
|
||||
} else throw Error()
|
||||
r = await douyin({
|
||||
postId: patternMatch["postId"],
|
||||
id: patternMatch["id"], lang: lang,
|
||||
});
|
||||
return (!r.error) ? apiJSON(2, {
|
||||
type: "bridge", u: r.urls, lang: lang,
|
||||
service: host, ip: ip,
|
||||
filename: r.filename, salt: process.env.streamSalt
|
||||
}) : apiJSON(0, { t: r.error });
|
||||
|
||||
case "tumblr":
|
||||
if ((patternMatch["id"] && patternMatch["id"].length < 21) ||
|
||||
(patternMatch["id"] && patternMatch["id"].length < 21 &&
|
||||
patternMatch["user"] && patternMatch["user"].length <= 32)) {
|
||||
let r = await tumblr({
|
||||
id: patternMatch["id"], url: url, user: patternMatch["user"] ? patternMatch["user"] : false,
|
||||
lang: lang
|
||||
});
|
||||
return (!r.error) ? apiJSON(1, { u: r.split('?')[0] }) : apiJSON(0, { t: r.error })
|
||||
} else throw Error()
|
||||
r = await tumblr({
|
||||
id: patternMatch["id"], url: url, user: patternMatch["user"] ? patternMatch["user"] : false,
|
||||
lang: lang
|
||||
});
|
||||
return (!r.error) ? apiJSON(1, { u: r.split('?')[0] }) : apiJSON(0, { t: r.error });
|
||||
default:
|
||||
return apiJSON(0, { t: errorUnsupported(lang) })
|
||||
return apiJSON(0, { t: errorUnsupported(lang) });
|
||||
}
|
||||
} catch (e) {
|
||||
return apiJSON(0, { t: genericError(lang, host) })
|
||||
|
||||
@@ -2,7 +2,9 @@ import { services, appName, authorInfo, version, quality, repo, donations } from
|
||||
import { getCommitInfo } from "./sub/currentCommit.js";
|
||||
import loc from "../localization/manager.js";
|
||||
|
||||
let s = services
|
||||
let s = services;
|
||||
let com = getCommitInfo();
|
||||
|
||||
let enabledServices = Object.keys(s).filter((p) => {
|
||||
if (s[p].enabled) {
|
||||
return true
|
||||
@@ -19,8 +21,6 @@ let donate = ``
|
||||
for (let i in donations) {
|
||||
donate += `<div class="subtitle">${i} (REPLACEME)</div><div id="don-${i}" class="text-to-copy" onClick="copy('don-${i}')">${donations[i]}</div>`
|
||||
}
|
||||
|
||||
let com = getCommitInfo();
|
||||
export default function(obj) {
|
||||
let isIOS = obj.useragent.toLowerCase().match("iphone os")
|
||||
try {
|
||||
@@ -196,7 +196,7 @@ export default function(obj) {
|
||||
</div>
|
||||
</footer>
|
||||
</body>
|
||||
<script type="text/javascript">const loc = {noInternet:"${loc(obj.lang, 'ErrorNoInternet')}", noURLReturned: "${loc(obj.lang, 'ErrorBadFetch')}"}</script>
|
||||
<script type="text/javascript">const loc = {noInternet:"${loc(obj.lang, 'ErrorNoInternet')}", noURLReturned: "${loc(obj.lang, 'ErrorBadFetch')}"};</script>
|
||||
<script type="text/javascript" src="cobalt.js"></script>
|
||||
</html>`;
|
||||
} catch (err) {
|
||||
|
||||
22
src/modules/servicesPatternTesters.js
Normal file
22
src/modules/servicesPatternTesters.js
Normal file
@@ -0,0 +1,22 @@
|
||||
export let testers = {
|
||||
"twitter": (patternMatch) => (patternMatch["id"] && patternMatch["id"].length < 20),
|
||||
|
||||
"vk": (patternMatch) => (patternMatch["userId"] && patternMatch["videoId"] &&
|
||||
patternMatch["userId"].length <= 10 && patternMatch["videoId"].length == 9),
|
||||
|
||||
"bilibili": (patternMatch) => (patternMatch["id"] && patternMatch["id"].length >= 12),
|
||||
|
||||
"youtube": (patternMatch) => (patternMatch["id"] && patternMatch["id"].length >= 11),
|
||||
|
||||
"reddit": (patternMatch) => (patternMatch["sub"] && patternMatch["id"] && patternMatch["title"] &&
|
||||
patternMatch["sub"].length <= 22 && patternMatch["id"].length <= 10 && patternMatch["title"].length <= 96),
|
||||
|
||||
"tiktok": (patternMatch) => ((patternMatch["user"] && patternMatch["postId"] && patternMatch["postId"].length <= 21) ||
|
||||
(patternMatch["id"] && patternMatch["id"].length <= 13)),
|
||||
|
||||
"douyin": (patternMatch) => ((patternMatch["postId"] && patternMatch["postId"].length <= 21) ||
|
||||
(patternMatch["id"] && patternMatch["id"].length <= 13)),
|
||||
|
||||
"tumblr": (patternMatch) => ((patternMatch["id"] && patternMatch["id"].length < 21) ||
|
||||
(patternMatch["id"] && patternMatch["id"].length < 21 && patternMatch["user"] && patternMatch["user"].length <= 32)),
|
||||
};
|
||||
Reference in New Issue
Block a user