fix: remove extra and the actual original IDNA domain name is no longer stored, for reduce memory
This commit is contained in:
parent
c8382d90e3
commit
04910ba4a0
7 changed files with 37 additions and 131 deletions
|
@ -83,6 +83,4 @@ type Rule interface {
|
||||||
Payload() string
|
Payload() string
|
||||||
ShouldResolveIP() bool
|
ShouldResolveIP() bool
|
||||||
ShouldFindProcess() bool
|
ShouldFindProcess() bool
|
||||||
RuleExtra() *RuleExtra
|
|
||||||
SetRuleExtra(re *RuleExtra)
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,48 +1,9 @@
|
||||||
package constant
|
package constant
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"net/netip"
|
|
||||||
"strings"
|
|
||||||
|
|
||||||
"github.com/Dreamacro/clash/component/geodata/router"
|
"github.com/Dreamacro/clash/component/geodata/router"
|
||||||
)
|
)
|
||||||
|
|
||||||
type RuleExtra struct {
|
|
||||||
Network NetWork
|
|
||||||
SourceIPs []*netip.Prefix
|
|
||||||
ProcessNames []string
|
|
||||||
}
|
|
||||||
|
|
||||||
func (re *RuleExtra) NotMatchNetwork(network NetWork) bool {
|
|
||||||
return re.Network != ALLNet && re.Network != network
|
|
||||||
}
|
|
||||||
|
|
||||||
func (re *RuleExtra) NotMatchSourceIP(srcIP netip.Addr) bool {
|
|
||||||
if re.SourceIPs == nil {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, ips := range re.SourceIPs {
|
|
||||||
if ips.Contains(srcIP) {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
|
|
||||||
func (re *RuleExtra) NotMatchProcessName(processName string) bool {
|
|
||||||
if re.ProcessNames == nil {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, pn := range re.ProcessNames {
|
|
||||||
if strings.EqualFold(pn, processName) {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
|
|
||||||
type RuleGeoSite interface {
|
type RuleGeoSite interface {
|
||||||
GetDomainMatcher() *router.DomainMatcher
|
GetDomainMatcher() *router.DomainMatcher
|
||||||
}
|
}
|
||||||
|
|
|
@ -2,10 +2,6 @@ package common
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
"net/netip"
|
|
||||||
"strings"
|
|
||||||
|
|
||||||
C "github.com/Dreamacro/clash/constant"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
@ -15,15 +11,6 @@ var (
|
||||||
)
|
)
|
||||||
|
|
||||||
type Base struct {
|
type Base struct {
|
||||||
ruleExtra *C.RuleExtra
|
|
||||||
}
|
|
||||||
|
|
||||||
func (b *Base) RuleExtra() *C.RuleExtra {
|
|
||||||
return b.ruleExtra
|
|
||||||
}
|
|
||||||
|
|
||||||
func (b *Base) SetRuleExtra(re *C.RuleExtra) {
|
|
||||||
b.ruleExtra = re
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *Base) ShouldFindProcess() bool {
|
func (b *Base) ShouldFindProcess() bool {
|
||||||
|
@ -42,47 +29,3 @@ func HasNoResolve(params []string) bool {
|
||||||
}
|
}
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
func FindNetwork(params []string) C.NetWork {
|
|
||||||
for _, p := range params {
|
|
||||||
if strings.EqualFold(p, "tcp") {
|
|
||||||
return C.TCP
|
|
||||||
} else if strings.EqualFold(p, "udp") {
|
|
||||||
return C.UDP
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return C.ALLNet
|
|
||||||
}
|
|
||||||
|
|
||||||
func FindSourceIPs(params []string) []*netip.Prefix {
|
|
||||||
var ips []*netip.Prefix
|
|
||||||
for _, p := range params {
|
|
||||||
if p == noResolve || len(p) < 7 {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
ipnet, err := netip.ParsePrefix(p)
|
|
||||||
if err != nil {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
ips = append(ips, &ipnet)
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(ips) > 0 {
|
|
||||||
return ips
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func FindProcessName(params []string) []string {
|
|
||||||
var processNames []string
|
|
||||||
for _, p := range params {
|
|
||||||
if strings.HasPrefix(p, "P:") {
|
|
||||||
processNames = append(processNames, strings.TrimPrefix(p, "P:"))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(processNames) > 0 {
|
|
||||||
return processNames
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
|
@ -9,9 +9,9 @@ import (
|
||||||
|
|
||||||
type Domain struct {
|
type Domain struct {
|
||||||
*Base
|
*Base
|
||||||
domain string
|
domain string
|
||||||
rawDomain string
|
adapter string
|
||||||
adapter string
|
isIDNA bool
|
||||||
}
|
}
|
||||||
|
|
||||||
func (d *Domain) RuleType() C.RuleType {
|
func (d *Domain) RuleType() C.RuleType {
|
||||||
|
@ -30,16 +30,20 @@ func (d *Domain) Adapter() string {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (d *Domain) Payload() string {
|
func (d *Domain) Payload() string {
|
||||||
return d.rawDomain
|
domain := d.domain
|
||||||
|
if d.isIDNA {
|
||||||
|
domain, _ = idna.ToUnicode(domain)
|
||||||
|
}
|
||||||
|
return domain
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewDomain(domain string, adapter string) *Domain {
|
func NewDomain(domain string, adapter string) *Domain {
|
||||||
actualDomain, _ := idna.ToASCII(domain)
|
actualDomain, _ := idna.ToASCII(domain)
|
||||||
return &Domain{
|
return &Domain{
|
||||||
Base: &Base{},
|
Base: &Base{},
|
||||||
domain: strings.ToLower(actualDomain),
|
domain: strings.ToLower(actualDomain),
|
||||||
adapter: adapter,
|
adapter: adapter,
|
||||||
rawDomain: domain,
|
isIDNA: actualDomain != domain,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -9,9 +9,9 @@ import (
|
||||||
|
|
||||||
type DomainKeyword struct {
|
type DomainKeyword struct {
|
||||||
*Base
|
*Base
|
||||||
keyword string
|
keyword string
|
||||||
adapter string
|
adapter string
|
||||||
rawKeyword string
|
isIDNA bool
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dk *DomainKeyword) RuleType() C.RuleType {
|
func (dk *DomainKeyword) RuleType() C.RuleType {
|
||||||
|
@ -31,16 +31,20 @@ func (dk *DomainKeyword) Adapter() string {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dk *DomainKeyword) Payload() string {
|
func (dk *DomainKeyword) Payload() string {
|
||||||
return dk.rawKeyword
|
keyword := dk.keyword
|
||||||
|
if dk.isIDNA {
|
||||||
|
keyword, _ = idna.ToUnicode(keyword)
|
||||||
|
}
|
||||||
|
return keyword
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewDomainKeyword(keyword string, adapter string) *DomainKeyword {
|
func NewDomainKeyword(keyword string, adapter string) *DomainKeyword {
|
||||||
actualDomainKeyword, _ := idna.ToASCII(keyword)
|
actualDomainKeyword, _ := idna.ToASCII(keyword)
|
||||||
return &DomainKeyword{
|
return &DomainKeyword{
|
||||||
Base: &Base{},
|
Base: &Base{},
|
||||||
keyword: strings.ToLower(actualDomainKeyword),
|
keyword: strings.ToLower(actualDomainKeyword),
|
||||||
adapter: adapter,
|
adapter: adapter,
|
||||||
rawKeyword: keyword,
|
isIDNA: keyword != actualDomainKeyword,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -9,9 +9,9 @@ import (
|
||||||
|
|
||||||
type DomainSuffix struct {
|
type DomainSuffix struct {
|
||||||
*Base
|
*Base
|
||||||
suffix string
|
suffix string
|
||||||
adapter string
|
adapter string
|
||||||
rawSuffix string
|
isIDNA bool
|
||||||
}
|
}
|
||||||
|
|
||||||
func (ds *DomainSuffix) RuleType() C.RuleType {
|
func (ds *DomainSuffix) RuleType() C.RuleType {
|
||||||
|
@ -31,16 +31,20 @@ func (ds *DomainSuffix) Adapter() string {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (ds *DomainSuffix) Payload() string {
|
func (ds *DomainSuffix) Payload() string {
|
||||||
return ds.rawSuffix
|
suffix := ds.suffix
|
||||||
|
if ds.isIDNA {
|
||||||
|
suffix, _ = idna.ToUnicode(suffix)
|
||||||
|
}
|
||||||
|
return suffix
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewDomainSuffix(suffix string, adapter string) *DomainSuffix {
|
func NewDomainSuffix(suffix string, adapter string) *DomainSuffix {
|
||||||
actualDomainKeyword, _ := idna.ToASCII(suffix)
|
actualDomainSuffix, _ := idna.ToASCII(suffix)
|
||||||
return &DomainSuffix{
|
return &DomainSuffix{
|
||||||
Base: &Base{},
|
Base: &Base{},
|
||||||
suffix: strings.ToLower(actualDomainKeyword),
|
suffix: strings.ToLower(actualDomainSuffix),
|
||||||
adapter: adapter,
|
adapter: adapter,
|
||||||
rawSuffix: suffix,
|
isIDNA: suffix != actualDomainSuffix,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -65,13 +65,5 @@ func ParseRule(tp, payload, target string, params []string) (parsed C.Rule, pars
|
||||||
return nil, parseErr
|
return nil, parseErr
|
||||||
}
|
}
|
||||||
|
|
||||||
ruleExtra := &C.RuleExtra{
|
|
||||||
Network: RC.FindNetwork(params),
|
|
||||||
SourceIPs: RC.FindSourceIPs(params),
|
|
||||||
ProcessNames: RC.FindProcessName(params),
|
|
||||||
}
|
|
||||||
|
|
||||||
parsed.SetRuleExtra(ruleExtra)
|
|
||||||
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue