678eb81d54
* V3-898 Create ability for querying db in transaction scope * handling errors * fixing linter * Transaction updated * fixing empty lines linter * tx signatures changed * fixing comments
120 lines
3.0 KiB
Go
120 lines
3.0 KiB
Go
// Copyright (C) 2018 Storj Labs, Inc.
|
|
// See LICENSE for copying information.
|
|
|
|
package satellitedb
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/skyrings/skyring-common/tools/uuid"
|
|
"github.com/zeebo/errs"
|
|
|
|
"storj.io/storj/pkg/satellite"
|
|
"storj.io/storj/pkg/satellite/satellitedb/dbx"
|
|
)
|
|
|
|
// implementation of Users interface repository using spacemonkeygo/dbx orm
|
|
type users struct {
|
|
db dbx.Methods
|
|
}
|
|
|
|
// Get is a method for querying user from the database by id
|
|
func (users *users) Get(ctx context.Context, id uuid.UUID) (*satellite.User, error) {
|
|
user, err := users.db.Get_User_By_Id(ctx, dbx.User_Id(id[:]))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return userFromDBX(user)
|
|
}
|
|
|
|
// GetByCredentials is a method for querying user by credentials from the database.
|
|
func (users *users) GetByCredentials(ctx context.Context, password []byte, email string) (*satellite.User, error) {
|
|
userEmail := dbx.User_Email(email)
|
|
userPassword := dbx.User_PasswordHash(password)
|
|
|
|
user, err := users.db.Get_User_By_Email_And_PasswordHash(ctx, userEmail, userPassword)
|
|
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return userFromDBX(user)
|
|
}
|
|
|
|
// Insert is a method for inserting user into the database
|
|
func (users *users) Insert(ctx context.Context, user *satellite.User) (*satellite.User, error) {
|
|
userID, err := uuid.New()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
createdUser, err := users.db.Create_User(ctx,
|
|
dbx.User_Id(userID[:]),
|
|
dbx.User_FirstName(user.FirstName),
|
|
dbx.User_LastName(user.LastName),
|
|
dbx.User_Email(user.Email),
|
|
dbx.User_PasswordHash(user.PasswordHash))
|
|
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return userFromDBX(createdUser)
|
|
}
|
|
|
|
// Delete is a method for deleting user by Id from the database.
|
|
func (users *users) Delete(ctx context.Context, id uuid.UUID) error {
|
|
_, err := users.db.Delete_User_By_Id(ctx, dbx.User_Id(id[:]))
|
|
|
|
return err
|
|
}
|
|
|
|
// Update is a method for updating user entity
|
|
func (users *users) Update(ctx context.Context, user *satellite.User) error {
|
|
_, err := users.db.Update_User_By_Id(
|
|
ctx,
|
|
dbx.User_Id(user.ID[:]),
|
|
toUpdateUser(user),
|
|
)
|
|
|
|
return err
|
|
}
|
|
|
|
// toUpdateUser creates dbx.User_Update_Fields with only non-empty fields as updatable
|
|
func toUpdateUser(user *satellite.User) dbx.User_Update_Fields {
|
|
update := dbx.User_Update_Fields{
|
|
Email: dbx.User_Email(user.Email),
|
|
FirstName: dbx.User_FirstName(user.FirstName),
|
|
LastName: dbx.User_LastName(user.LastName),
|
|
}
|
|
|
|
// extra password check to update only calculated hash from service
|
|
if len(user.PasswordHash) == 32 {
|
|
update.PasswordHash = dbx.User_PasswordHash(user.PasswordHash)
|
|
}
|
|
|
|
return update
|
|
}
|
|
|
|
// userFromDBX is used for creating User entity from autogenerated dbx.User struct
|
|
func userFromDBX(user *dbx.User) (*satellite.User, error) {
|
|
if user == nil {
|
|
return nil, errs.New("user parameter is nil")
|
|
}
|
|
|
|
id, err := bytesToUUID(user.Id)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &satellite.User{
|
|
ID: id,
|
|
FirstName: user.FirstName,
|
|
LastName: user.LastName,
|
|
Email: user.Email,
|
|
PasswordHash: user.PasswordHash,
|
|
CreatedAt: user.CreatedAt,
|
|
}, nil
|
|
}
|