@ -1,15 +1,23 @@
package obfssh
import (
"bufio"
"context"
"errors"
"fmt"
socks "github.com/fangdingjun/socks-go"
"golang.org/x/crypto/ssh"
"golang.org/x/crypto/ssh/terminal"
"net"
"net/http"
"os"
"os/signal"
"strings"
"sync"
"syscall"
"time"
"github.com/fangdingjun/go-log"
socks "github.com/fangdingjun/socks-go"
"golang.org/x/crypto/ssh"
"golang.org/x/crypto/ssh/terminal"
)
// Client is ssh client connection
@ -18,43 +26,30 @@ type Client struct {
sshConn ssh . Conn
client * ssh . Client
listeners [ ] net . Listener
ch chan struct { }
err error
ctx context . Context
cancel context . CancelFunc
}
// NewClient create a new ssh Client
//
// addr is server address
//
// method is obfs encrypt method, value is rc4, aes or none or ""
//
// key is obfs encrypt key
//
// conf is the client configure
//
// if set method to none or "", means disable the obfs,
// when the obfs is disabled, the client can connect to standard ssh server, like OpenSSH server
//
func NewClient ( c net . Conn , config * ssh . ClientConfig , addr string , conf * Conf ) ( * Client , error ) {
Log ( DEBUG , "create obfs conn with method %s" , conf . ObfsMethod )
obfsConn, err := NewObfsConn ( & TimedOutConn { c , conf . Timeout } , conf . ObfsMethod , conf . ObfsKey , false )
//obfsConn := &TimedOutConn{c, conf.Timeout}
sshConn, newch , reqs , err := ssh . NewClientConn ( c , addr , config )
if err != nil {
return nil , err
}
sshConn , newch , reqs , err := ssh . NewClientConn ( obfsConn , addr , config )
if err != nil {
return nil , err
}
if conf . DisableObfsAfterHandshake {
obfsConn . DisableObfs ( )
}
sshClient := ssh . NewClient ( sshConn , newch , reqs )
client := & Client {
conn : c , sshConn : sshConn , client : sshClient ,
ch : make ( chan struct { } ) ,
}
client . ctx , client . cancel = context . WithCancel ( context . Background ( ) )
go client . keepAlive ( conf . KeepAliveInterval , conf . KeepAliveMax )
return client , nil
}
@ -66,49 +61,75 @@ func (cc *Client) Client() *ssh.Client {
// Run wait ssh connection to finish
func ( cc * Client ) Run ( ) error {
defer cc . Close ( )
defer cc . cancel ( )
select {
case <- time . After ( 1 * time . Second ) :
}
// wait port forward to finish
if cc . listeners != nil {
Log ( DEBUG , "wait all channel to be done" )
log . Debugf ( "wait all channel to be done" )
go cc . registerSignal ( )
go func ( ) {
cc . err = cc . sshConn . Wait ( )
Log ( DEBUG , "connection hang up" )
close ( cc . ch )
log . Debugf ( "connection hang up" )
cc . cancel ( )
//close(cc.ch)
} ( )
<- cc . ctx . Done ( )
}
return cc . err
}
// wait exit signal
select {
case <- cc . ch :
Log ( INFO , "got signal, exit" )
func ( cc * Client ) closeListener ( ) {
if len ( cc . listeners ) == 0 {
return
}
// close remote listener may block, because of connection issue
// so only 1 second to wait
ctx , cancel := context . WithTimeout ( context . Background ( ) , 1 * time . Second )
defer cancel ( )
wg := & sync . WaitGroup { }
for _ , l := range cc . listeners {
go func ( l net . Listener ) {
log . Debugf ( "begin to close listener %s" , l . Addr ( ) . String ( ) )
l . Close ( )
log . Debugf ( "close listener %s done" , l . Addr ( ) . String ( ) )
wg . Done ( )
} ( l )
wg . Add ( 1 )
}
Log ( DEBUG , "Done" )
cc . Close ( )
return cc . err
go func ( ) {
wg . Wait ( )
cancel ( )
} ( )
<- ctx . Done ( )
}
// Close close the ssh connection
// and free all the port forward resources
func ( cc * Client ) Close ( ) {
for _ , l := range cc . listeners {
Log ( INFO , "close the listener %s" , l . Addr ( ) )
l . Close ( )
}
//Log(DEBUG, "close ssh connection")
//cc.sshConn.Close()
cc . closeListener ( )
log . Debugf ( "close ssh connection" )
cc . sshConn . Close ( )
cc . conn . Close ( )
log . Debugf ( "close ssh connection done" )
}
// RunCmd run a single command on server
func ( cc * Client ) RunCmd ( cmd string ) ( [ ] byte , error ) {
Log ( INFO , "run command %s" , cmd )
log . Debugf ( "run command %s" , cmd )
session , err := cc . client . NewSession ( )
if err != nil {
Log ( DEBUG , "command exited with error: %s" , err . Error ( ) )
log . Debugf ( "command exited with error: %s" , err . Error ( ) )
} else {
Log ( DEBUG , "command exited with no error" )
log . Debugf ( "command exited with no error" )
}
if err != nil {
@ -121,7 +142,7 @@ func (cc *Client) RunCmd(cmd string) ([]byte, error) {
// Shell start a login shell on server
func ( cc * Client ) Shell ( ) error {
Log ( DEBUG , "request new session" )
log . Debugf ( "request new session" )
session , err := cc . client . NewSession ( )
if err != nil {
return err
@ -137,34 +158,34 @@ func (cc *Client) Shell() error {
}
// this make CTRL+C works
Log ( DEBUG , "turn terminal mode to raw" )
log . Debugf ( "turn terminal mode to raw" )
oldState , _ := terminal . MakeRaw ( 0 )
defer func ( ) {
log . Debugf ( "restore terminal mode" )
terminal . Restore ( 0 , oldState )
} ( )
w , h , _ := terminal . GetSize ( 0 )
Log ( DEBUG , "request pty" )
log . Debugf ( "request pty" )
if err := session . RequestPty ( "xterm" , h , w , modes ) ; err != nil {
Log ( ERROR , "request pty error: %s" , err . Error ( ) )
Log ( DEBUG , "restore terminal mode" )
terminal . Restore ( 0 , oldState )
log . Errorf ( "request pty error: %s" , err . Error ( ) )
return err
}
Log ( DEBUG , "request shell" )
log . Debugf ( "request shell" )
if err := session . Shell ( ) ; err != nil {
Log ( ERROR , "start shell error: %s" , err . Error ( ) )
Log ( DEBUG , "restore terminal mode" )
terminal . Restore ( 0 , oldState )
log . Errorf ( "start shell error: %s" , err . Error ( ) )
return err
}
session . Wait ( )
Log ( DEBUG , "session closed" )
terminal . Restore ( 0 , oldState )
Log ( DEBUG , "restore terminal mode" )
log . Debugf ( "session closed" )
return nil
}
// AddLocalForward add a local to remote port forward
func ( cc * Client ) AddLocalForward ( local , remote string ) error {
Log ( DEBUG , "add local forward %s -> %s" , local , remote )
log . Debugf ( "add local forward %s -> %s" , local , remote )
l , err := net . Listen ( "tcp" , local )
if err != nil {
return err
@ -175,10 +196,10 @@ func (cc *Client) AddLocalForward(local, remote string) error {
for {
c , err := l . Accept ( )
if err != nil {
Log ( DEBUG , "local listen %s closed" , l . Addr ( ) )
log . Debugf ( "local listen %s closed" , l . Addr ( ) )
return
}
Log ( DEBUG , "connection accepted from %s" , c . RemoteAddr ( ) )
log . Debugf ( "connection accepted from %s" , c . RemoteAddr ( ) )
go cc . handleLocalForward ( c , remote )
}
} ( l )
@ -188,7 +209,7 @@ func (cc *Client) AddLocalForward(local, remote string) error {
// AddRemoteForward add a remote to local port forward
func ( cc * Client ) AddRemoteForward ( local , remote string ) error {
Log ( DEBUG , "add remote forward %s -> %s" , remote , local )
log . Debugf ( "add remote forward %s -> %s" , remote , local )
l , err := cc . client . Listen ( "tcp" , remote )
if err != nil {
return err
@ -200,10 +221,10 @@ func (cc *Client) AddRemoteForward(local, remote string) error {
for {
c , err := l . Accept ( )
if err != nil {
Log ( DEBUG , "remote listener %s closed" , l . Addr ( ) )
log . Debugf ( "remote listener %s closed" , l . Addr ( ) )
return
}
Log ( DEBUG , "accept remote forward connection from %s" , c . RemoteAddr ( ) )
log . Debugf ( "accept remote forward connection from %s" , c . RemoteAddr ( ) )
go cc . handleRemoteForward ( c , local )
}
} ( l )
@ -212,7 +233,7 @@ func (cc *Client) AddRemoteForward(local, remote string) error {
// AddDynamicForward add a dynamic port forward
func ( cc * Client ) AddDynamicForward ( local string ) error {
Log ( DEBUG , "add dynamic forward %s" , local )
log . Debugf ( "add dynamic forward %s" , local )
l , err := net . Listen ( "tcp" , local )
if err != nil {
return err
@ -223,10 +244,10 @@ func (cc *Client) AddDynamicForward(local string) error {
for {
c , err := l . Accept ( )
if err != nil {
Log ( DEBUG , "local listener %s closed" , l . Addr ( ) )
log . Debugf ( "local listener %s closed" , l . Addr ( ) )
return
}
Log ( DEBUG , "accept connection from %s" , c . RemoteAddr ( ) )
log . Debugf ( "accept connection from %s" , c . RemoteAddr ( ) )
go cc . handleDynamicForward ( c )
}
} ( l )
@ -236,22 +257,22 @@ func (cc *Client) AddDynamicForward(local string) error {
func ( cc * Client ) handleLocalForward ( conn net . Conn , remote string ) {
rconn , err := cc . client . Dial ( "tcp" , remote )
if err != nil {
Log ( ERROR , "connect to %s failed: %s" , remote , err . Error ( ) )
log . Errorf ( "connect to %s failed: %s" , remote , err . Error ( ) )
conn . Close ( )
return
}
Log ( DEBUG , "remote connect to %s success" , remote )
log . Debugf ( "remote connect to %s success" , remote )
PipeAndClose ( rconn , conn )
}
func ( cc * Client ) handleRemoteForward ( conn net . Conn , local string ) {
lconn , err := net . Dial ( "tcp" , local )
lconn , err := dialer . Dial ( "tcp" , local )
if err != nil {
Log ( ERROR , "connect to %s failed: %s" , local , err . Error ( ) )
log . Errorf ( "connect to %s failed: %s" , local , err . Error ( ) )
conn . Close ( )
return
}
Log ( DEBUG , "connect to %s success" , local )
log . Debugf ( "connect to %s success" , local )
PipeAndClose ( conn , lconn )
}
@ -261,19 +282,19 @@ func (cc *Client) handleDynamicForward(conn net.Conn) {
if addr . String ( ) != conn . LocalAddr ( ) . String ( ) {
// transparent proxy
// iptables redirect the packet to this port
Log ( DEBUG , "transparent %s -> %s" , conn . RemoteAddr ( ) , addr )
log . Debugf ( "transparent %s -> %s" , conn . RemoteAddr ( ) , addr )
cc . handleTransparentProxy ( conn , addr )
return
}
} else {
// SO_ORIGNAL_DST failed
// just ignore it
Log ( DEBUG , "get original destination on %s failed: %s, ignore" ,
log . Debugf ( "get original destination on %s failed: %s, ignore" ,
conn . LocalAddr ( ) , err )
}
// socks5 to this port
Log ( DEBUG , "socks %s" , conn . RemoteAddr ( ) )
log . Debugf ( "socks %s" , conn . RemoteAddr ( ) )
s := socks . Conn { Conn : conn , Dial : cc . client . Dial }
s . Serve ( )
}
@ -281,32 +302,54 @@ func (cc *Client) handleDynamicForward(conn net.Conn) {
func ( cc * Client ) handleTransparentProxy ( c net . Conn , addr net . Addr ) {
c2 , err := cc . client . Dial ( "tcp" , addr . String ( ) )
if err != nil {
Log ( ERROR , "%s" , err )
log . Errorf ( "%s" , err )
c . Close ( )
return
}
PipeAndClose ( c2 , c )
}
func doKeepAlive ( conn ssh . Conn , timeout time . Duration ) error {
ctx , cancel := context . WithTimeout ( context . Background ( ) , timeout )
defer cancel ( )
ch := make ( chan error , 1 )
go func ( ) {
_ , _ , err := conn . SendRequest ( "keepalive@openssh.org" , true , nil )
ch <- err
} ( )
select {
case <- ctx . Done ( ) :
return errors . New ( "keepalive timeout" )
case err := <- ch :
if err != nil {
return err
}
return nil
}
}
func ( cc * Client ) keepAlive ( interval time . Duration , maxCount int ) {
count := 0
c := time . NewTicker ( interval )
defer c . Stop ( )
for {
select {
case <- cc . ctx . Done ( ) :
return
case <- c . C :
_ , _ , err := cc . sshConn . SendRequest ( "keepalive@openssh.org" , true , nil )
if err != nil {
Log ( DEBUG , "keep alive error: %s" , err . Error ( ) )
if err := doKeepAlive ( cc . sshConn , 3 * time . Second ) ; err != nil {
count ++
} else {
count = 0
}
if count >= maxCount {
cc . err = fmt . Errorf ( "keep alive detects connection hang up" )
Log ( ERROR , "keep alive hit max count, exit" )
cc . sshConn . Close ( )
// send exit signal
close ( cc . ch )
log . Errorf ( "keep alive hit max count, exit" )
cc . cancel ( )
return
}
}
@ -319,7 +362,96 @@ func (cc *Client) registerSignal() {
select {
case s1 := <- c :
cc . err = fmt . Errorf ( "signal %v" , s1 )
Log ( ERROR , "signal %d received, exit" , s1 )
close ( cc . ch )
log . Errorf ( "signal %d received, exit" , s1 )
//close(cc.ch)
cc . cancel ( )
}
}
// AddDynamicHTTPForward add a http dynamic forward through
// secure channel
func ( cc * Client ) AddDynamicHTTPForward ( addr string ) error {
log . Debugf ( "add dynamic http listen: %s" , addr )
l , err := net . Listen ( "tcp" , addr )
if err != nil {
log . Errorf ( "listen on %s failed, %s" , addr , err )
return err
}
cc . listeners = append ( cc . listeners , l )
go func ( l net . Listener ) {
// defer l.Close()
for {
c , err := l . Accept ( )
if err != nil {
log . Errorf ( "accept error %s" , err )
break
}
go cc . handleHTTPIncoming ( c )
}
} ( l )
return nil
}
func ( cc * Client ) handleHTTPIncoming ( c net . Conn ) {
//defer c.Close()
r := bufio . NewReader ( c )
req , err := http . ReadRequest ( r )
if err != nil {
log . Errorf ( "read http request error %s" , err )
c . Close ( )
return
}
if req . Method == "CONNECT" {
cc . handleConnect ( req , c )
return
}
cc . handleHTTPReq ( req , c )
}
func ( cc * Client ) handleConnect ( req * http . Request , c net . Conn ) {
log . Debugf ( "connect to %s" , req . RequestURI )
c1 , err := cc . client . Dial ( "tcp" , req . RequestURI )
if err != nil {
fmt . Fprintf ( c , "HTTP/1.0 503 connection failed\r\n\r\n" )
log . Errorf ( "dial error %s" , err )
c . Close ( )
return
}
//defer c1.Close()
fmt . Fprintf ( c , "HTTP/1.0 200 connection established\r\n\r\n" )
PipeAndClose ( c , c1 )
}
func ( cc * Client ) handleHTTPReq ( req * http . Request , c net . Conn ) {
host := req . Host
if ! strings . Contains ( host , ":" ) {
host = fmt . Sprintf ( "%s:80" , host )
}
log . Debugf ( "request to %s" , host )
c1 , err := cc . client . Dial ( "tcp" , host )
if err != nil {
fmt . Fprintf ( c , "HTTP/1.1 503 connection failed\r\nConnection: close\r\n\r\n" )
log . Errorf ( "connection failed %s" , err )
c . Close ( )
return
}
//defer c1.Close()
if err = req . Write ( c1 ) ; err != nil {
fmt . Fprintf ( c , "HTTP/1.1 503 write to server error\r\nConnection: close\r\n\r\n" )
log . Errorf ( "write request to server error %s" , err )
c . Close ( )
c1 . Close ( )
return
}
PipeAndClose ( c , c1 )
}
dingjun
dingjun
nlimpid
fangdingjun