router_test.go 7.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386
  1. package conf_test
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "io/fs"
  6. "os"
  7. "path/filepath"
  8. "testing"
  9. _ "unsafe"
  10. "github.com/golang/protobuf/proto"
  11. "github.com/v2fly/v2ray-core/v4/app/router"
  12. "github.com/v2fly/v2ray-core/v4/common"
  13. "github.com/v2fly/v2ray-core/v4/common/net"
  14. "github.com/v2fly/v2ray-core/v4/common/platform"
  15. "github.com/v2fly/v2ray-core/v4/common/platform/filesystem"
  16. . "github.com/v2fly/v2ray-core/v4/infra/conf"
  17. )
  18. func init() {
  19. wd, err := os.Getwd()
  20. common.Must(err)
  21. tempPath := filepath.Join(wd, "..", "..", "testing", "temp")
  22. geoipPath := filepath.Join(tempPath, "geoip.dat")
  23. os.Setenv("v2ray.location.asset", tempPath)
  24. common.Must(os.MkdirAll(tempPath, 0755))
  25. if _, err := os.Stat(platform.GetAssetLocation("geoip.dat")); err != nil && errors.Is(err, fs.ErrNotExist) {
  26. if _, err := os.Stat(geoipPath); err != nil && errors.Is(err, fs.ErrNotExist) {
  27. geoipBytes, err := common.FetchHTTPContent(geoipURL)
  28. common.Must(err)
  29. common.Must(filesystem.WriteFile(geoipPath, geoipBytes))
  30. }
  31. }
  32. }
  33. //go:linkname toCidrList github.com/v2fly/v2ray-core/v4/infra/conf.toCidrList
  34. func toCidrList(ips StringList) ([]*router.GeoIP, error)
  35. func TestToCidrList(t *testing.T) {
  36. t.Log(os.Getenv("v2ray.location.asset"))
  37. common.Must(filesystem.CopyFile(platform.GetAssetLocation("geoiptestrouter.dat"), platform.GetAssetLocation("geoip.dat")))
  38. ips := StringList([]string{
  39. "geoip:us",
  40. "geoip:cn",
  41. "geoip:!cn",
  42. "ext:geoiptestrouter.dat:!cn",
  43. "ext:geoiptestrouter.dat:ca",
  44. "ext-ip:geoiptestrouter.dat:!cn",
  45. "ext-ip:geoiptestrouter.dat:!ca",
  46. })
  47. _, err := toCidrList(ips)
  48. if err != nil {
  49. t.Fatalf("Failed to parse geoip list, got %s", err)
  50. }
  51. }
  52. func TestRouterConfig(t *testing.T) {
  53. createParser := func() func(string) (proto.Message, error) {
  54. return func(s string) (proto.Message, error) {
  55. config := new(RouterConfig)
  56. if err := json.Unmarshal([]byte(s), config); err != nil {
  57. return nil, err
  58. }
  59. return config.Build()
  60. }
  61. }
  62. runMultiTestCase(t, []TestCase{
  63. {
  64. Input: `{
  65. "strategy": "rules",
  66. "settings": {
  67. "domainStrategy": "AsIs",
  68. "rules": [
  69. {
  70. "type": "field",
  71. "domain": [
  72. "baidu.com",
  73. "qq.com"
  74. ],
  75. "outboundTag": "direct"
  76. },
  77. {
  78. "type": "field",
  79. "domains": [
  80. "v2fly.org",
  81. "github.com"
  82. ],
  83. "outboundTag": "direct"
  84. },
  85. {
  86. "type": "field",
  87. "ip": [
  88. "10.0.0.0/8",
  89. "::1/128"
  90. ],
  91. "outboundTag": "test"
  92. },{
  93. "type": "field",
  94. "port": "53, 443, 1000-2000",
  95. "outboundTag": "test"
  96. },{
  97. "type": "field",
  98. "port": 123,
  99. "outboundTag": "test"
  100. }
  101. ]
  102. },
  103. "balancers": [
  104. {
  105. "tag": "b1",
  106. "selector": ["test"]
  107. }
  108. ]
  109. }`,
  110. Parser: createParser(),
  111. Output: &router.Config{
  112. DomainStrategy: router.Config_AsIs,
  113. BalancingRule: []*router.BalancingRule{
  114. {
  115. Tag: "b1",
  116. OutboundSelector: []string{"test"},
  117. Strategy: "random",
  118. },
  119. },
  120. Rule: []*router.RoutingRule{
  121. {
  122. Domain: []*router.Domain{
  123. {
  124. Type: router.Domain_Plain,
  125. Value: "baidu.com",
  126. },
  127. {
  128. Type: router.Domain_Plain,
  129. Value: "qq.com",
  130. },
  131. },
  132. TargetTag: &router.RoutingRule_Tag{
  133. Tag: "direct",
  134. },
  135. },
  136. {
  137. Domain: []*router.Domain{
  138. {
  139. Type: router.Domain_Plain,
  140. Value: "v2fly.org",
  141. },
  142. {
  143. Type: router.Domain_Plain,
  144. Value: "github.com",
  145. },
  146. },
  147. TargetTag: &router.RoutingRule_Tag{
  148. Tag: "direct",
  149. },
  150. },
  151. {
  152. Geoip: []*router.GeoIP{
  153. {
  154. Cidr: []*router.CIDR{
  155. {
  156. Ip: []byte{10, 0, 0, 0},
  157. Prefix: 8,
  158. },
  159. {
  160. Ip: []byte{0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1},
  161. Prefix: 128,
  162. },
  163. },
  164. },
  165. },
  166. TargetTag: &router.RoutingRule_Tag{
  167. Tag: "test",
  168. },
  169. },
  170. {
  171. PortList: &net.PortList{
  172. Range: []*net.PortRange{
  173. {From: 53, To: 53},
  174. {From: 443, To: 443},
  175. {From: 1000, To: 2000},
  176. },
  177. },
  178. TargetTag: &router.RoutingRule_Tag{
  179. Tag: "test",
  180. },
  181. },
  182. {
  183. PortList: &net.PortList{
  184. Range: []*net.PortRange{
  185. {From: 123, To: 123},
  186. },
  187. },
  188. TargetTag: &router.RoutingRule_Tag{
  189. Tag: "test",
  190. },
  191. },
  192. },
  193. },
  194. },
  195. {
  196. Input: `{
  197. "strategy": "rules",
  198. "settings": {
  199. "domainStrategy": "IPIfNonMatch",
  200. "rules": [
  201. {
  202. "type": "field",
  203. "domain": [
  204. "baidu.com",
  205. "qq.com"
  206. ],
  207. "outboundTag": "direct"
  208. },
  209. {
  210. "type": "field",
  211. "domains": [
  212. "v2fly.org",
  213. "github.com"
  214. ],
  215. "outboundTag": "direct"
  216. },
  217. {
  218. "type": "field",
  219. "ip": [
  220. "10.0.0.0/8",
  221. "::1/128"
  222. ],
  223. "outboundTag": "test"
  224. }
  225. ]
  226. }
  227. }`,
  228. Parser: createParser(),
  229. Output: &router.Config{
  230. DomainStrategy: router.Config_IpIfNonMatch,
  231. Rule: []*router.RoutingRule{
  232. {
  233. Domain: []*router.Domain{
  234. {
  235. Type: router.Domain_Plain,
  236. Value: "baidu.com",
  237. },
  238. {
  239. Type: router.Domain_Plain,
  240. Value: "qq.com",
  241. },
  242. },
  243. TargetTag: &router.RoutingRule_Tag{
  244. Tag: "direct",
  245. },
  246. },
  247. {
  248. Domain: []*router.Domain{
  249. {
  250. Type: router.Domain_Plain,
  251. Value: "v2fly.org",
  252. },
  253. {
  254. Type: router.Domain_Plain,
  255. Value: "github.com",
  256. },
  257. },
  258. TargetTag: &router.RoutingRule_Tag{
  259. Tag: "direct",
  260. },
  261. },
  262. {
  263. Geoip: []*router.GeoIP{
  264. {
  265. Cidr: []*router.CIDR{
  266. {
  267. Ip: []byte{10, 0, 0, 0},
  268. Prefix: 8,
  269. },
  270. {
  271. Ip: []byte{0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1},
  272. Prefix: 128,
  273. },
  274. },
  275. },
  276. },
  277. TargetTag: &router.RoutingRule_Tag{
  278. Tag: "test",
  279. },
  280. },
  281. },
  282. },
  283. },
  284. {
  285. Input: `{
  286. "domainStrategy": "AsIs",
  287. "rules": [
  288. {
  289. "type": "field",
  290. "domain": [
  291. "baidu.com",
  292. "qq.com"
  293. ],
  294. "outboundTag": "direct"
  295. },
  296. {
  297. "type": "field",
  298. "domains": [
  299. "v2fly.org",
  300. "github.com"
  301. ],
  302. "outboundTag": "direct"
  303. },
  304. {
  305. "type": "field",
  306. "ip": [
  307. "10.0.0.0/8",
  308. "::1/128"
  309. ],
  310. "outboundTag": "test"
  311. }
  312. ]
  313. }`,
  314. Parser: createParser(),
  315. Output: &router.Config{
  316. DomainStrategy: router.Config_AsIs,
  317. Rule: []*router.RoutingRule{
  318. {
  319. Domain: []*router.Domain{
  320. {
  321. Type: router.Domain_Plain,
  322. Value: "baidu.com",
  323. },
  324. {
  325. Type: router.Domain_Plain,
  326. Value: "qq.com",
  327. },
  328. },
  329. TargetTag: &router.RoutingRule_Tag{
  330. Tag: "direct",
  331. },
  332. },
  333. {
  334. Domain: []*router.Domain{
  335. {
  336. Type: router.Domain_Plain,
  337. Value: "v2fly.org",
  338. },
  339. {
  340. Type: router.Domain_Plain,
  341. Value: "github.com",
  342. },
  343. },
  344. TargetTag: &router.RoutingRule_Tag{
  345. Tag: "direct",
  346. },
  347. },
  348. {
  349. Geoip: []*router.GeoIP{
  350. {
  351. Cidr: []*router.CIDR{
  352. {
  353. Ip: []byte{10, 0, 0, 0},
  354. Prefix: 8,
  355. },
  356. {
  357. Ip: []byte{0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1},
  358. Prefix: 128,
  359. },
  360. },
  361. },
  362. },
  363. TargetTag: &router.RoutingRule_Tag{
  364. Tag: "test",
  365. },
  366. },
  367. },
  368. },
  369. },
  370. })
  371. }