(tunnelConn io.ReadWriter, originConn net.Conn, log *zerolog.Logger)
| 132 | } |
| 133 | |
| 134 | func StreamHandler(tunnelConn io.ReadWriter, originConn net.Conn, log *zerolog.Logger) { |
| 135 | dialer := NewConnDialer(originConn) |
| 136 | requestHandler := NewRequestHandler(dialer, nil) |
| 137 | socksServer := NewConnectionHandler(requestHandler) |
| 138 | |
| 139 | if err := socksServer.Serve(tunnelConn); err != nil { |
| 140 | log.Debug().Err(err).Msg("Socks stream handler error") |
| 141 | } |
| 142 | } |
| 143 | |
| 144 | func StreamNetHandler(tunnelConn io.ReadWriter, accessPolicy *ipaccess.Policy, log *zerolog.Logger) { |
| 145 | dialer := NewNetDialer() |
nothing calls this directly
no test coverage detected