root
/
telebit
mirror of https://github.com/therootcompany/telebit.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

SNI Detection working, sets ‘HTTPS’ for packer for external connections

This commit is contained in:
Henry Camacho 2017-03-11 08:28:04 -06:00
parent 5334649fba
commit 2fc5cf5e69
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rvpn/genericlistener/listener_generic.go
View File

@ -171,7 +171,7 @@ func handleConnection(ctx context.Context, wConn *WedgeConn) {
if wssHostName != sniHostName { if wssHostName != sniHostName {
//traffic not terminating on the rvpn do not decrypt //traffic not terminating on the rvpn do not decrypt
loginfo.Println("processing non terminating traffic") loginfo.Println("processing non terminating traffic")
handleExternalHTTPRequest(ctx, wConn, sniHostName) handleExternalHTTPRequest(ctx, wConn, sniHostName, "https")
} }
loginfo.Println("processing traffic terminating on RVPN") loginfo.Println("processing traffic terminating on RVPN")
@ -257,7 +257,7 @@ func handleStream(ctx context.Context, wConn *WedgeConn) {
//handleExternalHTTPRequest - //handleExternalHTTPRequest -
// - get a wConn and start processing requests // - get a wConn and start processing requests
func handleExternalHTTPRequest(ctx context.Context, extConn net.Conn, hostname string) { func handleExternalHTTPRequest(ctx context.Context, extConn net.Conn, hostname string, service string) {
connectionTracking := ctx.Value(ctxConnectionTrack).(*Tracking) connectionTracking := ctx.Value(ctxConnectionTrack).(*Tracking)
defer func() { defer func() {
@ -286,7 +286,7 @@ func handleExternalHTTPRequest(ctx context.Context, extConn net.Conn, hostname s
return return
} }
var buffer [512]byte var buffer [1024]byte
for { for {
cnt, err := extConn.Read(buffer[0:]) cnt, err := extConn.Read(buffer[0:])
if err != nil { if err != nil {
@ -301,7 +301,7 @@ func handleExternalHTTPRequest(ctx context.Context, extConn net.Conn, hostname s
return return
} }
p.Header.Service = "http" p.Header.Service = service
p.Data.AppendBytes(buffer[0:cnt]) p.Data.AppendBytes(buffer[0:cnt])
buf := p.PackV1() buf := p.PackV1()