rule_set.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. package route
  2. import (
  3. "context"
  4. "github.com/sagernet/sing-box/adapter"
  5. C "github.com/sagernet/sing-box/constant"
  6. "github.com/sagernet/sing-box/option"
  7. "github.com/sagernet/sing/common"
  8. E "github.com/sagernet/sing/common/exceptions"
  9. "github.com/sagernet/sing/common/logger"
  10. "go4.org/netipx"
  11. )
  12. func NewRuleSet(ctx context.Context, router adapter.Router, logger logger.ContextLogger, options option.RuleSet) (adapter.RuleSet, error) {
  13. switch options.Type {
  14. case C.RuleSetTypeInline, C.RuleSetTypeLocal, "":
  15. return NewLocalRuleSet(ctx, router, logger, options)
  16. case C.RuleSetTypeRemote:
  17. return NewRemoteRuleSet(ctx, router, logger, options), nil
  18. default:
  19. return nil, E.New("unknown rule-set type: ", options.Type)
  20. }
  21. }
  22. func extractIPSetFromRule(rawRule adapter.HeadlessRule) []*netipx.IPSet {
  23. switch rule := rawRule.(type) {
  24. case *DefaultHeadlessRule:
  25. return common.FlatMap(rule.destinationIPCIDRItems, func(rawItem RuleItem) []*netipx.IPSet {
  26. switch item := rawItem.(type) {
  27. case *IPCIDRItem:
  28. return []*netipx.IPSet{item.ipSet}
  29. default:
  30. return nil
  31. }
  32. })
  33. case *LogicalHeadlessRule:
  34. return common.FlatMap(rule.rules, extractIPSetFromRule)
  35. default:
  36. panic("unexpected rule type")
  37. }
  38. }