New oauth2client

.config/config.go

@@ -0,0 +1,115 @@
+package config
+
+import (
+	"local/rproxy3/storage/packable"
+	"log"
+	"strconv"
+	"strings"
+)
+
+func GetPort() string {
+	v := packable.NewString()
+	conf.Get(nsConf, flagPort, v)
+	return ":" + strings.TrimPrefix(v.String(), ":")
+}
+
+func GetRoutes() map[string]string {
+	v := packable.NewString()
+	conf.Get(nsConf, flagRoutes, v)
+	m := make(map[string]string)
+	for _, v := range strings.Split(v.String(), ",") {
+		if len(v) == 0 {
+			return m
+		}
+		from := v[:strings.Index(v, ":")]
+		to := v[strings.Index(v, ":")+1:]
+		m[from] = to
+	}
+	return m
+}
+
+func GetTCP() (string, bool) {
+	v := packable.NewString()
+	conf.Get(nsConf, flagTCP, v)
+	tcpAddr := v.String()
+	return tcpAddr, notEmpty(tcpAddr)
+}
+
+func GetSSL() (string, string, bool) {
+	v := packable.NewString()
+	conf.Get(nsConf, flagCert, v)
+	certPath := v.String()
+	conf.Get(nsConf, flagKey, v)
+	keyPath := v.String()
+	return certPath, keyPath, notEmpty(certPath, keyPath)
+}
+
+func GetAuth() (string, string, bool) {
+	v := packable.NewString()
+	conf.Get(nsConf, flagUser, v)
+	user := v.String()
+	conf.Get(nsConf, flagPass, v)
+	pass := v.String()
+	return user, pass, notEmpty(user, pass)
+}
+
+func notEmpty(s ...string) bool {
+	for i := range s {
+		if s[i] == "" || s[i] == "/dev/null" {
+			return false
+		}
+	}
+	return true
+}
+
+func GetRate() (int, int) {
+	r := packable.NewString()
+	conf.Get(nsConf, flagRate, r)
+	b := packable.NewString()
+	conf.Get(nsConf, flagBurst, b)
+
+	rate, err := strconv.Atoi(r.String())
+	if err != nil {
+		log.Printf("illegal rate: %v", err)
+		rate = 5
+	}
+	burst, _ := strconv.Atoi(b.String())
+	if err != nil {
+		log.Printf("illegal burst: %v", err)
+		burst = 5
+	}
+
+	return rate, burst
+}
+
+func GetTimeout() int {
+	t := packable.NewString()
+	conf.Get(nsConf, flagTimeout, t)
+
+	timeout, err := strconv.Atoi(t.String())
+	if err != nil || timeout == 5 {
+		return 5
+	}
+
+	return timeout
+}
+
+func GetRewrites(hostMatch string) map[string]string {
+	v := packable.NewString()
+	conf.Get(nsConf, flagRewrites, v)
+	m := make(map[string]string)
+	for _, v := range strings.Split(v.String(), ",") {
+		vs := strings.Split(v, ":")
+		if len(v) < 3 {
+			continue
+		}
+		host := vs[0]
+		if host != hostMatch {
+			continue
+		}
+		from := vs[1]
+		to := strings.Join(vs[2:], ":")
+		m[from] = to
+	}
+	return m
+}

.config/new.go

@@ -0,0 +1,161 @@
+package config
+
+import (
+	"flag"
+	"io/ioutil"
+	"local/rproxy3/storage"
+	"local/rproxy3/storage/packable"
+	"log"
+	"os"
+	"strings"
+
+	yaml "gopkg.in/yaml.v2"
+)
+
+const nsConf = "configuration"
+const flagPort = "p"
+const flagRoutes = "r"
+const flagConf = "c"
+const flagCert = "crt"
+const flagTCP = "tcp"
+const flagKey = "key"
+const flagUser = "user"
+const flagPass = "pass"
+const flagRate = "rate"
+const flagBurst = "burst"
+const flagTimeout = "timeout"
+const flagRewrites = "rw"
+
+var conf = storage.NewMap()
+
+type toBind struct {
+	flag  string
+	value *string
+}
+
+type fileConf struct {
+	Port     string   `yaml:"p"`
+	Routes   []string `yaml:"r"`
+	CertPath string   `yaml:"crt"`
+	TCPPath  string   `yaml:"tcp"`
+	KeyPath  string   `yaml:"key"`
+	Username string   `yaml:"user"`
+	Password string   `yaml:"pass"`
+	Rate     string   `yaml:"rate"`
+	Burst    string   `yaml:"burst"`
+	Timeout  string   `yaml:"timeout"`
+	Rewrites []string `yaml:"rw"`
+}
+
+func Init() error {
+	log.SetFlags(log.Ldate | log.Ltime | log.Llongfile)
+	log.SetFlags(log.Ltime | log.Lshortfile)
+	if err := fromFile(); err != nil {
+		return err
+	}
+	if err := fromFlags(); err != nil {
+		return err
+	}
+	return nil
+}
+
+func fromFile() error {
+	flag.CommandLine = flag.NewFlagSet(os.Args[0], flag.ContinueOnError)
+	defer func() {
+		flag.CommandLine = flag.NewFlagSet(os.Args[0], flag.ExitOnError)
+	}()
+	flag.String(flagConf, "/dev/null", "yaml config file path")
+	flag.Parse()
+	confFlag := flag.Lookup(flagConf)
+	if confFlag == nil || confFlag.Value.String() == "" {
+		return nil
+	}
+	confBytes, err := ioutil.ReadFile(confFlag.Value.String())
+	if err != nil {
+		return err
+	}
+	var c fileConf
+	if err := yaml.Unmarshal(confBytes, &c); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagPort, packable.NewString(c.Port)); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagRoutes, packable.NewString(strings.Join(c.Routes, ","))); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagCert, packable.NewString(c.CertPath)); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagTCP, packable.NewString(c.TCPPath)); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagKey, packable.NewString(c.KeyPath)); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagUser, packable.NewString(c.Username)); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagPass, packable.NewString(c.Password)); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagRate, packable.NewString(c.Rate)); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagBurst, packable.NewString(c.Burst)); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagTimeout, packable.NewString(c.Timeout)); err != nil {
+		return err
+	}
+	if err := conf.Set(nsConf, flagRewrites, packable.NewString(strings.Join(c.Rewrites, ","))); err != nil {
+		return err
+	}
+	return nil
+}
+
+func fromFlags() error {
+	binds := make([]toBind, 0)
+	binds = append(binds, addFlag(flagPort, "51555", "port to bind to"))
+	binds = append(binds, addFlag(flagConf, "", "configuration file path"))
+	binds = append(binds, addFlag(flagRoutes, "", "comma-separated routes to map, each as from:scheme://to.tld:port"))
+	binds = append(binds, addFlag(flagCert, "", "path to .crt"))
+	binds = append(binds, addFlag(flagTCP, "", "tcp addr"))
+	binds = append(binds, addFlag(flagKey, "", "path to .key"))
+	binds = append(binds, addFlag(flagUser, "", "basic auth username"))
+	binds = append(binds, addFlag(flagPass, "", "basic auth password"))
+	binds = append(binds, addFlag(flagRate, "100", "rate limit per second"))
+	binds = append(binds, addFlag(flagBurst, "100", "rate limit burst"))
+	binds = append(binds, addFlag(flagTimeout, "30", "seconds to wait for limiter"))
+	binds = append(binds, addFlag(flagRewrites, "", "comma-separated from:replace:replacement:oauth to rewrite in response bodies"))
+	flag.Parse()
+
+	for _, bind := range binds {
+		confFlag := flag.Lookup(bind.flag)
+		if confFlag == nil || confFlag.Value.String() == "" {
+			continue
+		}
+		if err := conf.Set(nsConf, bind.flag, packable.NewString(*bind.value)); err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+func addFlag(key, def, help string) toBind {
+	def = getFlagOrDefault(key, def)
+	v := flag.String(key, def, help)
+	return toBind{
+		flag:  key,
+		value: v,
+	}
+}
+
+func getFlagOrDefault(key, def string) string {
+	v := packable.NewString()
+	if err := conf.Get(nsConf, key, v); err != nil {
+		return def
+	}
+	return v.String()
+}

.gitignore

@@ -1,6 +1,10 @@
 lz4
 rclone
 rcloner
+exec
+exec-*
+**/exec
+**/exec-*
 Go
 cloudly
 dockfile

Dockerfile

@@ -0,0 +1,16 @@
+
+FROM golang:1.13-alpine as certs
+RUN apk update && apk add --no-cache ca-certificates
+
+FROM busybox:glibc
+RUN mkdir -p /var/log
+WORKDIR /main
+COPY --from=certs /etc/ssl/certs /etc/ssl/certs
+
+COPY . .
+
+ENV GOPATH=""
+ENV MNT="/mnt/"
+ENTRYPOINT ["/main/exec-rproxy3"]
+CMD []
+

conf.yaml

@@ -1,11 +0,0 @@
-p: 54243
-r: 
-- echo:http://localhost:49982
-- echo2:http://192.168.0.86:38090
-#crt: ./testdata/rproxy3server.crt
-#key: ./testdata/rproxy3server.key
-#user: bel
-#pass: bel
-rate: 1
-burst: 2
-timeout: 10

config/config.go

@@ -1,76 +1,75 @@
 package config
 
 import (
-	"local/rproxy3/storage/packable"
+	"fmt"
-	"strconv"
+	"log"
 	"strings"
+	"time"
 )
 
-func GetPort() string {
+type Proxy struct {
-	v := packable.NewString()
+	To string
-	conf.Get(nsConf, flagPort, v)
-	return ":" + strings.TrimPrefix(v.String(), ":")
 }
 
-func GetRoutes() map[string]string {
+func parseProxy(s string) (string, Proxy) {
-	v := packable.NewString()
+	p := Proxy{}
-	conf.Get(nsConf, flagRoutes, v)
+	key := ""
-	m := make(map[string]string)
+	l := strings.Split(s, ",")
-	for _, v := range strings.Split(v.String(), ",") {
+	if len(l) > 0 {
-		if len(v) == 0 {
+		key = l[0]
-			return m
 	}
-		from := v[:strings.Index(v, ":")]
+	if len(l) > 1 {
-		to := v[strings.Index(v, ":")+1:]
+		p.To = l[1]
-		m[from] = to
 	}
-	return m
+	return key, p
 }
 
-func GetSSL() (string, string, bool) {
+func GetBOAuthZ() (string, bool) {
-	v := packable.NewString()
+	boauthz := conf.Get("oauth").GetString()
-	conf.Get(nsConf, flagCert, v)
+	return boauthz, boauthz != ""
-	certPath := v.String()
-	conf.Get(nsConf, flagKey, v)
-	keyPath := v.String()
-	return certPath, keyPath, notEmpty(certPath, keyPath)
 }
 
 func GetAuth() (string, string, bool) {
-	v := packable.NewString()
+	user := conf.Get("user").GetString()
-	conf.Get(nsConf, flagUser, v)
+	pass := conf.Get("pass").GetString()
-	user := v.String()
+	return user, pass, user != "" && pass != ""
-	conf.Get(nsConf, flagPass, v)
-	pass := v.String()
-	return user, pass, notEmpty(user, pass)
 }
 
-func notEmpty(s ...string) bool {
+func GetPort() string {
-	for i := range s {
+	port := conf.Get("p").GetInt()
-		if s[i] == "" || s[i] == "/dev/null" {
+	return ":" + fmt.Sprint(port)
-			return false
-		}
-	}
-	return true
 }
 
 func GetRate() (int, int) {
-	r := packable.NewString()
+	rate := conf.Get("r").GetInt()
-	conf.Get(nsConf, flagRate, r)
+	burst := conf.Get("b").GetInt()
-	b := packable.NewString()
+	log.Println("rate/burst:", rate, burst)
-	conf.Get(nsConf, flagBurst, b)
-
-	rate, _ := strconv.Atoi(r.String())
-	burst, _ := strconv.Atoi(b.String())
-
 	return rate, burst
 }
 
-func GetTimeout() int {
+func GetRoutes() map[string]Proxy {
-	t := packable.NewString()
+	list := conf.Get("proxy").GetString()
-	conf.Get(nsConf, flagTimeout, t)
+	definitions := strings.Split(list, ",,")
+	routes := make(map[string]Proxy)
+	for _, definition := range definitions {
+		k, v := parseProxy(definition)
+		routes[k] = v
+	}
+	return routes
+}
 
-	timeout, _ := strconv.Atoi(t.String())
+func GetSSL() (string, string, bool) {
+	crt := conf.Get("crt").GetString()
+	key := conf.Get("key").GetString()
+	return crt, key, crt != "" && key != ""
+}
 
+func GetTCP() (string, bool) {
+	tcp := conf.Get("tcp").GetString()
+	return tcp, tcp != ""
+}
+
+func GetTimeout() time.Duration {
+	timeout := conf.Get("timeout").GetDuration()
 	return timeout
 }

config/new.go

@@ -1,148 +1,53 @@
 package config
 
 import (
-	"flag"
+	"fmt"
-	"io/ioutil"
+	"local/args"
-	"local/rproxy3/storage"
-	"local/rproxy3/storage/packable"
 	"log"
 	"os"
 	"strings"
-
+	"time"
-	yaml "gopkg.in/yaml.v2"
 )
 
-const nsConf = "configuration"
+var conf *args.ArgSet
-const flagPort = "p"
-const flagRoutes = "r"
-const flagConf = "c"
-const flagCert = "crt"
-const flagKey = "key"
-const flagUser = "user"
-const flagPass = "pass"
-const flagRate = "rate"
-const flagBurst = "burst"
-const flagTimeout = "timeout"
 
-var conf = storage.NewMap()
+func init() {
-
+	if err := Refresh(); err != nil {
-type toBind struct {
+		panic(err)
-	flag  string
+	}
-	value *string
 }
 
-type fileConf struct {
+func Refresh() error {
-	Port     string   `yaml:"p"`
-	Routes   []string `yaml:"r"`
-	CertPath string   `yaml:"crt"`
-	KeyPath  string   `yaml:"key"`
-	Username string   `yaml:"user"`
-	Password string   `yaml:"pass"`
-	Rate     string   `yaml:"rate"`
-	Burst    string   `yaml:"burst"`
-	Timeout  string   `yaml:"timeout"`
-}
-
-func Init() error {
 	log.SetFlags(log.Ldate | log.Ltime | log.Llongfile)
-	if err := fromFile(); err != nil {
+	log.SetFlags(log.Ltime | log.Lshortfile)
-		return err
+
-	}
+	as, err := parseArgs()
-	if err := fromFlags(); err != nil {
+	if err != nil && !strings.Contains(fmt.Sprint(os.Args), "-test") {
 		return err
 	}
+	conf = as
 	return nil
 }
 
-func fromFile() error {
+func parseArgs() (*args.ArgSet, error) {
-	flag.CommandLine = flag.NewFlagSet(os.Args[0], flag.ContinueOnError)
+	configFiles := []string{}
-	defer func() {
+	if v, ok := os.LookupEnv("CONFIG"); ok {
-		flag.CommandLine = flag.NewFlagSet(os.Args[0], flag.ExitOnError)
+		configFiles = strings.Split(v, ",")
-	}()
-	flag.String(flagConf, "/dev/null", "yaml config file path")
-	flag.Parse()
-	confFlag := flag.Lookup(flagConf)
-	if confFlag == nil || confFlag.Value.String() == "" {
-		return nil
-	}
-	confBytes, err := ioutil.ReadFile(confFlag.Value.String())
-	if err != nil {
-		return err
-	}
-	var c fileConf
-	if err := yaml.Unmarshal(confBytes, &c); err != nil {
-		return err
-	}
-	if err := conf.Set(nsConf, flagPort, packable.NewString(c.Port)); err != nil {
-		return err
-	}
-	if err := conf.Set(nsConf, flagRoutes, packable.NewString(strings.Join(c.Routes, ","))); err != nil {
-		return err
-	}
-	if err := conf.Set(nsConf, flagCert, packable.NewString(c.CertPath)); err != nil {
-		return err
-	}
-	if err := conf.Set(nsConf, flagKey, packable.NewString(c.KeyPath)); err != nil {
-		return err
-	}
-	if err := conf.Set(nsConf, flagUser, packable.NewString(c.Username)); err != nil {
-		return err
-	}
-	if err := conf.Set(nsConf, flagPass, packable.NewString(c.Password)); err != nil {
-		return err
-	}
-	if err := conf.Set(nsConf, flagRate, packable.NewString(c.Rate)); err != nil {
-		return err
-	}
-	if err := conf.Set(nsConf, flagBurst, packable.NewString(c.Burst)); err != nil {
-		return err
-	}
-	if err := conf.Set(nsConf, flagTimeout, packable.NewString(c.Timeout)); err != nil {
-		return err
-	}
-	return nil
 	}
+	as := args.NewArgSet(configFiles...)
 
-func fromFlags() error {
+	as.Append(args.STRING, "user", "username for basic auth", "")
-	binds := make([]toBind, 0)
+	as.Append(args.STRING, "pass", "password for basic auth", "")
-	binds = append(binds, addFlag(flagPort, "51555", "port to bind to"))
+	as.Append(args.INT, "p", "port for service", 51555)
-	binds = append(binds, addFlag(flagConf, "", "configuration file path"))
+	as.Append(args.INT, "r", "rate per second for requests", 100)
-	binds = append(binds, addFlag(flagRoutes, "", "comma-separated routes to map, each as from:scheme://to.tld:port"))
+	as.Append(args.INT, "b", "burst requests", 100)
-	binds = append(binds, addFlag(flagCert, "", "path to .crt"))
+	as.Append(args.STRING, "crt", "path to crt for ssl", "")
-	binds = append(binds, addFlag(flagKey, "", "path to .key"))
+	as.Append(args.STRING, "key", "path to key for ssl", "")
-	binds = append(binds, addFlag(flagUser, "", "basic auth username"))
+	as.Append(args.STRING, "tcp", "address for tcp only tunnel", "")
-	binds = append(binds, addFlag(flagPass, "", "basic auth password"))
+	as.Append(args.DURATION, "timeout", "timeout for tunnel", time.Minute)
-	binds = append(binds, addFlag(flagRate, "100", "rate limit per second"))
+	as.Append(args.STRING, "proxy", "double-comma separated (+ if oauth)from,scheme://to.tld:port,oauth,,", "")
-	binds = append(binds, addFlag(flagBurst, "100", "rate limit burst"))
+	as.Append(args.STRING, "oauth", "url for boauthz", "")
-	binds = append(binds, addFlag(flagTimeout, "30", "seconds to wait for limiter"))
-	flag.Parse()
 
-	for _, bind := range binds {
+	err := as.Parse()
-		confFlag := flag.Lookup(bind.flag)
+	return as, err
-		if confFlag == nil || confFlag.Value.String() == "" {
-			continue
-		}
-		if err := conf.Set(nsConf, bind.flag, packable.NewString(*bind.value)); err != nil {
-			return err
-		}
-	}
-
-	return nil
-}
-
-func addFlag(key, def, help string) toBind {
-	def = getFlagOrDefault(key, def)
-	v := flag.String(key, def, help)
-	return toBind{
-		flag:  key,
-		value: v,
-	}
-}
-
-func getFlagOrDefault(key, def string) string {
-	v := packable.NewString()
-	if err := conf.Get(nsConf, key, v); err != nil {
-		return def
-	}
-	return v.String()
 }

example_config.yaml

@@ -0,0 +1,11 @@
+user: ""
+pass: ""
+port: 51555
+r: 100
+b: 100
+crt: ""
+key: ""
+tcp: ""
+timeout: 1m
+proxy: a,http://localhost:41912,,+b,http://localhost:41912
+oauth: http://localhost:23456

main.go

@@ -6,7 +6,7 @@ import (
 )
 
 func main() {
-	if err := config.Init(); err != nil {
+	if err := config.Refresh(); err != nil {
 		panic(err)
 	}
 

main_test.go

@@ -34,8 +34,8 @@ func TestHTTPSMain(t *testing.T) {
 			"username",
 			"-pass",
 			"password",
-			"-r",
+			"-proxy",
-			"hello:" + addr,
+			"hello," + addr,
 			"-crt",
 			"./testdata/rproxy3server.crt",
 			"-key",
@@ -51,7 +51,7 @@ func TestHTTPSMain(t *testing.T) {
 			TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
 		},
 	}
-	r, _ := http.NewRequest("GET", "https://hello.localhost"+port, nil)
+	r, _ := http.NewRequest("GET", "https://hello.localhost:"+port, nil)
 
 	if resp, err := client.Do(r); err != nil {
 		t.Fatalf("client failed: %v", err)
@@ -89,8 +89,8 @@ func TestHTTPMain(t *testing.T) {
 			"username",
 			"-pass",
 			"password",
-			"-r",
+			"-proxy",
-			"hello:" + addr,
+			"hello," + addr,
 		}
 		main()
 	}()
@@ -98,7 +98,7 @@ func TestHTTPMain(t *testing.T) {
 	time.Sleep(time.Millisecond * 100)
 
 	client := &http.Client{}
-	r, _ := http.NewRequest("GET", "http://hello.localhost"+port, nil)
+	r, _ := http.NewRequest("GET", "http://hello.localhost:"+port, nil)
 
 	if resp, err := client.Do(r); err != nil {
 		t.Fatalf("client failed: %v", err)
@@ -127,5 +127,5 @@ func echoServer() (string, func()) {
 func getPort() string {
 	s := httptest.NewServer(nil)
 	s.Close()
-	return s.URL[strings.LastIndex(s.URL, ":"):]
+	return s.URL[strings.LastIndex(s.URL, ":")+1:]
 }

server/proxy.go

@@ -1,6 +1,9 @@
 package server
 
 import (
+	"bytes"
+	"crypto/tls"
+	"io"
 	"local/rproxy3/storage/packable"
 	"log"
 	"net/http"
@@ -12,13 +15,22 @@ import (
 type redirPurge struct {
 	proxyHost     string
 	targetHost    string
+	baseTransport http.RoundTripper
+}
+
+type rewrite struct {
+	rewrites      map[string]string
+	baseTransport http.RoundTripper
 }
 
 func (s *Server) Proxy(w http.ResponseWriter, r *http.Request) {
-	newURL, err := s.lookup(r.Host)
+	newURL, err := s.lookup(mapKey(r.Host))
-	transport := &redirPurge{
+	var transport http.RoundTripper
+	http.DefaultTransport.(*http.Transport).TLSClientConfig = &tls.Config{InsecureSkipVerify: true}
+	transport = &redirPurge{
 		proxyHost:     r.Host,
 		targetHost:    newURL.Host,
+		baseTransport: http.DefaultTransport,
 	}
 	if err != nil {
 		http.NotFound(w, r)
@@ -32,15 +44,25 @@ func (s *Server) Proxy(w http.ResponseWriter, r *http.Request) {
 }
 
 func (s *Server) lookup(host string) (*url.URL, error) {
-	host = strings.Split(host, ".")[0]
-	host = strings.Split(host, ":")[0]
 	v := packable.NewURL()
 	err := s.db.Get(nsRouting, host, v)
 	return v.URL(), err
 }
 
+func (s *Server) lookupBOAuthZ(host string) (bool, error) {
+	v := packable.NewString()
+	err := s.db.Get(nsBOAuthZ, host, v)
+	return v.String() == "true", err
+}
+
+func mapKey(host string) string {
+	host = strings.Split(host, ".")[0]
+	host = strings.Split(host, ":")[0]
+	return host
+}
+
 func (rp *redirPurge) RoundTrip(r *http.Request) (*http.Response, error) {
-	resp, err := http.DefaultTransport.RoundTrip(r)
+	resp, err := rp.baseTransport.RoundTrip(r)
 	if err != nil {
 		return resp, err
 	}
@@ -49,3 +71,40 @@ func (rp *redirPurge) RoundTrip(r *http.Request) (*http.Response, error) {
 	}
 	return resp, err
 }
+
+func (rw *rewrite) RoundTrip(r *http.Request) (*http.Response, error) {
+	resp, err := rw.baseTransport.RoundTrip(r)
+	if err != nil {
+		return resp, err
+	}
+	if len(rw.rewrites) == 0 {
+		return resp, err
+	}
+	resp.Header.Del("Content-Length")
+	pr, pw := io.Pipe()
+	body := resp.Body
+	resp.Body = pr
+	go func() {
+		buff := make([]byte, 1024)
+		n, err := body.Read(buff)
+		for err == nil || n > 0 {
+			chunk := buff[:n]
+			for k, v := range rw.rewrites {
+				chunk = bytes.Replace(chunk, []byte(k), []byte(v), -1)
+			}
+			n = len(chunk)
+			m := 0
+			for m < n {
+				l, err := pw.Write(chunk[m:])
+				if err != nil {
+					pw.CloseWithError(err)
+					return
+				}
+				m += l
+			}
+			n, err = body.Read(buff)
+		}
+		pw.CloseWithError(err)
+	}()
+	return resp, err
+}

server/proxy_test.go

@@ -1,3 +1,42 @@
 package server
 
+import (
+	"io/ioutil"
+	"net/http"
+	"strings"
+	"testing"
+)
+
+type fakeTransport struct{}
+
+func (ft fakeTransport) RoundTrip(r *http.Request) (*http.Response, error) {
+	return &http.Response{
+		Body: r.Body,
+	}, nil
+}
+
 // empty url -> OK   //TODO
+func TestRewrite(t *testing.T) {
+	transport := &rewrite{
+		rewrites: map[string]string{
+			"a": "b",
+		},
+		baseTransport: fakeTransport{},
+	}
+
+	r, err := http.NewRequest("GET", "asdf", strings.NewReader("mary had a little lamb"))
+	if err != nil {
+		t.Fatal(err)
+	}
+	resp, err := transport.RoundTrip(r)
+	if err != nil {
+		t.Fatal(err)
+	}
+	b, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if string(b) != "mbry hbd b little lbmb" {
+		t.Errorf("failed to replace: got %q, want \"b\"", b)
+	}
+}

server/server.go

@@ -5,10 +5,14 @@ import (
 	"crypto/tls"
 	"encoding/base64"
 	"errors"
+	"fmt"
+	"io"
+	"local/oauth2/oauth2client"
 	"local/rproxy3/config"
 	"local/rproxy3/storage"
 	"local/rproxy3/storage/packable"
 	"log"
+	"net"
 	"net/http"
 	"net/url"
 	"strings"
@@ -18,12 +22,14 @@ import (
 )
 
 const nsRouting = "routing"
+const nsBOAuthZ = "oauth"
 
 type listenerScheme int
 
 const (
 	schemeHTTP  listenerScheme = iota
 	schemeHTTPS listenerScheme = iota
+	schemeTCP   listenerScheme = iota
 )
 
 func (ls listenerScheme) String() string {
@@ -32,6 +38,8 @@ func (ls listenerScheme) String() string {
 		return "http"
 	case schemeHTTPS:
 		return "https"
+	case schemeTCP:
+		return "tcp"
 	}
 	return ""
 }
@@ -44,12 +52,15 @@ type Server struct {
 	limiter  *rate.Limiter
 }
 
-func (s *Server) Route(src, dst string) error {
+func (s *Server) Route(src string, dst config.Proxy) error {
-	log.Printf("Adding route %q -> %q...\n", src, dst)
+	hasOAuth := strings.HasPrefix(src, "+")
-	u, err := url.Parse(dst)
+	src = strings.TrimPrefix(src, "+")
+	log.Printf("Adding route %q -> %v...\n", src, dst)
+	u, err := url.Parse(dst.To)
 	if err != nil {
 		return err
 	}
+	s.db.Set(nsBOAuthZ, src, packable.NewString(fmt.Sprint(hasOAuth)))
 	return s.db.Set(nsRouting, src, packable.NewURL(u))
 }
 
@@ -58,6 +69,9 @@ func (s *Server) Run() error {
 	if _, _, ok := config.GetSSL(); ok {
 		scheme = schemeHTTPS
 	}
+	if _, ok := config.GetTCP(); ok {
+		scheme = schemeTCP
+	}
 	log.Printf("Listening for %v on %v...\n", scheme, s.addr)
 	switch scheme {
 	case schemeHTTP:
@@ -83,6 +97,10 @@ func (s *Server) Run() error {
 			TLSNextProto: make(map[string]func(*http.Server, *tls.Conn, http.Handler), 0),
 		}
 		return httpsServer.ListenAndServeTLS(c, k)
+	case schemeTCP:
+		log.Printf("Serve tcp")
+		addr, _ := config.GetTCP()
+		return s.ServeTCP(addr)
 	}
 	return errors.New("did not load server")
 }
@@ -91,7 +109,6 @@ func (s *Server) doAuth(foo http.HandlerFunc) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
 		rusr, rpwd, ok := config.GetAuth()
 		if ok {
-			//usr, pwd := getProxyAuth(r)
 			usr, pwd, ok := r.BasicAuth()
 			if !ok || rusr != usr || rpwd != pwd {
 				w.WriteHeader(http.StatusUnauthorized)
@@ -99,13 +116,55 @@ func (s *Server) doAuth(foo http.HandlerFunc) http.HandlerFunc {
 				return
 			}
 		}
+		key := mapKey(r.Host)
+		ok, err := s.lookupBOAuthZ(key)
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			return
+		}
+		if url, exists := config.GetBOAuthZ(); ok && exists {
+			err := oauth2client.Authenticate(url, key, w, r)
+			if err != nil {
+				return
+			}
+		}
 		foo(w, r)
 	}
 }
 
+func (s *Server) ServeTCP(addr string) error {
+	listen, err := net.Listen("tcp", s.addr)
+	if err != nil {
+		return err
+	}
+	for {
+		c, err := listen.Accept()
+		if err != nil {
+			return err
+		}
+		go func(c net.Conn) {
+			d, err := net.Dial("tcp", addr)
+			if err != nil {
+				log.Println(err)
+				return
+			}
+			go pipe(c, d)
+			go pipe(d, c)
+		}(c)
+	}
+}
+
+func pipe(a, b net.Conn) {
+	log.Println("open pipe")
+	defer log.Println("close pipe")
+	defer a.Close()
+	defer b.Close()
+	io.Copy(a, b)
+}
+
 func (s *Server) Pre(foo http.HandlerFunc) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
-		ctx, can := context.WithTimeout(r.Context(), time.Second*time.Duration(config.GetTimeout()))
+		ctx, can := context.WithTimeout(r.Context(), time.Duration(config.GetTimeout()))
 		defer can()
 		if err := s.limiter.Wait(ctx); err != nil {
 			w.WriteHeader(http.StatusTooManyRequests)

server/server_test.go

@@ -1,18 +1,25 @@
 package server
 
 import (
+	"context"
 	"fmt"
+	"local/rproxy3/config"
 	"local/rproxy3/storage"
 	"net/http"
 	"net/http/httptest"
 	"strings"
 	"testing"
+
+	"golang.org/x/time/rate"
 )
 
 func TestServerStart(t *testing.T) {
 	server := mockServer()
 
-	if err := server.Route("world", "http://hello.localhost"+server.addr); err != nil {
+	p := config.Proxy{
+		To: "http://hello.localhost" + server.addr,
+	}
+	if err := server.Route("world", p); err != nil {
 		t.Fatalf("cannot add route: %v", err)
 	}
 
@@ -35,6 +42,7 @@ func mockServer() *Server {
 	s := &Server{
 		db:      storage.NewMap(),
 		addr:    ":" + port,
+		limiter: rate.NewLimiter(rate.Limit(50), 50),
 	}
 	if err := s.Routes(); err != nil {
 		panic(fmt.Sprintf("cannot initiate server routes; %v", err))
@@ -44,11 +52,15 @@ func mockServer() *Server {
 
 func TestServerRoute(t *testing.T) {
 	server := mockServer()
-	if err := server.Route("world", "http://hello.localhost"+server.addr); err != nil {
+	p := config.Proxy{
+		To: "http://hello.localhost" + server.addr,
+	}
+	if err := server.Route("world", p); err != nil {
 		t.Fatalf("cannot add route: %v", err)
 	}
 	w := httptest.NewRecorder()
 	r, _ := http.NewRequest("GET", "http://world.localhost"+server.addr, nil)
+	r = r.WithContext(context.Background())
 	server.ServeHTTP(w, r)
 	if w.Code != 502 {
 		t.Fatalf("cannot proxy from 'world' to 'hello', status %v", w.Code)

testdata/index.html

@@ -0,0 +1,36 @@
+<!DOCTYPE html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <meta http-equiv="X-UA-Compatible" content="ie=edge" />
+    <title>Go WebSocket Tutorial</title>
+  </head>
+  <body>
+    <h2>Hello World</h2>
+
+    <script>
+        let socket = new WebSocket("ws://a.bel.test:51555/ws");
+         document.getElementsByTagName("body")[0].innerHTML += "<br>connecting";
+
+        socket.onopen = () => {
+            document.getElementsByTagName("body")[0].innerHTML += "<br>connected";
+            socket.send("Hi From the Client!")
+        };
+
+        socket.onclose = event => {
+            document.getElementsByTagName("body")[0].innerHTML += "<br>disconnected";
+            socket.send("Client Closed!")
+        };
+
+        socket.onerror = error => {
+            document.getElementsByTagName("body")[0].innerHTML += "<br>error:" + error;
+            console.log("Socket Error: ", error);
+        };
+        socket.onmessage = function(msgevent) {
+            document.getElementsByTagName("body")[0].innerHTML += "<br>got:" + msgevent.data;
+        };
+
+    </script>
+  </body>
+</html>

testdata/ws.go

@@ -0,0 +1,76 @@
+package main
+
+import (
+	"fmt"
+	"io/ioutil"
+	"log"
+	"net/http"
+	"time"
+
+	"github.com/gorilla/websocket"
+)
+
+func homePage(w http.ResponseWriter, r *http.Request) {
+	b, _ := ioutil.ReadFile("./index.html")
+	fmt.Fprintf(w, "%s", b)
+}
+
+func setupRoutes() {
+	http.HandleFunc("/", homePage)
+	http.HandleFunc("/ws", wsEndpoint)
+}
+
+func main() {
+	fmt.Println("Hello World")
+	setupRoutes()
+	log.Fatal(http.ListenAndServe(":8080", nil))
+}
+
+var upgrader = websocket.Upgrader{
+	ReadBufferSize:  1024,
+	WriteBufferSize: 1024,
+}
+
+func reader(conn *websocket.Conn) {
+	for {
+		// read in a message
+		messageType, p, err := conn.ReadMessage()
+		if err != nil {
+			log.Println(err)
+			return
+		}
+		// print out that message for clarity
+		fmt.Println(string(p))
+
+		if err := conn.WriteMessage(messageType, p); err != nil {
+			log.Println(err)
+			return
+		}
+
+	}
+}
+func wsEndpoint(w http.ResponseWriter, r *http.Request) {
+	upgrader.CheckOrigin = func(r *http.Request) bool { return true }
+
+	// upgrade this connection to a WebSocket
+	// connection
+	ws, err := upgrader.Upgrade(w, r, nil)
+	if err != nil {
+		log.Println(err)
+	}
+
+	log.Println("Client Connected")
+	// listen indefinitely for new messages coming
+	// through on our WebSocket connection
+	go reader(ws)
+	for {
+		log.Println("writing...")
+		err = ws.WriteMessage(1, []byte("Hi Client!"))
+		log.Println("written")
+		if err != nil {
+			log.Println(err)
+			return
+		}
+		time.Sleep(time.Second)
+	}
+}

vendor/vendor.json

@@ -1,25 +0,0 @@
-{
-	"comment": "",
-	"ignore": "test",
-	"package": [
-		{
-			"checksumSHA1": "GtamqiJoL7PGHsN454AoffBFMa8=",
-			"path": "golang.org/x/net/context",
-			"revision": "65e2d4e15006aab9813ff8769e768bbf4bb667a0",
-			"revisionTime": "2019-02-01T23:59:58Z"
-		},
-		{
-			"checksumSHA1": "HoCvrd3hEhsFeBOdEw7cbcfyk50=",
-			"path": "golang.org/x/time/rate",
-			"revision": "fbb02b2291d28baffd63558aa44b4b56f178d650",
-			"revisionTime": "2018-04-12T16:56:04Z"
-		},
-		{
-			"checksumSHA1": "QqDq2x8XOU7IoOR98Cx1eiV5QY8=",
-			"path": "gopkg.in/yaml.v2",
-			"revision": "51d6538a90f86fe93ac480b35f37b2be17fef232",
-			"revisionTime": "2018-11-15T11:05:04Z"
-		}
-	],
-	"rootPath": "local/rproxy3"
-}