Karl/homepage
1
0
Fork 0
mirror of https://github.com/karl0ss/homepage.git synced 2025-05-20 21:16:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

forward proxy bodies raw

Browse Source
This commit is contained in:
Ben Phelps 2022-08-25 20:57:25 +03:00
parent b47f5b6953
commit 1f3cd43bef
2 changed files with 66 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
src/pages/api/proxy.js
View File

@ -1,52 +1,16 @@
import https from "https"; import https from "https";
import http from "http"; import getRawBody from "raw-body";
function httpsRequest(params) { import { httpRequest, httpsRequest } from "utils/http";
return new Promise(function (resolve, reject) {
var request = https.request(params, function (response) {
let data = "";
response.on("data", (chunk) => { export const config = {
data = data + chunk.toString(); api: {
}); bodyParser: false,
},
response.on("end", () => { };
resolve([response.statusCode, data]);
});
});
request.on("error", (error) => {
reject([500, error]);
});
request.end();
});
}
function httpRequest(params) {
return new Promise(function (resolve, reject) {
var request = http.request(params, function (response) {
let data = "";
response.on("data", (chunk) => {
data = data + chunk.toString();
});
response.on("end", () => {
resolve([response.statusCode, data]);
});
});
request.on("error", (error) => {
reject([500, error]);
});
request.end();
});
}
export default async function handler(req, res) { export default async function handler(req, res) {
const headers = ["X-API-Key", "Content-Type", "Authorization"].reduce((obj, key) => { const headers = ["X-API-Key", "Authorization"].reduce((obj, key) => {
if (req.headers && req.headers.hasOwnProperty(key.toLowerCase())) { if (req.headers && req.headers.hasOwnProperty(key.toLowerCase())) {
obj[key] = req.headers[key.toLowerCase()]; obj[key] = req.headers[key.toLowerCase()];
} }
@ -69,7 +33,12 @@ export default async function handler(req, res) {
agent: httpsAgent, agent: httpsAgent,
method: req.method, method: req.method,
headers: headers, headers: headers,
body: req.method == "GET" || req.method == "HEAD" ? null : req.body, body:
req.method == "GET" || req.method == "HEAD"
? null
: await getRawBody(req, {
encoding: "utf8",
}),
}); });
return res.status(status).send(data); return res.status(status).send(data);
@ -80,7 +49,12 @@ export default async function handler(req, res) {
port: url.port, port: url.port,
method: req.method, method: req.method,
headers: headers, headers: headers,
body: req.method == "GET" || req.method == "HEAD" ? null : req.body, body:
req.method == "GET" || req.method == "HEAD"
? null
: await getRawBody(req, {
encoding: "utf8",
}),
}); });
return res.status(status).send(data); return res.status(status).send(data);

46
src/utils/http.js Normal file
View File

@ -0,0 +1,46 @@
import https from "https";
import http from "http";
export function httpsRequest(params) {
return new Promise(function (resolve, reject) {
var request = https.request(params, function (response) {
let data = "";
response.on("data", (chunk) => {
data = data + chunk.toString();
});
response.on("end", () => {
resolve([response.statusCode, data]);
});
});
request.on("error", (error) => {
reject([500, error]);
});
request.end();
});
}
export function httpRequest(params) {
return new Promise(function (resolve, reject) {
var request = http.request(params, function (response) {
let data = "";
response.on("data", (chunk) => {
data = data + chunk.toString();
});
response.on("end", () => {
resolve([response.statusCode, data]);
});
});
request.on("error", (error) => {
reject([500, error]);
});
request.end();
});
}