tcp-proxy.js
Advanced tools
Comparing version 1.3.0 to 1.4.0
14
index.js
@@ -7,2 +7,3 @@ 'use strict'; | ||
const EventEmitter = require('events').EventEmitter; | ||
let seqId = 0; | ||
@@ -12,2 +13,3 @@ function genThrough(interceptor, connection) { | ||
const context = { | ||
connId: connection.id, | ||
client: { | ||
@@ -87,5 +89,13 @@ ip: connection.client.address().address, | ||
const conn = { | ||
id: seqId++, | ||
client, | ||
server, | ||
forwardHost, | ||
forwardPort, | ||
}; | ||
// client interceptor | ||
if (interceptor.client) { | ||
interceptorClient = genThrough(interceptor.client, { client, server, forwardHost, forwardPort }); | ||
interceptorClient = genThrough(interceptor.client, conn); | ||
_client = _client.pipe(interceptorClient); | ||
@@ -96,3 +106,3 @@ } | ||
if (interceptor.server) { | ||
interceptorServer = genThrough(interceptor.server, { client, server, forwardHost, forwardPort }); | ||
interceptorServer = genThrough(interceptor.server, conn); | ||
_server = _server.pipe(interceptorServer); | ||
@@ -99,0 +109,0 @@ } |
{ | ||
"name": "tcp-proxy.js", | ||
"version": "1.3.0", | ||
"version": "1.4.0", | ||
"description": "simple tcp proxy", | ||
@@ -20,3 +20,3 @@ "dependencies": { | ||
"engines": { | ||
"node": ">=6.0.0" | ||
"node": ">=14.0.0" | ||
}, | ||
@@ -33,3 +33,3 @@ "scripts": { | ||
"ci": { | ||
"version": "6, 8" | ||
"version": "14, 16, 18" | ||
}, | ||
@@ -36,0 +36,0 @@ "repository": { |
137
9731
4