50 lines
1.3 KiB
Go
50 lines
1.3 KiB
Go
package domain
|
|
|
|
import (
|
|
"context"
|
|
"log/slog"
|
|
)
|
|
|
|
type RegistrationService struct {
|
|
tx Transactor
|
|
UserService *UserService
|
|
InviteService *InviteService
|
|
}
|
|
|
|
func NewRegistrationService(tx Transactor, u *UserService, i *InviteService) *RegistrationService {
|
|
return &RegistrationService{tx: tx, UserService: u, InviteService: i}
|
|
}
|
|
|
|
func (s *RegistrationService) Register(ctx context.Context, inviteCode string, email string, username string, password string) (*User, error) {
|
|
invite, err := s.InviteService.GetInvite(ctx, inviteCode)
|
|
if err != nil {
|
|
slog.ErrorContext(ctx, "failed to get invite", slog.Any("error", err))
|
|
return nil, err
|
|
}
|
|
|
|
var user *User
|
|
err = s.tx.WithinTx(ctx, func(ctx context.Context) error {
|
|
user, err = s.UserService.CreateUser(ctx, email, username, password)
|
|
if err != nil {
|
|
slog.ErrorContext(ctx, "failed to create user", slog.Any("error", err))
|
|
return err
|
|
}
|
|
|
|
err = s.InviteService.ConsumeInvite(ctx, invite.ID, user.ID)
|
|
if err != nil {
|
|
slog.ErrorContext(ctx, "failed to consume invite", slog.Any("error", err))
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
slog.InfoContext(ctx, "user registration complete",
|
|
slog.String("user_id", user.ID),
|
|
slog.String("invite_id", invite.ID))
|
|
return user, nil
|
|
}
|