feat: cloudflare port expansion, reality files, archive fix, clean_failed_subs toggle

Author: Delta-Kronecker

data/settings.json

@@ -1,6 +1,7 @@
 {
   "validation": {
 
+    "clean_failed_subs": false,
     "num_workers": 1000,
     "global_timeout_sec": 20000,
     "xray_start_timeout_ms": 8000,

src/geoip.go

@@ -643,3 +643,97 @@ func enrichResultsWithGeoIP(results []configResult, settings GeoSettings) []conf
 
 	return results
 }
+
+// ── Cloudflare port expansion ────────────────────────────────────────────────
+
+var cfPorts = []string{
+	"443", "8443", "2053", "2083", "2087", "2096",
+	"80", "8080", "8880", "2052", "2082", "2086", "2095",
+}
+
+func expandCloudflarePorts(lines []string) []string {
+	seen := make(map[string]bool, len(lines))
+	var result []string
+
+	for _, line := range lines {
+		proto := detectProto(line)
+		if proto != "vless" && proto != "trojan" {
+			if !seen[line] {
+				seen[line] = true
+				result = append(result, line)
+			}
+			continue
+		}
+		if !isWSTransport(line, proto) {
+			if !seen[line] {
+				seen[line] = true
+				result = append(result, line)
+			}
+			continue
+		}
+
+		host := extractServerHost(line, proto)
+		if host == "" {
+			if !seen[line] {
+				seen[line] = true
+				result = append(result, line)
+			}
+			continue
+		}
+
+		ip := resolveHost(host)
+		if ip == "" || !isCloudflareIP(ip) {
+			if !seen[line] {
+				seen[line] = true
+				result = append(result, line)
+			}
+			continue
+		}
+
+		// Cloudflare WS config — expand to all ports
+		for _, port := range cfPorts {
+			expanded := replacePort(line, port)
+			if expanded != "" && !seen[expanded] {
+				seen[expanded] = true
+				result = append(result, expanded)
+			}
+		}
+	}
+
+	expanded := len(result) - len(lines)
+	if expanded > 0 {
+		fmt.Printf(" Cloudflare: expanded %d configs to %d port variants\n", len(lines), len(result))
+	}
+	return result
+}
+
+func replacePort(line, newPort string) string {
+	hashIdx := strings.LastIndex(line, "#")
+	suffix := ""
+	if hashIdx != -1 {
+		suffix = line[hashIdx:]
+		line = line[:hashIdx]
+	}
+
+	qIdx := strings.Index(line, "?")
+	var base, query string
+	if qIdx != -1 {
+		base = line[:qIdx]
+		query = line[qIdx:]
+	} else {
+		base = line
+	}
+
+	atIdx := strings.LastIndex(base, "@")
+	if atIdx == -1 {
+		return ""
+	}
+	afterAt := base[atIdx+1:]
+	colonIdx := strings.LastIndex(afterAt, ":")
+	if colonIdx == -1 {
+		return ""
+	}
+	host := afterAt[:colonIdx]
+	rewritten := base[:atIdx+1] + host + ":" + newPort + query + suffix
+	return rewritten
+}

src/main.go

@@ -69,7 +69,7 @@ func main() {
 		fmt.Printf(" Loaded %d sources from sub.txt\n", len(subURLs))
 		var failedURLs []string
 		allConfigs, failedLinks, failedURLs = fetchAllFromSubs(subURLs)
-		if len(failedURLs) > 0 {
+		if len(failedURLs) > 0 && cfg.Validation.CleanFailedSubs {
 			cleanSubFile("data/sub.txt", failedURLs)
 		}
 	} else {
@@ -78,6 +78,8 @@ func main() {
 	}
 	fmt.Printf(" Total fetched: %d | Failed sources: %d\n", len(allConfigs), len(failedLinks))
 
+	allConfigs = expandCloudflarePorts(allConfigs)
+
 	if gLog != nil {
 		gLog.logStart(len(allConfigs), len(failedLinks))
 	}

src/types.go

@@ -27,7 +27,8 @@ type GeoSettings struct {
 }
 
 type ValidationSettings struct {
-	NumWorkers             int      `json:"num_workers"`
+	CleanFailedSubs         bool     `json:"clean_failed_subs"`
+	NumWorkers              int      `json:"num_workers"`
 	GlobalTimeoutSec       float64  `json:"global_timeout_sec"`
 	XrayStartTimeoutMs    int      `json:"xray_start_timeout_ms"`
 	XrayStartIntervalMs   int      `json:"xray_start_interval_ms"`

src/writer.go

@@ -84,7 +84,16 @@ func injectClashProxies(baseContent string, proxyEntries []string, proxyNames []
 // ── prepareOutputDirs ─────────────────────────────────────────────────────────
 
 func prepareOutputDirs() error {
+	archiveDir := filepath.Join("config", "archive")
+	tmpArchive := filepath.Join("config", ".archive_tmp")
+	if _, err := os.Stat(archiveDir); err == nil {
+		os.Rename(archiveDir, tmpArchive)
+	}
 	os.RemoveAll("config")
+	if _, err := os.Stat(tmpArchive); err == nil {
+		os.MkdirAll(archiveDir, 0755)
+		os.Rename(tmpArchive, archiveDir)
+	}
 	dirs := []string{
 		"config",
 		cfg.Output.ProtocolsDir,