58 lines
1.2 KiB
Go
58 lines
1.2 KiB
Go
|
package provider
|
||
|
|
|
||
|
|
import (
|
||
|
|
"github.com/Dreamacro/clash/component/trie"
|
||
|
|
C "github.com/Dreamacro/clash/constant"
|
||
|
|
"github.com/Dreamacro/clash/log"
|
||
|
|
"strings"
|
||
|
|
)
|
||
|
|
|
||
|
|
type domainStrategy struct {
|
||
|
|
shouldResolveIP bool
|
||
|
|
count int
|
||
|
|
domainRules *trie.DomainTrie
|
||
|
|
}
|
||
|
|
|
||
|
|
func (d *domainStrategy) Match(metadata *C.Metadata) bool {
|
||
|
|
return d.domainRules != nil && d.domainRules.Search(metadata.Host) != nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (d *domainStrategy) Count() int {
|
||
|
|
return d.count
|
||
|
|
}
|
||
|
|
|
||
|
|
func (d *domainStrategy) ShouldResolveIP() bool {
|
||
|
|
return d.shouldResolveIP
|
||
|
|
}
|
||
|
|
|
||
|
|
func (d *domainStrategy) OnUpdate(rules []string) {
|
||
|
|
domainTrie := trie.New()
|
||
|
|
for _, rule := range rules {
|
||
|
|
err := domainTrie.Insert(rule, "")
|
||
|
|
if err != nil {
|
||
|
|
log.Warnln("invalid domain:[%s]", rule)
|
||
|
|
} else {
|
||
|
|
d.count++
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
d.domainRules = domainTrie
|
||
|
|
}
|
||
|
|
|
||
|
|
func ruleParse(ruleRaw string) (string, string, []string) {
|
||
|
|
item := strings.Split(ruleRaw, ",")
|
||
|
|
if len(item) == 1 {
|
||
|
|
return "", item[0], nil
|
||
|
|
} else if len(item) == 2 {
|
||
|
|
return item[0], item[1], nil
|
||
|
|
} else if len(item) > 2 {
|
||
|
|
return item[0], item[1], item[2:]
|
||
|
|
}
|
||
|
|
|
||
|
|
return "", "", nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func NewDomainStrategy() *domainStrategy {
|
||
|
|
return &domainStrategy{shouldResolveIP: false}
|
||
|
|
}
|