Method SyncUser

backend/xray/user.go:120–156

(ctx context.Context, user *common.User)

}

func (x *Xray) SyncUser(ctx context.Context, user *common.User) error {
	proxySetting, err := setupUserAccount(user)
	if err != nil {
		return err
	}

	handler := x.handler
	inbounds := x.config.InboundConfigs

	var errMessage string

	userInbounds := user.GetInbounds()

	for _, inbound := range inbounds {
		if inbound.exclude {
			continue
		}

		_ = handler.RemoveInboundUser(ctx, inbound.Tag, user.Email)
		account, isActive := isActiveInbound(inbound, userInbounds, proxySetting)
		if isActive {
			inbound.updateUser(account)
			err = handler.AddInboundUser(ctx, inbound.Tag, accountForAPI(inbound, account))
			if err != nil {
				log.Println(err)
				errMessage += "\n" + err.Error()
			}
		} else {
			inbound.removeUser(user.GetEmail())
		}
	}

	if errMessage != "" {
		return errors.New("failed to add user:" + errMessage)
	}
	return nil
}

func (x *Xray) SyncUsers(ctx context.Context, users []*common.User) error {
	x.config.syncUsers(users)