2017-08-23 16:35:39 +08:00
|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
|
|
|
"errors"
|
|
|
|
"net"
|
|
|
|
"net/url"
|
|
|
|
)
|
|
|
|
|
|
|
|
// A Dialer means to establish a connection and relay it.
|
|
|
|
type Dialer interface {
|
|
|
|
// Addr()
|
|
|
|
Addr() string
|
|
|
|
|
|
|
|
// Dial connects to the given address via the proxy.
|
|
|
|
Dial(network, addr string) (c net.Conn, err error)
|
2017-08-23 17:45:57 +08:00
|
|
|
|
|
|
|
// Get the dialer by dstAddr
|
|
|
|
NextDialer(dstAddr string) Dialer
|
2017-08-23 16:35:39 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
// DialerFromURL parses url and get a Proxy
|
|
|
|
// TODO: table
|
|
|
|
func DialerFromURL(s string, cDialer Dialer) (Dialer, error) {
|
|
|
|
u, err := url.Parse(s)
|
|
|
|
if err != nil {
|
|
|
|
logf("parse err: %s", err)
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
addr := u.Host
|
|
|
|
var user, pass string
|
|
|
|
if u.User != nil {
|
|
|
|
user = u.User.Username()
|
|
|
|
pass, _ = u.User.Password()
|
|
|
|
}
|
|
|
|
|
|
|
|
if cDialer == nil {
|
|
|
|
cDialer = Direct
|
|
|
|
}
|
|
|
|
|
|
|
|
switch u.Scheme {
|
|
|
|
case "http":
|
2018-01-13 14:25:55 +08:00
|
|
|
return NewHTTP(addr, user, pass, "", cDialer, nil)
|
2017-08-23 16:35:39 +08:00
|
|
|
case "socks5":
|
2017-09-07 23:50:10 +08:00
|
|
|
return NewSOCKS5(addr, user, pass, cDialer, nil)
|
2017-08-23 16:35:39 +08:00
|
|
|
case "ss":
|
2018-01-08 22:28:11 +08:00
|
|
|
return NewSS(addr, user, pass, cDialer, nil)
|
2017-08-23 16:35:39 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
return nil, errors.New("unknown schema '" + u.Scheme + "'")
|
|
|
|
}
|