fmt; fixed IP address dialer option for seclient

fixed.go

@@ -0,0 +1,31 @@
+package main
+
+import (
+	"context"
+	"net"
+)
+
+type FixedDialer struct {
+	fixedAddress string
+	next ContextDialer
+}
+
+func NewFixedDialer(address string, next ContextDialer) *FixedDialer {
+	return &FixedDialer{
+		fixedAddress: address,
+		next: next,
+	}
+}
+
+func (d *FixedDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error) {
+	_, port, err := net.SplitHostPort(address)
+	if err != nil {
+		return nil, err
+	}
+
+	return d.next.DialContext(ctx, network, net.JoinHostPort(d.fixedAddress, port))
+}
+
+func (d *FixedDialer) Dial(network, address string) (net.Conn, error) {
+	return d.DialContext(context.Background(), network, address)
+}

main.go

@@ -1,8 +1,9 @@
 package main
 
 import (
-	"encoding/csv"
 	"context"
+	"crypto/tls"
+	"encoding/csv"
 	"errors"
 	"flag"
 	"fmt"
@@ -11,9 +12,8 @@ import (
 	"net/http"
 	"net/url"
 	"os"
-	"time"
-	"crypto/tls"
 	"strings"
+	"time"
 
 	xproxy "golang.org/x/net/proxy"
 
@@ -43,11 +43,11 @@ type CLIArgs struct {
 	bindAddress   string
 	verbosity     int
 	timeout       time.Duration
-	resolver     string
 	showVersion   bool
 	proxy         string
 	apiLogin      string
 	apiPassword   string
+	apiAddress    string
 }
 
 func parse_args() CLIArgs {
@@ -59,15 +59,13 @@ func parse_args() CLIArgs {
 	flag.IntVar(&args.verbosity, "verbosity", 20, "logging verbosity "+
 		"(10 - debug, 20 - info, 30 - warning, 40 - error, 50 - critical)")
 	flag.DurationVar(&args.timeout, "timeout", 10*time.Second, "timeout for network operations")
-	flag.StringVar(&args.resolver, "resolver", "https://cloudflare-dns.com/dns-query",
-		"DNS/DoH/DoT resolver to workaround Hola blocked hosts. "+
-			"See https://github.com/ameshkov/dnslookup/ for upstream DNS URL format.")
 	flag.BoolVar(&args.showVersion, "version", false, "show program version and exit")
 	flag.StringVar(&args.proxy, "proxy", "", "sets base proxy to use for all dial-outs. "+
 		"Format: <http|https|socks5|socks5h>://[login:password@]host[:port] "+
 		"Examples: http://user:password@192.168.1.1:3128, socks5://10.0.0.1:1080")
 	flag.StringVar(&args.apiLogin, "api-login", "se0316", "SurfEasy API login")
 	flag.StringVar(&args.apiPassword, "api-password", "SILrMEPBmJuhomxWkfm3JalqHX2Eheg1YhlEZiMh8II", "SurfEasy API password")
+	flag.StringVar(&args.apiAddress, "api-address", "", "override IP address of api.sec-tunnel.com")
 	flag.Parse()
 	if args.country == "" {
 		arg_fail("Country can't be empty string.")
@@ -110,6 +108,7 @@ func run() int {
 		Timeout:   30 * time.Second,
 		KeepAlive: 30 * time.Second,
 	}
+
 	if args.proxy != "" {
 		xproxy.RegisterDialerType("http", proxyFromURLWrapper)
 		xproxy.RegisterDialerType("https", proxyFromURLWrapper)
@@ -126,6 +125,11 @@ func run() int {
 		dialer = pxDialer.(ContextDialer)
 	}
 
+	seclientDialer := dialer
+	if args.apiAddress != "" {
+		seclientDialer = NewFixedDialer(args.apiAddress, dialer)
+	}
+
 	// Dialing w/o SNI, receiving self-signed certificate, so skip verification.
 	// Either way we'll validate certificate of actual proxy server.
 	tlsConfig := &tls.Config{
@@ -133,9 +137,9 @@ func run() int {
 		InsecureSkipVerify: true,
 	}
 	seclient, err := se.NewSEClient(args.apiLogin, args.apiPassword, &http.Transport{
-		DialContext:           dialer.DialContext,
+		DialContext: seclientDialer.DialContext,
 		DialTLSContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
-			conn, err := dialer.DialContext(ctx, network, addr)
+			conn, err := seclientDialer.DialContext(ctx, network, addr)
 			if err != nil {
 				return conn, err
 			}

seclient/messages.go

@@ -2,9 +2,9 @@ package seclient
 
 import (
 	"encoding/json"
-	"net"
-	"fmt"
 	"errors"
+	"fmt"
+	"net"
 	"strconv"
 )