Skip to content

Commit b09dee5

Browse files
authored
Merge pull request #334 from yokowu/feat-unlimit-user
feat: 取消用户限制配置参数
2 parents 21d77b3 + 6f92119 commit b09dee5

File tree

2 files changed

+0
-23
lines changed

2 files changed

+0
-23
lines changed

backend/config/config.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ type Config struct {
3030
Admin struct {
3131
User string `mapstructure:"user"`
3232
Password string `mapstructure:"password"`
33-
Limit int `mapstructure:"limit"`
3433
} `mapstructure:"admin"`
3534

3635
Session struct {
@@ -128,7 +127,6 @@ func Init() (*Config, error) {
128127
v.SetDefault("server.port", "")
129128
v.SetDefault("admin.user", "admin")
130129
v.SetDefault("admin.password", "")
131-
v.SetDefault("admin.limit", 100)
132130
v.SetDefault("session.expire_day", 30)
133131
v.SetDefault("database.master", "")
134132
v.SetDefault("database.slave", "")

backend/internal/user/repo/user.go

Lines changed: 0 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -139,9 +139,6 @@ func (r *UserRepo) innerValidateInviteCode(ctx context.Context, tx *db.Tx, code
139139
func (r *UserRepo) CreateUser(ctx context.Context, us *db.User) (*db.User, error) {
140140
var res *db.User
141141
err := entx.WithTx(ctx, r.db, func(tx *db.Tx) error {
142-
if err := r.checkLimit(ctx, tx); err != nil {
143-
return err
144-
}
145142
n, err := tx.User.Query().Where(user.Email(us.Email)).Count(ctx)
146143
if err != nil {
147144
return err
@@ -371,10 +368,6 @@ func (r *UserRepo) DeleteAdmin(ctx context.Context, id string) error {
371368
func (r *UserRepo) OAuthRegister(ctx context.Context, platform consts.UserPlatform, inviteCode string, req *domain.OAuthUserInfo) (*db.User, error) {
372369
var u *db.User
373370
err := entx.WithTx(ctx, r.db, func(tx *db.Tx) error {
374-
if err := r.checkLimit(ctx, tx); err != nil {
375-
return err
376-
}
377-
378371
if _, err := r.innerValidateInviteCode(ctx, tx, inviteCode); err != nil {
379372
return errcode.ErrInviteCodeInvalid.Wrap(err)
380373
}
@@ -447,17 +440,6 @@ func (r *UserRepo) updateAvatar(ctx context.Context, tx *db.Tx, ui *db.UserIdent
447440
return tx.User.UpdateOneID(ui.UserID).SetAvatarURL(avatar).Exec(ctx)
448441
}
449442

450-
func (r *UserRepo) checkLimit(ctx context.Context, tx *db.Tx) error {
451-
count, err := tx.User.Query().Count(ctx)
452-
if err != nil {
453-
return err
454-
}
455-
if count >= r.cfg.Admin.Limit {
456-
return errcode.ErrUserLimit.Wrap(err)
457-
}
458-
return nil
459-
}
460-
461443
func (r *UserRepo) SignUpOrIn(ctx context.Context, platform consts.UserPlatform, req *domain.OAuthUserInfo) (*db.User, error) {
462444
var u *db.User
463445
err := entx.WithTx(ctx, r.db, func(tx *db.Tx) error {
@@ -480,9 +462,6 @@ func (r *UserRepo) SignUpOrIn(ctx context.Context, platform consts.UserPlatform,
480462
if !db.IsNotFound(err) {
481463
return err
482464
}
483-
if err = r.checkLimit(ctx, tx); err != nil {
484-
return err
485-
}
486465
user, err := tx.User.Create().
487466
SetUsername(req.Name).
488467
SetEmail(req.Email).

0 commit comments

Comments
 (0)