RevelaNetwork/Revelav3
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Format

Browse source
This commit is contained in:
MotorTruck1221 2024-03-23 01:48:06 -06:00
parent 0e6ee114e5
commit 460aa64634
No known key found for this signature in database
GPG key ID: 06901A625432AC21
3 changed files with 257 additions and 239 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
masqr.js
View file

@ -1,29 +1,35 @@
import fp from 'fastify-plugin' import fp from "fastify-plugin";
import fs from 'fs'; import fs from "fs";
const failureFile = fs.readFileSync("Checkfailed.html", "utf8"); const failureFile = fs.readFileSync("Checkfailed.html", "utf8");
const LICENSE_SERVER_URL = "https://license.mercurywork.shop/validate?license="; const LICENSE_SERVER_URL = "https://license.mercurywork.shop/validate?license=";
const whiteListedDomain = ["nebulaproxy.io"]; const whiteListedDomain = ["nebulaproxy.io"];
async function licenseCheck(req, pass) { async function licenseCheck(req, pass) {
try { try {
const resp = await fetch(`${LICENSE_SERVER_URL}${pass}&host=${req.headers.host}`); const resp = await fetch(
`${LICENSE_SERVER_URL}${pass}&host=${req.headers.host}`
);
const data = await resp.json(); const data = await resp.json();
if (data.status === "License valid") { if (data.status === "License valid") {
return true; return true;
} } else {
else { return false;
}
} catch {
return false; return false;
} }
} catch { return false; }
} }
const plugin = (fastify, opts, done) => { const plugin = (fastify, opts, done) => {
fastify.addHook('onRequest', function (req, reply, next) { fastify.addHook("onRequest", function (req, reply, next) {
if (req.cookies.authcheck === 'true' || whiteListedDomain.includes(req.headers.host)) { if (
req.cookies.authcheck === "true" ||
whiteListedDomain.includes(req.headers.host)
) {
return next(); return next();
} }
const authHeader = req.headers.authorization; const authHeader = req.headers.authorization;
if (req.cookies.refreshcheck != "true") { if (req.cookies.refreshcheck != "true") {
reply reply
.setCookie('refreshcheck', 'true', { maxAge: 1000 }) .setCookie("refreshcheck", "true", { maxAge: 1000 })
.type("text/html") .type("text/html")
.send(failureFile); .send(failureFile);
return; return;
@ -31,21 +37,29 @@ const plugin = (fastify, opts, done) => {
if (!authHeader) { if (!authHeader) {
reply reply
.code(401) .code(401)
.header('WWW-Authenticate', 'Basic') .header("WWW-Authenticate", "Basic")
.type("text/html") .type("text/html")
.send(failureFile); .send(failureFile);
return; return;
} }
const auth = Buffer.from(authHeader.split(" ")[1], "base64").toString().split(":"); const auth = Buffer.from(authHeader.split(" ")[1], "base64")
.toString()
.split(":");
const user = auth[0]; const user = auth[0];
const pass = auth[1]; const pass = auth[1];
licenseCheck(req, pass).then((data) => { licenseCheck(req, pass).then((data) => {
if (!data) { if (!data) {
reply.status(401).header('WWW-Authenticate', 'Basic').type("text/html").send(failureFile); reply
.status(401)
.header("WWW-Authenticate", "Basic")
.type("text/html")
.send(failureFile);
return; return;
} } else {
else { reply
reply.setCookie('authcheck', 'true').type("text/html").send('<script>window.location.href = window.location.href</script>') .setCookie("authcheck", "true")
.type("text/html")
.send("<script>window.location.href = window.location.href</script>");
return; return;
} }
}); });
@ -54,8 +68,8 @@ const plugin = (fastify, opts, done) => {
}; };
const masqr = fp(plugin, { const masqr = fp(plugin, {
fastify: '4.x', fastify: "4.x",
name: 'masqr' name: "masqr"
}); });
export default masqr; export default masqr;

10
server.ts
View file

@ -14,7 +14,7 @@ const __dirname = path.dirname(__filename);
const bare = createBareServer("/bare/"); const bare = createBareServer("/bare/");
const rh = createRammerhead(); const rh = createRammerhead();
import chalk from "chalk"; import chalk from "chalk";
import masqr from './masqr.js'; import masqr from "./masqr.js";
const rammerheadScopes = [ const rammerheadScopes = [
"/rammerhead.js", "/rammerhead.js",
@ -102,8 +102,12 @@ app.setNotFoundHandler((req, res) => {
res.sendFile("index.html"); // SPA catch-all res.sendFile("index.html"); // SPA catch-all
}); });
console.log(chalk.green(`Server listening on ${chalk.bold("http://localhost:8080")}`)); console.log(
console.log(chalk.magenta(`Server also listening on ${chalk.bold("http://0.0.0.0:8080")}`)); chalk.green(`Server listening on ${chalk.bold("http://localhost:8080")}`)
);
console.log(
chalk.magenta(`Server also listening on ${chalk.bold("http://0.0.0.0:8080")}`)
);
app.listen({ app.listen({
port: 8080, port: 8080,