push.rocks/smartproxy
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2020-02-23 19:03:25 +00:00
parent 3b2d140836
commit 736113eb4e
2 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
test/test.ts
View File

@ -12,7 +12,7 @@ tap.test('should start the testproxy', async () => {
}); });
tap.test('should supply reverse proxy config', async () => { tap.test('should supply reverse proxy config', async () => {
testProxy.updateReversConfigs([ testProxy.updateReverseConfigs([
{ {
destinationIp: 'localhost', destinationIp: 'localhost',
destinationPort: '3000', destinationPort: '3000',

20
ts/smartproxy.portproxy.ts
View File

@ -2,9 +2,23 @@ import * as plugins from './smartproxy.plugins';
import { expose } from '@pushrocks/smartspawn'; import { expose } from '@pushrocks/smartspawn';
import * as net from 'net'; import * as net from 'net';
let netServer: plugins.net.Server; let netServer: plugins.net.Server;
let httpServer: plugins.http.Server;
const portProxyCalls = { const portProxyCalls = {
start: async (portArg = 8000) => { start: async (portArg = 8000) => {
httpServer = plugins.http.createServer((request, response) => {
const requestUrl = new URL(request.url, `http://${request.headers.host}`);
const completeUrlWithoutProtocol = `${requestUrl.host}${requestUrl.pathname}${requestUrl.search}`;
const redirectUrl = `https://${completeUrlWithoutProtocol}`;
console.log(`Got http request for http://${completeUrlWithoutProtocol}`);
console.log(`Redirecting to ${redirectUrl}`);
response.writeHead(302, {
'Location': redirectUrl
});
response.end();
});
httpServer.listen(7999);
netServer = net netServer = net
.createServer(from => { .createServer(from => {
const to = net.createConnection({ const to = net.createConnection({
@ -19,8 +33,10 @@ const portProxyCalls = {
}, },
stop: async () => { stop: async () => {
const done = plugins.smartpromise.defer(); const done = plugins.smartpromise.defer();
netServer.close(() => { httpServer.close(() => {
done.resolve(); netServer.close(() => {
done.resolve();
});
}); });
await done.promise; await done.promise;
} }