feat: user create
This commit is contained in:
@@ -110,12 +110,12 @@ func (m *Users) List(ctx context.Context, pagination *requests.Pagination, cond
|
||||
}
|
||||
|
||||
// Create creates a new user
|
||||
func (m *Users) Create(ctx context.Context, userModel *Users) (*Users, error) {
|
||||
userModel.CreatedAt = time.Now()
|
||||
userModel.UpdatedAt = time.Now()
|
||||
func (m *Users) Create(ctx context.Context) (*Users, error) {
|
||||
m.CreatedAt = time.Now()
|
||||
m.UpdatedAt = time.Now()
|
||||
|
||||
tbl := table.Users
|
||||
stmt := tbl.INSERT(tbl.MutableColumns).MODEL(userModel).RETURNING(tbl.AllColumns)
|
||||
stmt := tbl.INSERT(tbl.MutableColumns).MODEL(m).RETURNING(tbl.AllColumns)
|
||||
m.log().Infof("sql: %s", stmt.DebugSql())
|
||||
|
||||
var createdUser Users
|
||||
@@ -256,7 +256,7 @@ func (m *Users) GetUserByOpenIDOrCreate(ctx context.Context, openID string, user
|
||||
user, err := m.GetUserByOpenID(ctx, openID)
|
||||
if err != nil {
|
||||
if errors.Is(err, qrm.ErrNoRows) {
|
||||
user, err = m.Create(ctx, userModel)
|
||||
user, err = userModel.Create(ctx)
|
||||
if err != nil {
|
||||
return nil, errors.Wrap(err, "failed to create user")
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user