157 lines
3.2 KiB
Go
157 lines
3.2 KiB
Go
package chain
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
"net"
|
|
|
|
"github.com/go-gost/gost/pkg/connector"
|
|
"github.com/go-gost/gost/pkg/logger"
|
|
"github.com/go-gost/gost/pkg/resolver"
|
|
)
|
|
|
|
type Router struct {
|
|
retries int
|
|
chain *Chain
|
|
resolver resolver.Resolver
|
|
logger logger.Logger
|
|
}
|
|
|
|
func (r *Router) WithChain(chain *Chain) *Router {
|
|
r.chain = chain
|
|
return r
|
|
}
|
|
|
|
func (r *Router) WithResolver(resolver resolver.Resolver) *Router {
|
|
r.resolver = resolver
|
|
return r
|
|
}
|
|
|
|
func (r *Router) WithRetry(retries int) *Router {
|
|
r.retries = retries
|
|
return r
|
|
}
|
|
|
|
func (r *Router) WithLogger(logger logger.Logger) *Router {
|
|
r.logger = logger
|
|
return r
|
|
}
|
|
|
|
func (r *Router) Dial(ctx context.Context, network, address string) (conn net.Conn, err error) {
|
|
conn, err = r.dial(ctx, network, address)
|
|
if err != nil {
|
|
return
|
|
}
|
|
if network == "udp" || network == "udp4" || network == "udp6" {
|
|
if _, ok := conn.(net.PacketConn); !ok {
|
|
return &packetConn{conn}, nil
|
|
}
|
|
}
|
|
return
|
|
}
|
|
|
|
func (r *Router) dial(ctx context.Context, network, address string) (conn net.Conn, err error) {
|
|
count := r.retries + 1
|
|
if count <= 0 {
|
|
count = 1
|
|
}
|
|
r.logger.Debugf("dial %s/%s", address, network)
|
|
|
|
for i := 0; i < count; i++ {
|
|
route := r.chain.GetRouteFor(network, address)
|
|
|
|
if r.logger.IsLevelEnabled(logger.DebugLevel) {
|
|
buf := bytes.Buffer{}
|
|
for _, node := range route.Path() {
|
|
fmt.Fprintf(&buf, "%s@%s > ", node.Name(), node.Addr())
|
|
}
|
|
fmt.Fprintf(&buf, "%s", address)
|
|
r.logger.Debugf("route(retry=%d) %s", i, buf.String())
|
|
}
|
|
|
|
address, err = r.resolve(ctx, address)
|
|
if err != nil {
|
|
r.logger.Error(err)
|
|
break
|
|
}
|
|
|
|
conn, err = route.Dial(ctx, network, address)
|
|
if err == nil {
|
|
break
|
|
}
|
|
r.logger.Errorf("route(retry=%d) %s", i, err)
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
func (r *Router) resolve(ctx context.Context, addr string) (string, error) {
|
|
host, port, err := net.SplitHostPort(addr)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
/*
|
|
if ip := hosts.Lookup(host); ip != nil {
|
|
return net.JoinHostPort(ip.String(), port)
|
|
}
|
|
*/
|
|
|
|
if r.resolver != nil {
|
|
ips, err := r.resolver.Resolve(ctx, host)
|
|
if err != nil {
|
|
r.logger.Error(err)
|
|
}
|
|
if len(ips) == 0 {
|
|
return "", errors.New("domain not exists")
|
|
}
|
|
return net.JoinHostPort(ips[0].String(), port), nil
|
|
}
|
|
return addr, nil
|
|
}
|
|
|
|
func (r *Router) Bind(ctx context.Context, network, address string, opts ...connector.BindOption) (ln net.Listener, err error) {
|
|
count := r.retries + 1
|
|
if count <= 0 {
|
|
count = 1
|
|
}
|
|
r.logger.Debugf("bind on %s/%s", address, network)
|
|
|
|
for i := 0; i < count; i++ {
|
|
route := r.chain.GetRouteFor(network, address)
|
|
|
|
if r.logger.IsLevelEnabled(logger.DebugLevel) {
|
|
buf := bytes.Buffer{}
|
|
for _, node := range route.Path() {
|
|
fmt.Fprintf(&buf, "%s@%s > ", node.Name(), node.Addr())
|
|
}
|
|
fmt.Fprintf(&buf, "%s", address)
|
|
r.logger.Debugf("route(retry=%d) %s", i, buf.String())
|
|
}
|
|
|
|
ln, err = route.Bind(ctx, network, address, opts...)
|
|
if err == nil {
|
|
break
|
|
}
|
|
r.logger.Errorf("route(retry=%d) %s", i, err)
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
type packetConn struct {
|
|
net.Conn
|
|
}
|
|
|
|
func (c *packetConn) ReadFrom(b []byte) (n int, addr net.Addr, err error) {
|
|
n, err = c.Read(b)
|
|
addr = c.Conn.RemoteAddr()
|
|
return
|
|
}
|
|
|
|
func (c *packetConn) WriteTo(b []byte, addr net.Addr) (n int, err error) {
|
|
return c.Write(b)
|
|
}
|