1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980 |
- package conf
- import (
- "encoding/json"
- "github.com/golang/protobuf/proto"
- "github.com/xtls/xray-core/common/protocol"
- "github.com/xtls/xray-core/common/serial"
- "github.com/xtls/xray-core/proxy/http"
- )
- type HTTPAccount struct {
- Username string `json:"user"`
- Password string `json:"pass"`
- }
- func (v *HTTPAccount) Build() *http.Account {
- return &http.Account{
- Username: v.Username,
- Password: v.Password,
- }
- }
- type HTTPServerConfig struct {
- Timeout uint32 `json:"timeout"`
- Accounts []*HTTPAccount `json:"accounts"`
- Transparent bool `json:"allowTransparent"`
- UserLevel uint32 `json:"userLevel"`
- }
- func (c *HTTPServerConfig) Build() (proto.Message, error) {
- config := &http.ServerConfig{
- Timeout: c.Timeout,
- AllowTransparent: c.Transparent,
- UserLevel: c.UserLevel,
- }
- if len(c.Accounts) > 0 {
- config.Accounts = make(map[string]string)
- for _, account := range c.Accounts {
- config.Accounts[account.Username] = account.Password
- }
- }
- return config, nil
- }
- type HTTPRemoteConfig struct {
- Address *Address `json:"address"`
- Port uint16 `json:"port"`
- Users []json.RawMessage `json:"users"`
- }
- type HTTPClientConfig struct {
- Servers []*HTTPRemoteConfig `json:"servers"`
- }
- func (v *HTTPClientConfig) Build() (proto.Message, error) {
- config := new(http.ClientConfig)
- config.Server = make([]*protocol.ServerEndpoint, len(v.Servers))
- for idx, serverConfig := range v.Servers {
- server := &protocol.ServerEndpoint{
- Address: serverConfig.Address.Build(),
- Port: uint32(serverConfig.Port),
- }
- for _, rawUser := range serverConfig.Users {
- user := new(protocol.User)
- if err := json.Unmarshal(rawUser, user); err != nil {
- return nil, newError("failed to parse HTTP user").Base(err).AtError()
- }
- account := new(HTTPAccount)
- if err := json.Unmarshal(rawUser, account); err != nil {
- return nil, newError("failed to parse HTTP account").Base(err).AtError()
- }
- user.Account = serial.ToTypedMessage(account.Build())
- server.User = append(server.User, user)
- }
- config.Server[idx] = server
- }
- return config, nil
- }
|