from flask import render_template, request, flash, redirect, url_for, Blueprint, jsonify from flask_login import login_user, logout_user, login_required, current_user from models import db, User, Notif from functools import wraps from datetime import datetime from utils import log_event, create_notification, get_unread_count auth_bp = Blueprint('auth', __name__) @auth_bp.context_processor def inject_unread_notifications(): if current_user.is_authenticated: unread_count = get_unread_count(current_user.id) return {'unread_notifications': unread_count} return {'unread_notifications': 0} def require_password_change(f): @wraps(f) def decorated_function(*args, **kwargs): if current_user.is_authenticated and current_user.check_password('changeme'): flash('Please change your password before continuing.', 'warning') return redirect(url_for('auth.change_password')) return f(*args, **kwargs) return decorated_function def init_routes(auth_bp): @auth_bp.route('/login', methods=['GET', 'POST']) def login(): if current_user.is_authenticated: return redirect(url_for('main.dashboard')) if request.method == 'POST': email = request.form.get('email') password = request.form.get('password') remember = True if request.form.get('remember') else False user = User.query.filter_by(email=email).first() if not user or not user.check_password(password): # Log failed login attempt log_event( event_type='user_login', details={ 'email': email, 'success': False, 'reason': 'invalid_credentials' } ) db.session.commit() flash('Please check your login details and try again.', 'danger') return redirect(url_for('auth.login')) login_user(user, remember=remember) # Log successful login log_event( event_type='user_login', details={ 'user_id': user.id, 'user_name': f"{user.username} {user.last_name}", 'email': user.email, 'success': True, 'remember': remember } ) db.session.commit() # Check if user is using default password if password == 'changeme': flash('Please change your password before continuing.', 'warning') return redirect(url_for('auth.change_password')) next_page = request.args.get('next') if next_page: return redirect(next_page) return redirect(url_for('main.dashboard')) return render_template('auth/login.html') @auth_bp.route('/register', methods=['GET', 'POST']) def register(): if current_user.is_authenticated: return redirect(url_for('main.dashboard')) if request.method == 'POST': email = request.form.get('email') username = request.form.get('username') password = request.form.get('password') user = User.query.filter_by(email=email).first() if user: flash('Email address already exists', 'danger') return redirect(url_for('auth.register')) user = User.query.filter_by(username=username).first() if user: flash('Username already exists', 'danger') return redirect(url_for('auth.register')) new_user = User(email=email, username=username) new_user.set_password(password) db.session.add(new_user) db.session.commit() # Create notification for the new user create_notification( notif_type='account_created', user_id=new_user.id, details={ 'message': 'Welcome to DocuPulse! Your account has been created successfully.', 'username': new_user.username, 'email': new_user.email, 'timestamp': datetime.utcnow().isoformat() } ) # Log successful registration log_event( event_type='user_create', details={ 'user_id': new_user.id, 'user_name': f"{new_user.username} {new_user.last_name}", 'email': new_user.email, 'method': 'web_form' } ) db.session.commit() login_user(new_user) return redirect(url_for('main.dashboard')) return render_template('auth/register.html') @auth_bp.route('/logout') @login_required def logout(): # Log logout event before logging out log_event( event_type='user_logout', details={ 'user_id': current_user.id, 'user_name': f"{current_user.username} {current_user.last_name}", 'email': current_user.email } ) db.session.commit() logout_user() return redirect(url_for('auth.login')) @auth_bp.route('/change-password', methods=['GET', 'POST']) @login_required def change_password(): if request.method == 'POST': current_password = request.form.get('current_password') new_password = request.form.get('new_password') confirm_password = request.form.get('confirm_password') if not current_user.check_password(current_password): # Log failed password change attempt log_event( event_type='user_update', details={ 'user_id': current_user.id, 'user_name': f"{current_user.username} {current_user.last_name}", 'update_type': 'password_change', 'success': False, 'reason': 'invalid_current_password' } ) db.session.commit() flash('Current password is incorrect.', 'danger') return redirect(url_for('auth.change_password')) if new_password != confirm_password: # Log failed password change attempt log_event( event_type='user_update', details={ 'user_id': current_user.id, 'user_name': f"{current_user.username} {current_user.last_name}", 'update_type': 'password_change', 'success': False, 'reason': 'passwords_dont_match' } ) db.session.commit() flash('New passwords do not match.', 'danger') return redirect(url_for('auth.change_password')) current_user.set_password(new_password) # Create password change notification create_notification( notif_type='password_changed', user_id=current_user.id, details={ 'message': 'Your password has been changed successfully.', 'timestamp': datetime.utcnow().isoformat() } ) # Log successful password change log_event( event_type='user_update', details={ 'user_id': current_user.id, 'user_name': f"{current_user.username} {current_user.last_name}", 'update_type': 'password_change', 'success': True } ) db.session.commit() flash('Password changed successfully!', 'success') return redirect(url_for('main.dashboard')) return render_template('auth/change_password.html')