v2fly/proxy/vmess/inbound/config_json.go

// +build json

package inbound

import (
	"encoding/json"
	"errors"

	"v2ray.com/core/common"
	"v2ray.com/core/common/log"
	"v2ray.com/core/common/protocol"
	"v2ray.com/core/proxy/registry"
	"v2ray.com/core/proxy/vmess"

	"github.com/golang/protobuf/ptypes"
)

func (this *DetourConfig) UnmarshalJSON(data []byte) error {
	type JsonDetourConfig struct {
		ToTag string `json:"to"`
	}
	jsonConfig := new(JsonDetourConfig)
	if err := json.Unmarshal(data, jsonConfig); err != nil {
		return errors.New("VMess|Inbound: Failed to parse detour config: " + err.Error())
	}
	this.To = jsonConfig.ToTag
	return nil
}

type FeaturesConfig struct {
	Detour *DetourConfig `json:"detour"`
}

func (this *DefaultConfig) UnmarshalJSON(data []byte) error {
	type JsonDefaultConfig struct {
		AlterIDs uint16 `json:"alterId"`
		Level    byte   `json:"level"`
	}
	jsonConfig := new(JsonDefaultConfig)
	if err := json.Unmarshal(data, jsonConfig); err != nil {
		return errors.New("VMess|Inbound: Failed to parse default config: " + err.Error())
	}
	this.AlterId = uint32(jsonConfig.AlterIDs)
	if this.AlterId == 0 {
		this.AlterId = 32
	}
	this.Level = uint32(jsonConfig.Level)
	return nil
}

func (this *Config) UnmarshalJSON(data []byte) error {
	type JsonConfig struct {
		Users        []json.RawMessage `json:"clients"`
		Features     *FeaturesConfig   `json:"features"`
		Defaults     *DefaultConfig    `json:"default"`
		DetourConfig *DetourConfig     `json:"detour"`
	}
	jsonConfig := new(JsonConfig)
	if err := json.Unmarshal(data, jsonConfig); err != nil {
		return errors.New("VMess|Inbound: Failed to parse config: " + err.Error())
	}
	this.Default = jsonConfig.Defaults
	if this.Default == nil {
		this.Default = &DefaultConfig{
			Level:   0,
			AlterId: 32,
		}
	}
	this.Detour = jsonConfig.DetourConfig
	// Backward compatibility
	if jsonConfig.Features != nil && jsonConfig.DetourConfig == nil {
		this.Detour = jsonConfig.Features.Detour
	}
	this.User = make([]*protocol.User, len(jsonConfig.Users))
	for idx, rawData := range jsonConfig.Users {
		user := new(protocol.User)
		if err := json.Unmarshal(rawData, user); err != nil {
			return errors.New("VMess|Inbound: Invalid user: " + err.Error())
		}
		account := new(vmess.AccountPB)
		if err := json.Unmarshal(rawData, account); err != nil {
			return errors.New("VMess|Inbound: Invalid user: " + err.Error())
		}
		anyAccount, err := ptypes.MarshalAny(account)
		if err != nil {
			log.Error("VMess|Inbound: Failed to create account: ", err)
			return common.ErrBadConfiguration
		}
		user.Account = anyAccount
		this.User[idx] = user
	}

	return nil
}

func init() {
	registry.RegisterInboundConfig("vmess", func() interface{} { return new(Config) })
}