Added UNTESTED -p proxy support. Please someone test it and let me know if it works.

Author: doxx

bin/checksums.txt

@@ -1,12 +1,12 @@
 # DarkFlare Binary Checksums
-# Generated: Mon Dec  9 18:14:05 UTC 2024
+# Generated: Sun Dec 22 18:06:43 UTC 2024
 
-1d4017ad4a6ace56edf39528a7511b06bfbb2444badda2469e82fdfc14f02a37  checksums.txt
-fdcb0991c621b858fc467323eff3f6060df8158e69a2072df292a155d1af910c  darkflare-client-darwin-amd64
-220e2c7395c6da0d77e2d69bb87eda0d02b81458929d999bcccd921343f993c2  darkflare-client-darwin-arm64
-43653e4eda240d527b58eea152d411cb3daa075ce8e022ff487f163d0163bfb4  darkflare-client-linux-amd64
-99042d7a72f3da8c3189a4a8ad2ba5a672c48bf08f6e7a90818ead6384067ca7  darkflare-client-linux-arm64
-27f404822f45afa0675a75fcf374c5c7f581cec34bf5f2f4dbad8f168ec810b8  darkflare-client-windows-amd64.exe
+7aca8ba2f3424a8fc7bd5b318ea64b065e2025c04b3bf56b75a580054485b65d  checksums.txt
+b5b99d41710c1fa7c5972c16e2569e9669a5f33b3a47a43637b3c759a0b7c37e  darkflare-client-darwin-amd64
+5fddf0bdeb8edbad23480667c52d0e80589796bd296cf0ddfde9687977af54c2  darkflare-client-darwin-arm64
+701ca0f8d425df0b081335d85209e3888835738d607b5595077fe53cf10ece80  darkflare-client-linux-amd64
+0c0576ade0937f2f5ff6999afcf22e2513f91f48aeaa0234552b7c2b9e1b509a  darkflare-client-linux-arm64
+6d581afcdd58545577f6fe37f984237e8ceafb3a9e279128cb729e5d2507ceae  darkflare-client-windows-amd64.exe
 047ea2e4b7adce407464ab539325d95e9258c25a83639384cea715641c6f5ca5  darkflare-server-darwin-amd64
 448c05be509e93de7f6dbf61121b52487654732b2b4424966715d27867df8a77  darkflare-server-darwin-arm64
 100ad4b1cf6f141616235be265620cf51eb12deae4c230516e6c55d28e643558  darkflare-server-linux-amd64

bin/darkflare-client-darwin-amd64

@@ -23,6 +23,7 @@ import (
 
 	"crypto/x509"
 
+	"golang.org/x/net/proxy"
 	"golang.org/x/time/rate"
 )
 
@@ -48,6 +49,7 @@ type Client struct {
 	writeBufferSize int
 	pollInterval    time.Duration
 	batchSize       int
+	proxyURL        string
 }
 
 func generateSessionID() string {
@@ -59,7 +61,7 @@ func generateSessionID() string {
 	return hex.EncodeToString(b)
 }
 
-func NewClient(cloudflareHost string, destPort int, scheme string, destAddr string, debug bool) *Client {
+func NewClient(cloudflareHost string, destPort int, scheme string, destAddr string, debug bool, proxyURL string) *Client {
 	rand.Seed(time.Now().UnixNano())
 
 	if scheme == "" {
@@ -86,9 +88,10 @@ func NewClient(cloudflareHost string, destPort int, scheme string, destAddr stri
 		writeBufferSize: 32 * 1024,
 		pollInterval:    50 * time.Millisecond,
 		batchSize:       32 * 1024,
+		proxyURL:        proxyURL,
 		bufferPool: sync.Pool{
 			New: func() interface{} {
-				return make([]byte, 64*1024) // Increase to 64KB
+				return make([]byte, 64*1024)
 			},
 		},
 	}
@@ -132,6 +135,29 @@ func NewClient(cloudflareHost string, destPort int, scheme string, destAddr stri
 		ExpectContinueTimeout: 1 * time.Second,
 	}
 
+	// Configure proxy support
+	if proxyURL != "" {
+		if strings.HasPrefix(proxyURL, "socks") {
+			// Handle SOCKS proxy
+			dialer, err := proxy.SOCKS5("tcp", proxyURL[strings.Index(proxyURL, "//")+2:], nil, proxy.Direct)
+			if err != nil {
+				log.Printf("Error creating SOCKS5 dialer: %v", err)
+			} else {
+				transport.DialContext = func(ctx context.Context, network, addr string) (net.Conn, error) {
+					return dialer.Dial(network, addr)
+				}
+			}
+		} else {
+			// Handle HTTP/HTTPS proxy
+			proxyURLParsed, err := url.Parse(proxyURL)
+			if err != nil {
+				log.Printf("Error parsing proxy URL: %v", err)
+			} else {
+				transport.Proxy = http.ProxyURL(proxyURLParsed)
+			}
+		}
+	}
+
 	client.httpClient = &http.Client{
 		Transport: transport,
 		Timeout:   30 * time.Second,
@@ -448,6 +474,7 @@ func main() {
 	var targetURL string
 	var destAddr string
 	var debug bool
+	var proxyURL string
 
 	flag.Usage = func() {
 		fmt.Fprintf(os.Stderr, "DarkFlare Client - TCP-over-CDN tunnel client component\n")
@@ -466,6 +493,8 @@ func main() {
 		fmt.Fprintf(os.Stderr, "            This is where your traffic will ultimately be sent\n\n")
 		fmt.Fprintf(os.Stderr, "  -debug    Enable detailed debug logging\n")
 		fmt.Fprintf(os.Stderr, "            Shows connection details, data transfer, and errors\n\n")
+		fmt.Fprintf(os.Stderr, "  -p        Proxy URL for outbound connections\n")
+		fmt.Fprintf(os.Stderr, "            Format: http://host:port or socks5://host:port\n\n")
 		fmt.Fprintf(os.Stderr, "Examples:\n")
 		fmt.Fprintf(os.Stderr, "  Basic SSH tunnel:\n")
 		fmt.Fprintf(os.Stderr, "    %s -l 2222 -t https://cdn.miami.us.doxx.net -d ssh.destination.com:22\n\n", os.Args[0])
@@ -483,6 +512,7 @@ func main() {
 	flag.StringVar(&targetURL, "t", "", "")
 	flag.StringVar(&destAddr, "d", "", "")
 	flag.BoolVar(&debug, "debug", false, "")
+	flag.StringVar(&proxyURL, "p", "", "Proxy URL (http://host:port or socks5://host:port)")
 	flag.Parse()
 
 	if len(os.Args) == 1 {
@@ -544,7 +574,7 @@ func main() {
 			continue
 		}
 
-		client := NewClient(host, destPort, scheme, destAddr, debug)
+		client := NewClient(host, destPort, scheme, destAddr, debug, proxyURL)
 		go client.handleConnection(conn)
 	}
 }