v2fly/infra/conf/merge/merge_test.go

// Copyright 2020 Jebbs. All rights reserved.
// Use of this source code is governed by MIT
// license that can be found in the LICENSE file.

package merge_test

import (
	"bytes"
	"reflect"
	"strings"
	"testing"

	"github.com/v2fly/v2ray-core/v5/infra/conf/merge"
	"github.com/v2fly/v2ray-core/v5/infra/conf/serial"
)

func TestMergeV2Style(t *testing.T) {
	json1 := `
	  {
		"log": {"access": "some_value", "loglevel": "debug"},
		"inbounds": [{"tag": "in-1"}],
		"outbounds": [{"_priority": 100, "tag": "out-1"}],
		"routing": {"rules": [
		  {"_tag":"default_route","inboundTag":["in-1"],"outboundTag":"out-1"}
		]}
	  }
`
	json2 := `
	  {
		"log": {"loglevel": "error"},
		"inbounds": [{"tag": "in-2"}],
		"outbounds": [{"_priority": -100, "tag": "out-2"}],
		"routing": {"rules": [
		  {"inboundTag":["in-2"],"outboundTag":"out-2"},
		  {"_tag":"default_route","inboundTag":["in-1.1"],"outboundTag":"out-1.1"}
		]}
	  }
`
	expected := `
	{
	  "log": {"access": "some_value", "loglevel": "error"},
	  "inbounds": [{"tag": "in-1"},{"tag": "in-2"}],
	  "outbounds": [
		   {"tag": "out-2"},
		   {"tag": "out-1"}
	  ],
	  "routing": {"rules": [
		   {"inboundTag":["in-1","in-1.1"],"outboundTag":"out-1.1"},
		   {"inboundTag":["in-2"],"outboundTag":"out-2"}
	  ]}
	}
	`
	m, err := merge.JSONs([][]byte{[]byte(json1), []byte(json2)})
	if err != nil {
		t.Error(err)
	}
	assertResult(t, m, expected)
}

func TestMergeTag(t *testing.T) {
	json1 := `
	{
	  	"routing": {
		  	"rules": [{
				"tag":"1",
				"inboundTag": ["in-1"],
				"outboundTag": "out-1"
			}]
		}
	}
`
	json2 := `
	{
	  	"routing": {
		  	"rules": [{
				"_tag":"1",
				"inboundTag": ["in-2"],
				"outboundTag": "out-2"
			}]
		}
	}
`
	expected := `
	{
	  	"routing": {
			"rules": [{
				"tag":"1",
				"inboundTag": ["in-1", "in-2"],
				"outboundTag": "out-2"
			}]
	  	}
	}
	`
	m, err := merge.JSONs([][]byte{[]byte(json1), []byte(json2)})
	if err != nil {
		t.Error(err)
	}
	assertResult(t, m, expected)
}

func TestMergeTagValueTypes(t *testing.T) {
	json1 := `
	{
	  	"array_1": [{
			"_tag":"1",
			"array_2": [{
				"_tag":"2",
				"array_3.1": ["string",true,false],
				"array_3.2": [1,2,3],
				"number_1": 1,
				"number_2": 1,
				"bool_1": true,
				"bool_2": true
			}]
		}]
	}
`
	json2 := `
	{
		"array_1": [{
			"_tag":"1",
			"array_2": [{
				"_tag":"2",
				"array_3.1": [0,1,null],
				"array_3.2": null,
				"number_1": 0,
				"number_2": 1,
				"bool_1": true,
				"bool_2": false,
				"null_1": null
			}]
		}]
	}
`
	expected := `
	{
	  "array_1": [{
		"array_2": [{
			"array_3.1": ["string",true,false,0,1,null],
			"array_3.2": [1,2,3],
			"number_1": 0,
			"number_2": 1,
			"bool_1": true,
			"bool_2": false,
			"null_1": null
		}]
	  }]
	}
	`
	m, err := merge.JSONs([][]byte{[]byte(json1), []byte(json2)})
	if err != nil {
		t.Error(err)
	}
	assertResult(t, m, expected)
}

func TestMergeTagDeep(t *testing.T) {
	json1 := `
	{
	  	"array_1": [{
			"_tag":"1",
			"array_2": [{
				"_tag":"2",
				"array_3": [true,false,"string"]
			}]
		}]
	}
`
	json2 := `
	{
	  	"array_1": [{
			"_tag":"1",
			"array_2": [{
				"_tag":"2",
				"_priority":-100,
				"array_3": [0,1,null]
			}]
		}]
	}
`
	expected := `
	{
	  	"array_1": [{
			"array_2": [{
				"array_3": [0,1,null,true,false,"string"]
			}]
		}]
	}
	`
	m, err := merge.JSONs([][]byte{[]byte(json1), []byte(json2)})
	if err != nil {
		t.Error(err)
	}
	assertResult(t, m, expected)
}

func TestNoMergeDnsServers(t *testing.T) {
	json1 := `
	{
		"dns": {
			"queryStrategy": "UseIPv4",
			"fallbackStrategy": "disabled-if-any-match",
			"domainMatcher": "mph",
			"servers": [
				{
					"address": "aaa.bbb.ccc.ddd",
					"port": 53,
					"domains": [
						"geosite:cn"
					],
					"tag": "dns-domestic"
				},
				{
					"address": "114.114.114.114",
					"port": 53,
					"domains": [
						"geosite:cn"
					],
					"tag": "dns-domestic"
				},
				{
					"address": "https://1.1.1.1/dns-query",
					"tag": "dns-international"
				}
			]
		},
		"routing": {
			"domainStrategy": "IPIfNonMatch",
			"domainMatcher": "mph",
			"rules": [
				{
					"type": "field",
					"inboundTag": "dns-domestic",
					"outboundTag": "direct"
				},
				{
					"type": "field",
					"inboundTag": "dns-international",
					"outboundTag": "proxy"
				}
			]
		}
	}
`
	expected := `
	{
		"dns": {
			"queryStrategy": "UseIPv4",
			"fallbackStrategy": "disabled-if-any-match",
			"domainMatcher": "mph",
			"servers": [
				{
					"address": "aaa.bbb.ccc.ddd",
					"port": 53,
					"domains": [
						"geosite:cn"
					],
					"tag": "dns-domestic"
				},
				{
					"address": "114.114.114.114",
					"port": 53,
					"domains": [
						"geosite:cn"
					],
					"tag": "dns-domestic"
				},
				{
					"address": "https://1.1.1.1/dns-query",
					"tag": "dns-international"
				}
			]
		},
		"routing": {
			"domainStrategy": "IPIfNonMatch",
			"domainMatcher": "mph",
			"rules": [
				{
					"type": "field",
					"inboundTag": "dns-domestic",
					"outboundTag": "direct"
				},
				{
					"type": "field",
					"inboundTag": "dns-international",
					"outboundTag": "proxy"
				}
			]
		}
	}
`
	m, err := merge.JSONs([][]byte{[]byte(json1)})
	if err != nil {
		t.Error(err)
	}
	assertResult(t, m, expected)
}

func assertResult(t *testing.T, value []byte, expected string) {
	v := make(map[string]interface{})
	err := serial.DecodeJSON(bytes.NewReader(value), &v)
	if err != nil {
		t.Error(err)
	}
	e := make(map[string]interface{})
	err = serial.DecodeJSON(strings.NewReader(expected), &e)
	if err != nil {
		t.Error(err)
	}
	if !reflect.DeepEqual(v, e) {
		t.Fatalf("expected:\n%s\n\nactual:\n%s", expected, string(value))
	}
}