import express, { response } from 'express';
import { createProxyServer } from 'http-proxy';
import zlib from 'zlib';
import fs from 'fs';
import path from 'path';
import cheerio from 'cheerio';
import bodyParser from 'body-parser';
let originalUrl: string | undefined = undefined;
const app = express();
const proxy = createProxyServer({
target: 'http://google.com', // Replace with your target URL
changeOrigin: true,
// ignorePath: true,
selfHandleResponse: true, // Required for modifying the response
// onProxyRes: responseInterceptor(async (responseBuffer, proxyRes, req, res) => {
// let response = responseBuffer.toString('utf8');
// // Convert relative URLs to absolute URLs
// response = response.replace(/(href|src)="\/([^"]+)"/g, `$1="http://google.com/$2"`);
// return response;
// }),
});
// app.use('/hardcodedproxy', proxy('www.google.com'));
// proxy.on('proxyRes', (proxyRes, req, res) => {
// let body: Buffer[] = [];
// proxyRes.on('data', (chunk) => {
// body.push(Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk));
// });
// proxyRes.on('end', () => {
// let rawBody = Buffer.concat(body);
// // Get content type
// const contentType = proxyRes.headers['content-type'] || '';
// // Handle decompression safely
// try {
// if (proxyRes.headers['content-encoding']) {
// if (proxyRes.headers['content-encoding'].includes('gzip')) {
// rawBody = zlib.gunzipSync(rawBody);
// } else if (proxyRes.headers['content-encoding'].includes('br')) {
// rawBody = zlib.brotliDecompressSync(rawBody);
// } else if (proxyRes.headers['content-encoding'].includes('deflate')) {
// rawBody = zlib.inflateSync(rawBody);
// }
// delete proxyRes.headers['content-encoding']; // Let the browser handle plain text
// }
// } catch (err) {
// console.error('Decompression failed:', err);
// }
// // Modify HTML only
// if (contentType.includes('text/html')) {
// let response = rawBody.toString('utf8');
// response = response.replace(//, ``);
// rawBody = Buffer.from(response, 'utf8');
// }
// // 🔹 Set CORS headers dynamically after modifications
// res.setHeader('Access-Control-Allow-Origin', '*');
// res.setHeader('Access-Control-Allow-Methods', 'GET, POST, OPTIONS');
// res.setHeader('Access-Control-Allow-Headers', 'Content-Type');
// // 🔹 Allow CORS for static assets
// if (
// contentType.includes('font') ||
// contentType.includes('css') ||
// contentType.includes('javascript') ||
// contentType.includes('image')
// ) {
// res.setHeader('Access-Control-Allow-Origin', '*');
// }
// res.writeHead(proxyRes.statusCode || 200, proxyRes.headers);
// res.end(rawBody);
// });
// });
// const baseUrl = 'http://localhost:3005/proxy?url='; // replace wtih env vars for different envs
const baseUrl = 'http://localhost:3005/proxy/'; // replace wtih env vars for different envs
const getBaseUrl = (urlString: string): string => {
try {
const url = new URL(urlString);
const baseDomain = url.hostname; // Get the base domain
const protocol = url.protocol; // Get the protocol (includes ':' at the end)
// Format the output as needed
const output = {
protocol: protocol, // e.g., 'https:'
baseDomain: baseDomain // e.g., 'www.example.com'
};
return protocol + '://' + baseDomain;
} catch (error) {
return '';
}
};
const rewriteLinks = (response: string): string => {
const originalHost = new URL(originalUrl || '').host;
// const baseProxyUrl = `http://localhost:3005/proxy?url=`;
const baseProxyUrl = `http://localhost:3005/proxy/`;
const hostnameParts = originalHost.split('.');
const baseDomain = hostnameParts.slice(-2).join('.');
// 🔹 Skip URLs pointing to static assets (JS, CSS, images, fonts)
const staticFileExtensions = /\.(js|css|png|jpe?g|gif|svg|woff2?|ttf|eot|ico|mp4|webm|ogg|json|xml)(\?.*)?$/i;
// 🔹 Rewrite `` links (absolute & relative) unless they are static assets
response = response.replace(
/]*?href=["'](https?:\/\/([^"']+))["']/gi,
(match, fullUrl, domain) => {
if (domain.includes(baseDomain) && !staticFileExtensions.test(fullUrl)) {
console.log('match', match);
return match.replace(fullUrl, `${baseProxyUrl}${encodeURIComponent(fullUrl)}`);
}
return match;
}
);
response = response.replace(
/]*?href=["'](\/[^"']*)["']/gi,
(match, relativePath) => {
if (!staticFileExtensions.test(relativePath)) {
return match.replace(relativePath, `${baseProxyUrl}${encodeURIComponent(originalUrl + relativePath)}`);
}
return match;
}
);
// 🔹 Rewrite `