-
Notifications
You must be signed in to change notification settings - Fork 2
/
Copy pathmain.go
70 lines (53 loc) · 1.99 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
package main
import (
"crypto/tls"
"flag"
"fmt"
"log"
"net/http"
"net/http/httputil"
"os"
)
var publicPort = flag.String("public-port", "9999", "Public port on which to serve proxied content")
var internalPort = flag.String("internal-port", "9998", "Internal port on which your reverse SSH tunnel is listening")
var hostname = flag.String("hostname", "localhost", "Value of the Host http header for which your vhost is configured")
var scheme = flag.String("scheme", "http", "Use http or https locally")
var insecure = flag.Bool("insecure", false, "If your local server uses a self-signed cert, set this to true")
var requestLogger *log.Logger
var responseLogger *log.Logger
type transport struct {
http.RoundTripper
}
func (t *transport) RoundTrip(req *http.Request) (resp *http.Response, err error) {
resp, err = t.RoundTripper.RoundTrip(req)
if err != nil {
return nil, err
}
responseLog := resp.Status
if 301 == resp.StatusCode || 302 == resp.StatusCode {
responseLog = responseLog + " '" + resp.Request.URL.EscapedPath() + "'"
}
responseLogger.Println(responseLog)
return resp, nil
}
func main() {
requestLogger = log.New(os.Stdout, "[proxy]\t<-\t", log.LstdFlags)
responseLogger = log.New(os.Stdout, "[proxy]\t->\t", log.LstdFlags)
flag.Parse()
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
requestLogger.Println("[" + r.RemoteAddr + "]\t" + r.Method + " " + r.URL.EscapedPath())
director := func(req *http.Request) {
req.URL.Scheme = *scheme
req.URL.Host = "127.0.0.1:" + *internalPort
req.Host = *hostname
}
tr := &http.Transport{
TLSClientConfig: &tls.Config{InsecureSkipVerify: *insecure},
}
proxy := &httputil.ReverseProxy{Director: director, Transport: &transport{tr}}
proxy.ServeHTTP(w, r)
})
fmt.Println("Listening for external requests on port " + *publicPort)
fmt.Println("Forwarding traffic to " + *scheme + "://" + *hostname + "/ on port " + *internalPort)
requestLogger.Fatal(http.ListenAndServe(":"+*publicPort, nil))
}