From 0f79e708bf07721b73ea41e5d341be08e8ea4dce Mon Sep 17 00:00:00 2001 From: Minteck Date: Sun, 7 Mar 2021 18:29:17 +0100 Subject: Initial commit --- php/cache.js | 90 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++ php/cleanup.js | 15 ++++++++++ php/headers.php | 8 +++++ php/runtime.js | 31 ++++++++++++++++++++ 4 files changed, 144 insertions(+) create mode 100644 php/cache.js create mode 100644 php/cleanup.js create mode 100644 php/headers.php create mode 100644 php/runtime.js (limited to 'php') diff --git a/php/cache.js b/php/cache.js new file mode 100644 index 0000000..25c47be --- /dev/null +++ b/php/cache.js @@ -0,0 +1,90 @@ +const uuid = require('uuid'); +const fs = require('fs'); +const url = require('url'); +const path = require('path'); +const os = require('os'); + +function addPhpServerVariable(server, name, value) { + if (typeof value == "string") { + return server + "\n$_SERVER['" + name.split("'").join("\\'") + "'] = \"" + value.split("\"").join("\\\"") + "\";"; + } else { + return server + "\n$_SERVER['" + name.split("'").join("\\'") + "'] = " + value + ";"; + } +} + +module.exports = (req, res, file, post, files) => { + cid = uuid.v4(); + fid = "PHP_" + cid; + parsed = url.parse(req.url, true); + + content = " r.concat(list.reduce((rr, i) => rr.concat(i.family==='IPv4' && !i.internal && i.address || []), [])), [])[0]); + content = addPhpServerVariable(content, "SERVER_NAME", os.hostname()); + content = addPhpServerVariable(content, "SERVER_SOFTWARE", config.product.name); + content = addPhpServerVariable(content, "SERVER_PROTOCOL", "HTTP/" + req.httpVersion); + content = addPhpServerVariable(content, "REQUEST_METHOD", req.method); + content = addPhpServerVariable(content, "REQUEST_TIME", REQUEST_START); + content = addPhpServerVariable(content, "REQUEST_TIME_FLOAT", REQUEST_START_FLOAT); + content = addPhpServerVariable(content, "QUERY_STRING", parsed.search); + content = addPhpServerVariable(content, "DOCUMENT_ROOT", path.resolve("./public")); + if (typeof req.headers["accept"] != "undefined") { + content = addPhpServerVariable(content, "HTTP_ACCEPT", req.headers["accept"]); + } + if (typeof req.headers["accept-charset"] != "undefined") { + content = addPhpServerVariable(content, "HTTP_ACCEPT_CHARSET", req.headers["accept-charset"]); + } + if (typeof req.headers["accept-encoding"] != "undefined") { + content = addPhpServerVariable(content, "HTTP_ACCEPT_ENCODING", req.headers["accept-encoding"]); + } + if (typeof req.headers["accept-language"] != "undefined") { + content = addPhpServerVariable(content, "HTTP_ACCEPT_LANGUAGE", req.headers["accept-language"]); + } + if (typeof req.headers["connection"] != "undefined") { + content = addPhpServerVariable(content, "HTTP_CONNECTION", req.headers["connection"]); + } + if (typeof req.headers["host"] != "undefined") { + content = addPhpServerVariable(content, "HTTP_HOST", req.headers["host"]); + } + content = addPhpServerVariable(content, "HTTP_REFERER", req.url); + if (typeof req.headers["user-agent"] != "undefined") { + content = addPhpServerVariable(content, "HTTP_USER_AGENT", req.headers["user-agent"]); + } + content = addPhpServerVariable(content, "REMOTE_ADDR", req.connection.remoteAddress); + content = addPhpServerVariable(content, "REMOTE_PORT", req.connection.remotePort); + content = addPhpServerVariable(content, "SCRIPT_FILENAME", path.resolve(file)); + content = addPhpServerVariable(content, "SERVER_ADMIN", config.network.admin); + content = addPhpServerVariable(content, "SERVER_PORT", config.network.port); + content = addPhpServerVariable(content, "SERVER_SIGNATURE", "
" + config.product.name + " version " + version + "
"); + content = addPhpServerVariable(content, "PATH_TRANSLATED", path.resolve(file)); + content = addPhpServerVariable(content, "SCRIPT_NAME", file.substr("./public/".length)); + content = addPhpServerVariable(content, "REQUEST_URI", parsed.pathname); + content = content + "\n$_FILES = [];"; + content = content + "\n$_POST = [];"; + content = content + "\n$_GET = [];"; + Object.keys(parsed.query).forEach((key) => { + content = content + "\n$_GET[\"" + key.split("\"").join("\\\"").split("$").join("\\\$") + "\"] = \"" + parsed.query[key].split("\"").join("\\\"").split("$").join("\\\$") + "\";" + }) + Object.keys(post).forEach((key) => { + content = content + "\n$_POST[\"" + key.split("\"").join("\\\"").split("$").join("\\\$") + "\"] = \"" + post[key].split("\"").join("\\\"").split("$").join("\\\$") + "\";" + }) + if (typeof files == "object") { + Object.keys(files).forEach((key) => { + content = content + "\n$_FILES[\"" + key.split("\"").join("\\\"").split("$").join("\\\$") + "\"] = ['name' => \"" + files[key]["name"].split("\"").join("\\\"") + "\",'type' => \"" + files[key]["type"].split("\"").join("\\\"") + "\",'tmp_name' => \"" + files[key]["path"].split("\"").join("\\\"").split("$").join("\\\$") + "\",'error' => 0,'size' => " + files[key]["size"] + "];" + }) + } + cookies = core.cookies(req); + Object.keys(cookies).forEach((key) => { + content = content + "\n$_COOKIE[\"" + key.split("\"").join("\\\"").split("$").join("\\\$") + "\"] = \"" + cookies[key].split("\"").join("\\\"").split("$").join("\\\$") + "\";" + }) + content = content + "\nrequire_once \"" + file.split("\"").join("\\\"") + "\";\n\n__electrode_end_hooks();"; + + fs.writeFileSync("./cache/" + fid + ".php", content); + return [ + "./cache/" + fid + ".php", + cid + ]; +} diff --git a/php/cleanup.js b/php/cleanup.js new file mode 100644 index 0000000..a3f37ea --- /dev/null +++ b/php/cleanup.js @@ -0,0 +1,15 @@ +const fs = require('fs'); + +module.exports = () => { + fs.readdir("./cache", (error, files) => { + if (error) { + console.log(chalk.gray(cluster.worker.id + " ") + chalk.yellow("warn:") + " unable to cleanup cache: " + error.message); + } else { + files.forEach((file) => { + if (file.startsWith("PHP_")) { + fs.unlink("./cache/" + file, () => {}); + } + }) + } + }) +} \ No newline at end of file diff --git a/php/headers.php b/php/headers.php new file mode 100644 index 0000000..d8518de --- /dev/null +++ b/php/headers.php @@ -0,0 +1,8 @@ + { + startd = new Date(); + try { + error = undefined; + var { stdout, stderr } = await exec("php \"" + file.split("\"").join("\\\"") + "\""); + } catch (e) { + error = e; + } + stopd = new Date(); + diff = stopd - startd; + + console.log(chalk.gray(cluster.worker.id + " ") + chalk.blueBright("php:") + " total run time: " + diff + "ms"); + + returnobj = {error: null, content: null, stderr: null, id: id}; + + if (error) { + returnobj.error = error; + returnobj.stderr = stderr; + } else { + php.cleanup() + returnobj.content = stdout; + returnobj.stderr = stderr; + } + + return returnobj; +} \ No newline at end of file -- cgit