ref: Remove unused code

Author: farbodbj

pkg/v2rayprobe/litespeedtest/web/profile.go

@@ -9,7 +9,6 @@ import (
 	"bufio"
 	"bytes"
 	"context"
-	"encoding/base64"
 	"encoding/json"
 	"errors"
 	"fmt"
@@ -463,6 +462,7 @@ func (p *ProfileTest) TestAll(ctx context.Context, trafficChan chan<- int64) (ch
 	return nodeChan, nil
 }
 
+// Deprecated: use testAllBatch instead
 func (p *ProfileTest) testAll(ctx context.Context) (render.Nodes, error) {
 	linksCount := len(p.Links)
 	if linksCount < 1 {
@@ -858,59 +858,6 @@ func FormatDuration(duration time.Duration) string {
 	return fmt.Sprintf("%dm %ds", m, s)
 }
 
-func png2base64(path string) (string, error) {
-	bytes, err := ioutil.ReadFile(path)
-	if err != nil {
-		return "", err
-	}
-	return "data:image/png;base64," + base64.StdEncoding.EncodeToString(bytes), nil
-}
-
 func isYamlFile(filePath string) bool {
 	return strings.HasSuffix(filePath, ".yaml") || strings.HasSuffix(filePath, ".yml")
 }
-
-// api
-func PeekClash(input string, n int) ([]string, error) {
-	scanner := bufio.NewScanner(strings.NewReader(input))
-	proxiesStart := false
-	data := []byte{}
-	linkCount := 0
-	for scanner.Scan() {
-		b := scanner.Bytes()
-		trimLine := strings.TrimSpace(string(b))
-		if trimLine == "proxy-groups:" || trimLine == "rules:" || trimLine == "Proxy Group:" {
-			break
-		}
-		if proxiesStart {
-			if _, err := config.ParseBaseProxy(trimLine); err != nil {
-				continue
-			}
-			if strings.HasPrefix(trimLine, "-") {
-				if linkCount >= n {
-					break
-				}
-				linkCount += 1
-			}
-			data = append(data, b...)
-			data = append(data, byte('\n'))
-			continue
-		}
-		if !proxiesStart && (trimLine == "proxies:" || trimLine == "Proxy:") {
-			proxiesStart = true
-			b = []byte("proxies:")
-		}
-		data = append(data, b...)
-		data = append(data, byte('\n'))
-	}
-	// fmt.Println(string(data))
-	links, err := parseClashByte(data)
-	if err != nil || len(links) < 1 {
-		return []string{}, err
-	}
-	endIndex := n
-	if endIndex > len(links) {
-		endIndex = len(links)
-	}
-	return links[:endIndex], nil
-}

pkg/v2rayprobe/litespeedtest/web/server.go

@@ -13,83 +13,14 @@ import (
 	"net/http"
 	"net/url"
 	"os"
-	"strconv"
 	"strings"
 	"time"
 
 	"ConfigProbe/pkg/v2rayprobe/litespeedtest/config"
 	"ConfigProbe/pkg/v2rayprobe/litespeedtest/utils"
 	"ConfigProbe/pkg/v2rayprobe/litespeedtest/web/render"
-	"github.com/gorilla/websocket"
 )
 
-var upgrader = websocket.Upgrader{}
-
-func ServeFile(port int) error {
-	http.HandleFunc("/test", updateTest)
-	http.HandleFunc("/getSubscriptionLink", getSubscriptionLink)
-	http.HandleFunc("/getSubscription", getSubscription)
-	log.Printf("Start server at http://127.0.0.1:%d\n", port)
-	if ipAddr, err := localIP(); err == nil {
-		log.Printf("Start server at http://%s", net.JoinHostPort(ipAddr.String(), strconv.Itoa(port)))
-	}
-	err := http.ListenAndServe(fmt.Sprintf(":%d", port), nil)
-	return err
-}
-
-func updateTest(w http.ResponseWriter, r *http.Request) {
-	c, err := upgrader.Upgrade(w, r, nil)
-	if err != nil {
-		log.Print("upgrade:", err)
-		return
-	}
-	defer c.Close()
-	ctx, cancel := context.WithCancel(context.Background())
-	defer cancel()
-	for {
-		mt, message, err := c.ReadMessage()
-		if err != nil {
-			log.Println("read:", err)
-			break
-		}
-		// log.Printf("recv: %s", message)
-		links, options, err := parseMessage(message)
-		if err != nil {
-			msg := `{"info": "error", "reason": "invalidsub"}`
-			c.WriteMessage(mt, []byte(msg))
-			continue
-		}
-		if options.Unique {
-			uniqueLinks := []string{}
-			uniqueMap := map[string]struct{}{}
-			for _, link := range links {
-				cfg, err := config.Link2Config(link)
-				if err != nil {
-					continue
-				}
-				key := fmt.Sprintf("%s%d%s%s%s", cfg.Server, cfg.Port, cfg.Password, cfg.Protocol, cfg.SNI)
-				if _, ok := uniqueMap[key]; !ok {
-					uniqueLinks = append(uniqueLinks, link)
-					uniqueMap[key] = struct{}{}
-				}
-			}
-			links = uniqueLinks
-		}
-		p := ProfileTest{
-			Writer:      c,
-			MessageType: mt,
-			Links:       links,
-			Options:     options,
-		}
-		go p.testAll(ctx)
-		// err = c.WriteMessage(mt, getMsgByte(0, "gotspeed"))
-		// if err != nil {
-		// 	log.Println("write:", err)
-		// 	break
-		// }
-	}
-}
-
 func readConfig(configPath string) (*ProfileTestOptions, error) {
 	data, err := os.ReadFile(configPath)
 	if err != nil {
@@ -200,7 +131,6 @@ type TestResult struct {
 	Nodes render.Nodes `json:"nodes"`
 }
 
-
 func isPrivateIP(ip net.IP) bool {
 	var privateIPBlocks []*net.IPNet
 	for _, cidr := range []string{