OpenGFW/analyzer/tcp/fet.go

package tcp

import "github.com/apernet/OpenGFW/analyzer"

var _ analyzer.TCPAnalyzer = (*FETAnalyzer)(nil)

// FETAnalyzer stands for "Fully Encrypted Traffic" analyzer.
// It implements an algorithm to detect fully encrypted proxy protocols
// such as Shadowsocks, mentioned in the following paper:
// https://gfw.report/publications/usenixsecurity23/data/paper/paper.pdf
type FETAnalyzer struct{}

func (a *FETAnalyzer) Name() string {
	return "fet"
}

func (a *FETAnalyzer) Limit() int {
	// We only really look at the first packet
	return 8192
}

func (a *FETAnalyzer) NewTCP(info analyzer.TCPInfo, logger analyzer.Logger) analyzer.TCPStream {
	return newFETStream(logger)
}

type fetStream struct {
	logger analyzer.Logger
}

func newFETStream(logger analyzer.Logger) *fetStream {
	return &fetStream{logger: logger}
}

func (s *fetStream) Feed(rev, start, end bool, skip int, data []byte) (u *analyzer.PropUpdate, done bool) {
	if skip != 0 {
		return nil, true
	}
	if len(data) == 0 {
		return nil, false
	}
	ex1 := averagePopCount(data)
	ex2 := isFirstSixPrintable(data)
	ex3 := printablePercentage(data)
	ex4 := contiguousPrintable(data)
	ex5 := isTLSorHTTP(data)
	exempt := (ex1 <= 3.4 || ex1 >= 4.6) || ex2 || ex3 > 0.5 || ex4 > 20 || ex5
	return &analyzer.PropUpdate{
		Type: analyzer.PropUpdateReplace,
		M: analyzer.PropMap{
			"ex1": ex1,
			"ex2": ex2,
			"ex3": ex3,
			"ex4": ex4,
			"ex5": ex5,
			"yes": !exempt,
		},
	}, true
}

func (s *fetStream) Close(limited bool) *analyzer.PropUpdate {
	return nil
}

func popCount(b byte) int {
	count := 0
	for b != 0 {
		count += int(b & 1)
		b >>= 1
	}
	return count
}

// averagePopCount returns the average popcount of the given bytes.
// This is the "Ex1" metric in the paper.
func averagePopCount(bytes []byte) float32 {
	if len(bytes) == 0 {
		return 0
	}
	total := 0
	for _, b := range bytes {
		total += popCount(b)
	}
	return float32(total) / float32(len(bytes))
}

// isFirstSixPrintable returns true if the first six bytes are printable ASCII.
// This is the "Ex2" metric in the paper.
func isFirstSixPrintable(bytes []byte) bool {
	if len(bytes) < 6 {
		return false
	}
	for i := range bytes[:6] {
		if !isPrintable(bytes[i]) {
			return false
		}
	}
	return true
}

// printablePercentage returns the percentage of printable ASCII bytes.
// This is the "Ex3" metric in the paper.
func printablePercentage(bytes []byte) float32 {
	if len(bytes) == 0 {
		return 0
	}
	count := 0
	for i := range bytes {
		if isPrintable(bytes[i]) {
			count++
		}
	}
	return float32(count) / float32(len(bytes))
}

// contiguousPrintable returns the length of the longest contiguous sequence of
// printable ASCII bytes.
// This is the "Ex4" metric in the paper.
func contiguousPrintable(bytes []byte) int {
	if len(bytes) == 0 {
		return 0
	}
	maxCount := 0
	current := 0
	for i := range bytes {
		if isPrintable(bytes[i]) {
			current++
		} else {
			if current > maxCount {
				maxCount = current
			}
			current = 0
		}
	}
	if current > maxCount {
		maxCount = current
	}
	return maxCount
}

// isTLSorHTTP returns true if the given bytes look like TLS or HTTP.
// This is the "Ex5" metric in the paper.
func isTLSorHTTP(bytes []byte) bool {
	if len(bytes) < 3 {
		return false
	}
	if bytes[0] == 0x16 && bytes[1] == 0x03 && bytes[2] <= 0x03 {
		// TLS handshake for TLS 1.0-1.3
		return true
	}
	// HTTP request
	str := string(bytes[:3])
	return str == "GET" || str == "HEA" || str == "POS" ||
		str == "PUT" || str == "DEL" || str == "CON" ||
		str == "OPT" || str == "TRA" || str == "PAT"
}

func isPrintable(b byte) bool {
	return b >= 0x20 && b <= 0x7e
}