Compare commits
No commits in common. "8ba42a09a4e62069d106fe7fa764f9ace95acb04" and "455db509286f2ae69bddb0e3139f9b344fb54a0a" have entirely different histories.
8ba42a09a4
...
455db50928
|
@ -24,15 +24,13 @@ func ver() string {
|
||||||
}
|
}
|
||||||
|
|
||||||
func usage() {
|
func usage() {
|
||||||
fmt.Fprintf(os.Stderr, "\n%s\n"+
|
fmt.Fprintf(os.Stderr, "\nsclient %s\n"+
|
||||||
"\nusage: sclient <remote> <local>\n"+
|
"\nusage: sclient <remote> <local>\n"+
|
||||||
"\n"+
|
"\n"+
|
||||||
" ex: sclient example.com 3000\n"+
|
" ex: sclient example.com 3000\n"+
|
||||||
" (sclient example.com:443 localhost:3000)\n"+
|
" (sclient example.com:443 localhost:3000)\n"+
|
||||||
"\n"+
|
"\n"+
|
||||||
" ex: sclient example.com:8443 0.0.0.0:4080\n"+
|
" ex: sclient example.com:8443 0.0.0.0:4080\n"+
|
||||||
"\n"+
|
|
||||||
" ex: sclient example.com:443 -\n"+
|
|
||||||
"\n", ver())
|
"\n", ver())
|
||||||
flag.PrintDefaults()
|
flag.PrintDefaults()
|
||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
@ -48,11 +46,9 @@ func main() {
|
||||||
}
|
}
|
||||||
|
|
||||||
flag.Usage = usage
|
flag.Usage = usage
|
||||||
insecure := flag.Bool("k", false, "alias for --insecure")
|
insecure := flag.Bool("k", false, "ignore bad TLS/SSL/HTTPS certificates")
|
||||||
silent := flag.Bool("s", false, "alias of --silent")
|
|
||||||
servername := flag.String("servername", "", "specify a servername different from <remote> (to disable SNI use an IP as <remote> and do use this option)")
|
servername := flag.String("servername", "", "specify a servername different from <remote> (to disable SNI use an IP as <remote> and do use this option)")
|
||||||
flag.BoolVar(insecure, "insecure", false, "ignore bad TLS/SSL/HTTPS certificates")
|
flag.BoolVar(insecure, "insecure", false, "ignore bad TLS/SSL/HTTPS certificates")
|
||||||
flag.BoolVar(silent, "silent", false, "less verbose output")
|
|
||||||
flag.Parse()
|
flag.Parse()
|
||||||
remotestr := flag.Arg(0)
|
remotestr := flag.Arg(0)
|
||||||
localstr := flag.Arg(1)
|
localstr := flag.Arg(1)
|
||||||
|
@ -73,7 +69,6 @@ func main() {
|
||||||
LocalAddress: "localhost",
|
LocalAddress: "localhost",
|
||||||
InsecureSkipVerify: *insecure,
|
InsecureSkipVerify: *insecure,
|
||||||
ServerName: *servername,
|
ServerName: *servername,
|
||||||
Silent: *silent,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
remote := strings.Split(remotestr, ":")
|
remote := strings.Split(remotestr, ":")
|
||||||
|
|
|
@ -18,7 +18,6 @@ type Tunnel struct {
|
||||||
LocalPort int
|
LocalPort int
|
||||||
InsecureSkipVerify bool
|
InsecureSkipVerify bool
|
||||||
ServerName string
|
ServerName string
|
||||||
Silent bool
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// DialAndListen will create a test TLS connection to the remote address and then
|
// DialAndListen will create a test TLS connection to the remote address and then
|
||||||
|
@ -46,7 +45,7 @@ func (t *Tunnel) DialAndListen() error {
|
||||||
} else {
|
} else {
|
||||||
name = "stdin"
|
name = "stdin"
|
||||||
}
|
}
|
||||||
conn := &stdnet{os.Stdin, os.Stdout, &stdaddr{net.UnixAddr{Name: name, Net: network}}}
|
conn := &stdnet{os.Stdin, os.Stdout, &stdaddr{net.UnixAddr{name, network}}}
|
||||||
t.handleConnection(remote, conn)
|
t.handleConnection(remote, conn)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
@ -58,10 +57,8 @@ func (t *Tunnel) DialAndListen() error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
if !t.Silent {
|
|
||||||
fmt.Fprintf(os.Stdout, "[listening] %s:%d <= %s:%d\n",
|
fmt.Fprintf(os.Stdout, "[listening] %s:%d <= %s:%d\n",
|
||||||
t.RemoteAddress, t.RemotePort, t.LocalAddress, t.LocalPort)
|
t.RemoteAddress, t.RemotePort, t.LocalAddress, t.LocalPort)
|
||||||
}
|
|
||||||
|
|
||||||
for {
|
for {
|
||||||
conn, err := ln.Accept()
|
conn, err := ln.Accept()
|
||||||
|
@ -113,7 +110,7 @@ func pipe(r netReadWriteCloser, w netReadWriteCloser, t string) {
|
||||||
if nil != err {
|
if nil != err {
|
||||||
//fmt.Fprintf(os.Stdout, "[debug] (%s:%d) error reading %s\n", t, count, err)
|
//fmt.Fprintf(os.Stdout, "[debug] (%s:%d) error reading %s\n", t, count, err)
|
||||||
if io.EOF != err {
|
if io.EOF != err {
|
||||||
fmt.Fprintf(os.Stderr, "[read error] (%s:%d) %s\n", t, count, err)
|
fmt.Fprintf(os.Stderr, "[read error] (%s:%s) %s\n", t, count, err)
|
||||||
}
|
}
|
||||||
r.Close()
|
r.Close()
|
||||||
//w.Close()
|
//w.Close()
|
||||||
|
@ -152,7 +149,6 @@ func (t *Tunnel) handleConnection(remote string, conn netReadWriteCloser) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if !t.Silent {
|
|
||||||
if "stdio" == conn.RemoteAddr().Network() {
|
if "stdio" == conn.RemoteAddr().Network() {
|
||||||
fmt.Fprintf(os.Stdout, "(connected to %s:%d and reading from %s)\n",
|
fmt.Fprintf(os.Stdout, "(connected to %s:%d and reading from %s)\n",
|
||||||
t.RemoteAddress, t.RemotePort, conn.RemoteAddr().String())
|
t.RemoteAddress, t.RemotePort, conn.RemoteAddr().String())
|
||||||
|
@ -160,7 +156,6 @@ func (t *Tunnel) handleConnection(remote string, conn netReadWriteCloser) {
|
||||||
fmt.Fprintf(os.Stdout, "[connect] %s => %s:%d\n",
|
fmt.Fprintf(os.Stdout, "[connect] %s => %s:%d\n",
|
||||||
strings.Replace(conn.RemoteAddr().String(), "[::1]:", "localhost:", 1), t.RemoteAddress, t.RemotePort)
|
strings.Replace(conn.RemoteAddr().String(), "[::1]:", "localhost:", 1), t.RemoteAddress, t.RemotePort)
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
go pipe(conn, sclient, "local")
|
go pipe(conn, sclient, "local")
|
||||||
pipe(sclient, conn, "remote")
|
pipe(sclient, conn, "remote")
|
||||||
|
|
|
@ -1,11 +0,0 @@
|
||||||
# I like my yoda conditions ST1017
|
|
||||||
checks = ["all", "-ST1017", "-ST1000", "-ST1003", "-ST1016", "-ST1020", "-ST1021", "-ST1022", "-ST1023"]
|
|
||||||
initialisms = ["ACL", "API", "ASCII", "CPU", "CSS", "DNS",
|
|
||||||
"EOF", "GUID", "HTML", "HTTP", "HTTPS", "ID",
|
|
||||||
"IP", "JSON", "QPS", "RAM", "RPC", "SLA",
|
|
||||||
"SMTP", "SQL", "SSH", "TCP", "TLS", "TTL",
|
|
||||||
"UDP", "UI", "GID", "UID", "UUID", "URI",
|
|
||||||
"URL", "UTF8", "VM", "XML", "XMPP", "XSRF",
|
|
||||||
"XSS", "SIP", "RTP", "AMQP", "DB", "TS"]
|
|
||||||
dot_import_whitelist = []
|
|
||||||
http_status_code_whitelist = ["200", "400", "404", "500"]
|
|
Loading…
Reference in New Issue