Revert "lib/tunnel: use httputil.ReverseProxy"

This reverts commit 48327a7669.

lib/tunnel/httpproxy.go

@@ -7,12 +7,9 @@ import (
 	"io/ioutil"
 	"net"
 	"net/http"
-	"net/http/httputil"
-	"net/url"
-	"sync"
 
-	"git.xeserv.us/xena/route/lib/tunnel/proto"
 	"github.com/koding/logging"
+	"git.xeserv.us/xena/route/lib/tunnel/proto"
 )
 
 var (
@@ -32,6 +29,9 @@ type HTTPProxy struct {
 	// LocalAddr defines the TCP address of the local server.
 	// This is optional if you want to specify a single TCP address.
 	LocalAddr string
+	// FetchLocalAddr is used for looking up TCP address of the server.
+	// This is optional if you want to specify a dynamic TCP address based on incommig port.
+	FetchLocalAddr func(port int) (string, error)
 	// ErrorResp is custom response send to tunnel server when client cannot
 	// establish connection to local server. If not set a default "no local server"
 	// response is sent.
@@ -39,9 +39,6 @@ type HTTPProxy struct {
 	// Log is a custom logger that can be used for the proxy.
 	// If not set a "http" logger is used.
 	Log logging.Logger
-
-	hs *http.Server
-	rp *httputil.ReverseProxy
 }
 
 // Proxy is a ProxyFunc.
@@ -60,28 +57,25 @@ func (p *HTTPProxy) Proxy(remote net.Conn, msg *proto.ControlMessage) {
 	var localAddr = fmt.Sprintf("127.0.0.1:%d", port)
 	if p.LocalAddr != "" {
 		localAddr = p.LocalAddr
-	}
-
-	if p.hs == nil {
-		su, _ := url.Parse(fmt.Sprintf("http://%s", p.LocalAddr))
-		p.rp = httputil.NewSingleHostReverseProxy(su)
-		p.hs = &http.Server{
-			Handler: p.rp,
+	} else if p.FetchLocalAddr != nil {
+		l, err := p.FetchLocalAddr(msg.LocalPort)
+		if err != nil {
+			log.Warning("Failed to get custom local address: %s", err)
+			p.sendError(remote)
+			return
 		}
+		localAddr = l
 	}
 
 	log.Debug("Dialing local server %q", localAddr)
-
-	sl := singleListener{
-		conn: remote,
-	}
-
-	err := p.hs.Serve(sl)
+	local, err := net.DialTimeout("tcp", localAddr, defaultTimeout)
 	if err != nil {
 		log.Error("Dialing local server %q failed: %s", localAddr, err)
 		p.sendError(remote)
 		return
 	}
+
+	Join(local, remote, log)
 }
 
 func (p *HTTPProxy) sendError(remote net.Conn) {
@@ -119,32 +113,3 @@ func (p *HTTPProxy) log() logging.Logger {
 	}
 	return httpLog
 }
-
-// A singleListener is a net.Listener that returns a single connection, then
-// gives the error io.EOF.
-type singleListener struct {
-	conn net.Conn
-	once sync.Once
-}
-
-func (s singleListener) Accept() (net.Conn, error) {
-	var c net.Conn
-	s.once.Do(func() {
-		c = s.conn
-	})
-	if c != nil {
-		return c, nil
-	}
-	return nil, io.EOF
-}
-
-func (s singleListener) Close() error {
-	s.once.Do(func() {
-		s.conn.Close()
-	})
-	return nil
-}
-
-func (s singleListener) Addr() net.Addr {
-	return s.conn.LocalAddr()
-}