mirror of
https://github.com/SagerNet/sing-box.git
synced 2024-11-24 01:21:30 +00:00
231 lines
6 KiB
Go
231 lines
6 KiB
Go
|
package option
|
||
|
|
||
|
import (
|
||
|
"reflect"
|
||
|
|
||
|
"github.com/sagernet/sing-box/common/json"
|
||
|
C "github.com/sagernet/sing-box/constant"
|
||
|
"github.com/sagernet/sing/common"
|
||
|
"github.com/sagernet/sing/common/domain"
|
||
|
E "github.com/sagernet/sing/common/exceptions"
|
||
|
F "github.com/sagernet/sing/common/format"
|
||
|
|
||
|
"go4.org/netipx"
|
||
|
)
|
||
|
|
||
|
type _RuleSet struct {
|
||
|
Type string `json:"type"`
|
||
|
Tag string `json:"tag"`
|
||
|
Format string `json:"format"`
|
||
|
LocalOptions LocalRuleSet `json:"-"`
|
||
|
RemoteOptions RemoteRuleSet `json:"-"`
|
||
|
}
|
||
|
|
||
|
type RuleSet _RuleSet
|
||
|
|
||
|
func (r RuleSet) MarshalJSON() ([]byte, error) {
|
||
|
var v any
|
||
|
switch r.Type {
|
||
|
case C.RuleSetTypeLocal:
|
||
|
v = r.LocalOptions
|
||
|
case C.RuleSetTypeRemote:
|
||
|
v = r.RemoteOptions
|
||
|
default:
|
||
|
return nil, E.New("unknown rule set type: " + r.Type)
|
||
|
}
|
||
|
return MarshallObjects((_RuleSet)(r), v)
|
||
|
}
|
||
|
|
||
|
func (r *RuleSet) UnmarshalJSON(bytes []byte) error {
|
||
|
err := json.Unmarshal(bytes, (*_RuleSet)(r))
|
||
|
if err != nil {
|
||
|
return err
|
||
|
}
|
||
|
if r.Tag == "" {
|
||
|
return E.New("missing tag")
|
||
|
}
|
||
|
switch r.Format {
|
||
|
case "":
|
||
|
return E.New("missing format")
|
||
|
case C.RuleSetFormatSource, C.RuleSetFormatBinary:
|
||
|
default:
|
||
|
return E.New("unknown rule set format: " + r.Format)
|
||
|
}
|
||
|
var v any
|
||
|
switch r.Type {
|
||
|
case C.RuleSetTypeLocal:
|
||
|
v = &r.LocalOptions
|
||
|
case C.RuleSetTypeRemote:
|
||
|
v = &r.RemoteOptions
|
||
|
case "":
|
||
|
return E.New("missing type")
|
||
|
default:
|
||
|
return E.New("unknown rule set type: " + r.Type)
|
||
|
}
|
||
|
err = UnmarshallExcluded(bytes, (*_RuleSet)(r), v)
|
||
|
if err != nil {
|
||
|
return E.Cause(err, "rule set")
|
||
|
}
|
||
|
return nil
|
||
|
}
|
||
|
|
||
|
type LocalRuleSet struct {
|
||
|
Path string `json:"path,omitempty"`
|
||
|
}
|
||
|
|
||
|
type RemoteRuleSet struct {
|
||
|
URL string `json:"url"`
|
||
|
DownloadDetour string `json:"download_detour,omitempty"`
|
||
|
UpdateInterval Duration `json:"update_interval,omitempty"`
|
||
|
}
|
||
|
|
||
|
type _HeadlessRule struct {
|
||
|
Type string `json:"type,omitempty"`
|
||
|
DefaultOptions DefaultHeadlessRule `json:"-"`
|
||
|
LogicalOptions LogicalHeadlessRule `json:"-"`
|
||
|
}
|
||
|
|
||
|
type HeadlessRule _HeadlessRule
|
||
|
|
||
|
func (r HeadlessRule) MarshalJSON() ([]byte, error) {
|
||
|
var v any
|
||
|
switch r.Type {
|
||
|
case C.RuleTypeDefault:
|
||
|
r.Type = ""
|
||
|
v = r.DefaultOptions
|
||
|
case C.RuleTypeLogical:
|
||
|
v = r.LogicalOptions
|
||
|
default:
|
||
|
return nil, E.New("unknown rule type: " + r.Type)
|
||
|
}
|
||
|
return MarshallObjects((_HeadlessRule)(r), v)
|
||
|
}
|
||
|
|
||
|
func (r *HeadlessRule) UnmarshalJSON(bytes []byte) error {
|
||
|
err := json.Unmarshal(bytes, (*_HeadlessRule)(r))
|
||
|
if err != nil {
|
||
|
return err
|
||
|
}
|
||
|
var v any
|
||
|
switch r.Type {
|
||
|
case "", C.RuleTypeDefault:
|
||
|
r.Type = C.RuleTypeDefault
|
||
|
v = &r.DefaultOptions
|
||
|
case C.RuleTypeLogical:
|
||
|
v = &r.LogicalOptions
|
||
|
default:
|
||
|
return E.New("unknown rule type: " + r.Type)
|
||
|
}
|
||
|
err = UnmarshallExcluded(bytes, (*_HeadlessRule)(r), v)
|
||
|
if err != nil {
|
||
|
return E.Cause(err, "route rule-set rule")
|
||
|
}
|
||
|
return nil
|
||
|
}
|
||
|
|
||
|
func (r HeadlessRule) IsValid() bool {
|
||
|
switch r.Type {
|
||
|
case C.RuleTypeDefault, "":
|
||
|
return r.DefaultOptions.IsValid()
|
||
|
case C.RuleTypeLogical:
|
||
|
return r.LogicalOptions.IsValid()
|
||
|
default:
|
||
|
panic("unknown rule type: " + r.Type)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
type DefaultHeadlessRule struct {
|
||
|
QueryType Listable[DNSQueryType] `json:"query_type,omitempty"`
|
||
|
Network Listable[string] `json:"network,omitempty"`
|
||
|
Domain Listable[string] `json:"domain,omitempty"`
|
||
|
DomainSuffix Listable[string] `json:"domain_suffix,omitempty"`
|
||
|
DomainKeyword Listable[string] `json:"domain_keyword,omitempty"`
|
||
|
DomainRegex Listable[string] `json:"domain_regex,omitempty"`
|
||
|
SourceIPCIDR Listable[string] `json:"source_ip_cidr,omitempty"`
|
||
|
IPCIDR Listable[string] `json:"ip_cidr,omitempty"`
|
||
|
SourcePort Listable[uint16] `json:"source_port,omitempty"`
|
||
|
SourcePortRange Listable[string] `json:"source_port_range,omitempty"`
|
||
|
Port Listable[uint16] `json:"port,omitempty"`
|
||
|
PortRange Listable[string] `json:"port_range,omitempty"`
|
||
|
ProcessName Listable[string] `json:"process_name,omitempty"`
|
||
|
ProcessPath Listable[string] `json:"process_path,omitempty"`
|
||
|
PackageName Listable[string] `json:"package_name,omitempty"`
|
||
|
WIFISSID Listable[string] `json:"wifi_ssid,omitempty"`
|
||
|
WIFIBSSID Listable[string] `json:"wifi_bssid,omitempty"`
|
||
|
Invert bool `json:"invert,omitempty"`
|
||
|
|
||
|
DomainMatcher *domain.Matcher `json:"-"`
|
||
|
SourceIPSet *netipx.IPSet `json:"-"`
|
||
|
IPSet *netipx.IPSet `json:"-"`
|
||
|
}
|
||
|
|
||
|
func (r DefaultHeadlessRule) IsValid() bool {
|
||
|
var defaultValue DefaultHeadlessRule
|
||
|
defaultValue.Invert = r.Invert
|
||
|
return !reflect.DeepEqual(r, defaultValue)
|
||
|
}
|
||
|
|
||
|
type LogicalHeadlessRule struct {
|
||
|
Mode string `json:"mode"`
|
||
|
Rules []HeadlessRule `json:"rules,omitempty"`
|
||
|
Invert bool `json:"invert,omitempty"`
|
||
|
}
|
||
|
|
||
|
func (r LogicalHeadlessRule) IsValid() bool {
|
||
|
return len(r.Rules) > 0 && common.All(r.Rules, HeadlessRule.IsValid)
|
||
|
}
|
||
|
|
||
|
type _PlainRuleSetCompat struct {
|
||
|
Version int `json:"version"`
|
||
|
Options PlainRuleSet `json:"-"`
|
||
|
}
|
||
|
|
||
|
type PlainRuleSetCompat _PlainRuleSetCompat
|
||
|
|
||
|
func (r PlainRuleSetCompat) MarshalJSON() ([]byte, error) {
|
||
|
var v any
|
||
|
switch r.Version {
|
||
|
case C.RuleSetVersion1:
|
||
|
v = r.Options
|
||
|
default:
|
||
|
return nil, E.New("unknown rule set version: ", r.Version)
|
||
|
}
|
||
|
return MarshallObjects((_PlainRuleSetCompat)(r), v)
|
||
|
}
|
||
|
|
||
|
func (r *PlainRuleSetCompat) UnmarshalJSON(bytes []byte) error {
|
||
|
err := json.Unmarshal(bytes, (*_PlainRuleSetCompat)(r))
|
||
|
if err != nil {
|
||
|
return err
|
||
|
}
|
||
|
var v any
|
||
|
switch r.Version {
|
||
|
case C.RuleSetVersion1:
|
||
|
v = &r.Options
|
||
|
case 0:
|
||
|
return E.New("missing rule set version")
|
||
|
default:
|
||
|
return E.New("unknown rule set version: ", r.Version)
|
||
|
}
|
||
|
err = UnmarshallExcluded(bytes, (*_PlainRuleSetCompat)(r), v)
|
||
|
if err != nil {
|
||
|
return E.Cause(err, "rule set")
|
||
|
}
|
||
|
return nil
|
||
|
}
|
||
|
|
||
|
func (r PlainRuleSetCompat) Upgrade() PlainRuleSet {
|
||
|
var result PlainRuleSet
|
||
|
switch r.Version {
|
||
|
case C.RuleSetVersion1:
|
||
|
result = r.Options
|
||
|
default:
|
||
|
panic("unknown rule set version: " + F.ToString(r.Version))
|
||
|
}
|
||
|
return result
|
||
|
}
|
||
|
|
||
|
type PlainRuleSet struct {
|
||
|
Rules []HeadlessRule `json:"rules,omitempty"`
|
||
|
}
|