new change

Author: machphy

cmd/frpc/main.go

@@ -4,56 +4,29 @@ import (
 	"fmt"
 	"log"
 	"net"
-	"os"
-
-	"github.com/BurntSushi/toml"
 )
 
-type ProxyConfig struct {
-	Name       string `toml:"name"`
-	Type       string `toml:"type"`
-	LocalPort  int    `toml:"localPort"`
-	RemotePort int    `toml:"remotePort"`
-}
-
-type FrpcConfig struct {
-	Proxies []ProxyConfig `toml:"proxies"`
-}
-
 func main() {
 	fmt.Println("Starting PolyProxy client (frpc)...")
 
-	// Load configuration
-	configPath := "../../configs/example_frpc.toml"
-	if _, err := os.Stat(configPath); os.IsNotExist(err) {
-		log.Fatalf("Config file not found: %s", configPath)
+	conn, err := net.Dial("tcp", "127.0.0.1:7000")
+	if err != nil {
+		log.Fatalf("Failed to connect: %v", err)
 	}
+	defer conn.Close()
 
-	var cfg FrpcConfig
-	if _, err := toml.DecodeFile(configPath, &cfg); err != nil {
-		log.Fatalf("Error decoding config: %v", err)
+	message := "Hello from frpc client!"
+	fmt.Println("Sending:", message)
+	_, err = conn.Write([]byte(message))
+	if err != nil {
+		log.Fatalf("Failed to send message: %v", err)
 	}
 
-	// Connect to each proxy defined in config
-	for _, proxy := range cfg.Proxies {
-		address := fmt.Sprintf("127.0.0.1:%d", proxy.RemotePort)
-		conn, err := net.Dial("tcp", address)
-		if err != nil {
-			log.Printf("[%s] Failed to connect: %v", proxy.Name, err)
-			continue
-		}
-		defer conn.Close()
-
-		message := fmt.Sprintf("Hello from %s!", proxy.Name)
-		fmt.Printf("[%s] Sending: %s\n", proxy.Name, message)
-		conn.Write([]byte(message))
-
-		buffer := make([]byte, 1024)
-		n, err := conn.Read(buffer)
-		if err != nil {
-			log.Printf("[%s] Error reading: %v", proxy.Name, err)
-			continue
-		}
-		fmt.Printf("[%s] Server replied: %s\n", proxy.Name, string(buffer[:n]))
+	// Read server response
+	buffer := make([]byte, 1024)
+	n, err := conn.Read(buffer)
+	if err != nil {
+		log.Fatalf("Error reading: %v", err)
 	}
+	fmt.Println("Server replied:", string(buffer[:n]))
 }

cmd/frps/frp

@@ -0,0 +1,45 @@
+package main
+
+import (
+	"fmt"
+	"log"
+	"net"
+)
+
+func main() {
+	port := "7000"
+	fmt.Println("Starting PolyProxy server (frps)...")
+	ln, err := net.Listen("tcp", ":"+port)
+	if err != nil {
+		log.Fatalf("Failed to start server: %v", err)
+	}
+	defer ln.Close()
+	fmt.Printf("Server is listening on port %s...\n", port)
+
+	for {
+		conn, err := ln.Accept()
+		if err != nil {
+			log.Printf("Failed to accept connection: %v", err)
+			continue
+		}
+		go handleConnection(conn)
+	}
+}
+
+func handleConnection(conn net.Conn) {
+	defer conn.Close()
+	fmt.Println("New client connected:", conn.RemoteAddr())
+
+	buffer := make([]byte, 1024)
+	n, err := conn.Read(buffer)
+	if err != nil {
+		log.Printf("Error reading from client: %v", err)
+		return
+	}
+
+	message := string(buffer[:n])
+	fmt.Println("Received from client:", message)
+
+	// Send response back
+	conn.Write([]byte("Server received: " + message))
+}

cmd/frps/frps

@@ -0,0 +1,60 @@
+# FRP client configuration (example_frpc.toml)
+
+[common]
+server_addr = "127.0.0.1"
+server_port = 7000
+# Optional: client identity token (if server uses token auth)
+# auth_token = "supersecret"
+
+################################################################################
+# 1) Simple TCP proxy (expose local TCP service)
+################################################################################
+[[proxies]]
+name = "ssh_local"
+type = "tcp"
+local_ip = "127.0.0.1"
+local_port = 22
+remote_port = 6000
+
+################################################################################
+# 2) HTTP proxy plugin (plugin runs on client side to provide an HTTP proxy)
+#    Connect to it as: http://user123:pass123@<frps_ip>:6001
+################################################################################
+[[proxies]]
+name = "http_proxy_test"
+type = "tcp"           # plugin sits on top of tcp forwarding
+remote_port = 6001
+
+[proxies.plugin]
+type = "http_proxy"
+http_user = "user123"
+http_password = "pass123"
+
+################################################################################
+# 3) SOCKS5 plugin (SOCKS tunnel). Connect via SOCKS5 client to remote_port.
+################################################################################
+[[proxies]]
+name = "socks5_proxy"
+type = "tcp"
+remote_port = 6002
+
+[proxies.plugin]
+type = "socks5"
+socks5_user = "socksuser"
+socks5_password = "sockspass"
+
+################################################################################
+# 4) Port Range Mapping (creates many proxies using template - v0.56.0 style)
+#    This snippet shows how you would write the template. Your client must
+#    support template expansion (as FRP does) for this to take effect.
+################################################################################
+# NOTE: Your implementation must support parseNumberRangePair template function
+# to expand the following block. Save this text as a fragment and include it
+# or place it in your frpc template-enabled config.
+{{- range $_, $v := parseNumberRangePair "7000-7003" "7000-7003" }}
+[[proxies]]
+name = "tcp-{{ $v.First }}"
+type = "tcp"
+local_port = {{ $v.First }}
+remote_port = {{ $v.Second }}
+{{- end }}

cmd/frps/main.go

@@ -0,0 +1,21 @@
+# FRP server configuration (example_frps.toml)
+
+[common]
+# port for frpc to connect to frps
+bind_port = 7000
+
+# optional dashboard
+dashboard_addr = "0.0.0.0"
+dashboard_port = 7500
+dashboard_user = "admin"
+dashboard_pwd = "admin"
+
+# vhost example (optional)
+vhost_http_port = 8080
+vhost_https_port = 8443
+
+# allow port ranges if you want to limit what remote ports may be used
+# allow_ports = [
+#   { start = 2000, end = 3000 },
+#   { single = 6000 }
+# ]

configs/example_frpc.toml

@@ -0,0 +1,5 @@
+module polyproxy
+
+go 1.22.2
+
+require github.com/BurntSushi/toml v1.5.0 // indirect

configs/example_frps.toml

@@ -0,0 +1,2 @@
+github.com/BurntSushi/toml v1.5.0 h1:W5quZX/G/csjUnuI8SUYlsHs9M38FC7znL0lIO+DvMg=
+github.com/BurntSushi/toml v1.5.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=