Method syncUsers

backend/xray/config.go:121–203

(users []*common.User)

}

func (i *Inbound) syncUsers(users []*common.User) {
	i.mu.Lock()
	defer i.mu.Unlock()

	// Clear existing clients map
	i.clients = make(map[string]api.Account)

	switch i.Protocol {
	case Vmess:
		for _, user := range users {
			if user.GetProxies().GetVmess() == nil {
				continue
			}
			if slices.Contains(user.Inbounds, i.Tag) {
				account, err := api.NewVmessAccount(user)
				if err != nil {
					log.Println("error for user", user.GetEmail(), ":", err)
					continue
				}
				i.clients[user.GetEmail()] = account
			}
		}

	case Vless:
		for _, user := range users {
			if user.GetProxies().GetVless() == nil {
				continue
			}
			if slices.Contains(user.Inbounds, i.Tag) {
				account, err := api.NewVlessAccount(user)
				if err != nil {
					log.Println("error for user", user.GetEmail(), ":", err)
					continue
				}
				i.clients[user.GetEmail()] = account
			}
		}

	case Trojan:
		for _, user := range users {
			if user.GetProxies().GetTrojan() == nil {
				continue
			}
			if slices.Contains(user.Inbounds, i.Tag) {
				i.clients[user.GetEmail()] = api.NewTrojanAccount(user)
			}
		}

	case Shadowsocks:
		method, methodOk := i.Settings["method"].(string)
		if methodOk && strings.HasPrefix(method, "2022-blake3") {
			for _, user := range users {
				if user.GetProxies().GetShadowsocks() == nil {
					continue
				}
				if slices.Contains(user.Inbounds, i.Tag) {
					account := api.NewShadowsocksAccount(user)
					newAccount := checkShadowsocks2022(method, *account)