Creepso/pstream-simple-proxy
1
0
Fork 0
mirror of https://github.com/p-stream/simple-proxy.git synced 2026-03-11 17:55:39 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #26 from movie-web/dev

Browse source 
Version 2.1.3: Push updates to support AWS
This commit is contained in:
William Oldham 2024-01-06 20:54:30 +00:00 committed by GitHub
commit 5a09e0c602
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 521 additions and 307 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
package.json
View file

@ -1,7 +1,7 @@
{ {
"name": "simple-proxy", "name": "simple-proxy",
"private": true, "private": true,
"version": "2.1.2", "version": "2.1.3",
"scripts": { "scripts": {
"prepare": "nitropack prepare", "prepare": "nitropack prepare",
"dev": "nitropack dev", "dev": "nitropack dev",
@ -15,9 +15,9 @@
"preinstall": "npx only-allow pnpm" "preinstall": "npx only-allow pnpm"
}, },
"dependencies": { "dependencies": {
"h3": "^1.9.0", "h3": "^1.10.0",
"jose": "^5.2.0", "jose": "^5.2.0",
"nitropack": "latest" "nitropack": "^2.8.1"
}, },
"devDependencies": { "devDependencies": {
"@typescript-eslint/eslint-plugin": "^6.7.0", "@typescript-eslint/eslint-plugin": "^6.7.0",

790
pnpm-lock.yaml
View file

File diff suppressed because it is too large Load diff

31
src/routes/index.ts
View file

@ -41,17 +41,22 @@ export default defineEventHandler(async (event) => {
const token = await createTokenIfNeeded(event); const token = await createTokenIfNeeded(event);
// proxy // proxy
await specificProxyRequest(event, destination, { try {
blacklistedHeaders: getBlacklistedHeaders(), await specificProxyRequest(event, destination, {
fetchOptions: { blacklistedHeaders: getBlacklistedHeaders(),
redirect: 'follow', fetchOptions: {
headers: getProxyHeaders(event.headers), redirect: 'follow',
body, headers: getProxyHeaders(event.headers),
}, body,
onResponse(outputEvent, response) { },
const headers = getAfterResponseHeaders(response.headers, response.url); onResponse(outputEvent, response) {
setResponseHeaders(outputEvent, headers); const headers = getAfterResponseHeaders(response.headers, response.url);
if (token) setTokenHeader(event, token); setResponseHeaders(outputEvent, headers);
}, if (token) setTokenHeader(event, token);
}); },
});
} catch (e) {
console.log('Error fetching', e);
throw e;
}
}); });

1
src/utils/headers.ts
View file

@ -20,6 +20,7 @@ const blacklistedHeaders = [
'x-forwarded-proto', 'x-forwarded-proto',
'forwarded', 'forwarded',
'x-real-ip', 'x-real-ip',
'content-length',
...Object.keys(headerMap), ...Object.keys(headerMap),
]; ];