refactor(service): enrich UserService.create_user
This commit is contained in:
parent
f5f86a2bc7
commit
0698ba5c1f
1 changed files with 48 additions and 30 deletions
|
|
@ -1,42 +1,60 @@
|
||||||
from models.User.user import User, db
|
from models.User.user import User
|
||||||
import logging
|
from models.UserProfile.user_profile import UserProfile
|
||||||
|
from models import db
|
||||||
logger = logging.getLogger(__name__)
|
import re
|
||||||
|
|
||||||
|
|
||||||
class UserService:
|
class UserService:
|
||||||
def create_user(self, username, password):
|
def create_user(self, username, password, email=None, first_name=None, last_name=None):
|
||||||
if not username or not password:
|
if not username or not password:
|
||||||
raise ValueError("Username and password are required")
|
raise ValueError("Username and password are required")
|
||||||
|
|
||||||
if len(username) < 5 or len(password) < 12:
|
if email:
|
||||||
raise ValueError(
|
email_regex = r'^[a-zA-Z0-9._%+-]+@[a-zA-Z0-9.-]+\.[a-zA-Z]{2,}$'
|
||||||
"Username must be at least 5 characters and password must be at least 12 characters."
|
if not re.match(email_regex, email):
|
||||||
)
|
raise ValueError("Invalid email format")
|
||||||
|
|
||||||
existing_user = User.query.filter_by(username=username).first()
|
existing_user = User.query.filter(
|
||||||
|
(User.username == username) | (User.email == email)
|
||||||
|
).first()
|
||||||
|
|
||||||
if existing_user:
|
if existing_user:
|
||||||
raise ValueError("User already exists")
|
if existing_user.username == username:
|
||||||
|
raise ValueError("Username already exists")
|
||||||
new_user = User(username=username, password=password)
|
else:
|
||||||
db.session.add(new_user)
|
raise ValueError("Email already exists")
|
||||||
|
|
||||||
|
if len(password) < 8:
|
||||||
|
raise ValueError("Password must be at least 8 characters long")
|
||||||
|
|
||||||
try:
|
try:
|
||||||
|
new_user = User(
|
||||||
|
username=username,
|
||||||
|
email=email or "",
|
||||||
|
password=password
|
||||||
|
)
|
||||||
|
|
||||||
|
db.session.add(new_user)
|
||||||
|
db.session.flush()
|
||||||
|
|
||||||
|
user_profile = UserProfile(
|
||||||
|
user_id=new_user.id,
|
||||||
|
first_name=first_name or "",
|
||||||
|
last_name=last_name or "",
|
||||||
|
bio="",
|
||||||
|
profile_picture=""
|
||||||
|
)
|
||||||
|
|
||||||
|
db.session.add(user_profile)
|
||||||
db.session.commit()
|
db.session.commit()
|
||||||
|
|
||||||
|
return new_user
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
db.session.rollback()
|
db.session.rollback()
|
||||||
logger.error(f"Error creating user: {e}")
|
raise Exception(f"Error creating user: {str(e)}")
|
||||||
raise ValueError("Could not create user") from e
|
|
||||||
return new_user
|
|
||||||
|
|
||||||
def verify_user(self, username, password):
|
def verify_user(self, username, password):
|
||||||
user = User.query.filter_by(username=username).first()
|
user = User.query.filter_by(username=username).first()
|
||||||
if not user:
|
if not user or not user.check_password(password):
|
||||||
logger.warning(f"User not found: {username}")
|
|
||||||
raise ValueError("Invalid username or password")
|
raise ValueError("Invalid username or password")
|
||||||
|
return user
|
||||||
if not user.check_password(password):
|
|
||||||
logger.warning(f"Invalid password for user: {username}")
|
|
||||||
raise ValueError("Invalid username or password")
|
|
||||||
|
|
||||||
logger.info(f"User verified: {username}")
|
|
||||||
return user
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue