from sqlalchemy.dialects.postgresql import UUID from sqlalchemy.orm import declarative_base from flask_sqlalchemy import SQLAlchemy from werkzeug.security import generate_password_hash, check_password_hash from datetime import datetime from flask_login import UserMixin import uuid Base = declarative_base() db = SQLAlchemy(model_class=Base) class User(Base, UserMixin): __tablename__ = 'users' id = db.Column(db.Integer, primary_key=True, autoincrement=True) first_name = db.Column(db.String(255), nullable=False) last_name = db.Column(db.String(255), nullable=False) email = db.Column(db.String(255), unique=True, nullable=False) password_hash = db.Column(db.String(2048), nullable=False) imap_config = db.Column(db.JSON) # Using db.JSON instead of db.JSONB for compatibility created_at = db.Column(db.DateTime, default=datetime.utcnow) updated_at = db.Column(db.DateTime, default=datetime.utcnow, onupdate=datetime.utcnow) def set_password(self, password): """Hash and set the password.""" self.password_hash = generate_password_hash(password) def check_password(self, password): """Check if the provided password matches the stored hash.""" return check_password_hash(self.password_hash, password) def __repr__(self): return f'' class Folder(Base): __tablename__ = 'folders' id = db.Column(db.Integer, primary_key=True, autoincrement=True) user_id = db.Column(db.Integer, db.ForeignKey('users.id'), nullable=False) name = db.Column(db.String(255), nullable=False) rule_text = db.Column(db.Text) priority = db.Column(db.Integer) organize_enabled = db.Column(db.Boolean, default=True) folder_type = db.Column(db.String(20), default='destination', nullable=False) total_count = db.Column(db.Integer, default=0) pending_count = db.Column(db.Integer, default=0) emails_count = db.Column(db.Integer, default=0) recent_emails = db.Column(db.JSON, default=list) # Store recent email subjects with dates user = db.relationship('User', backref=db.backref('folders', lazy=True)) class ProcessedEmail(Base): __tablename__ = 'processed_emails' id = db.Column(db.Integer, primary_key=True, autoincrement=True) user_id = db.Column(db.Integer, db.ForeignKey('users.id'), nullable=False) folder_id = db.Column(db.Integer, db.ForeignKey('folders.id'), nullable=False) email_uid = db.Column(db.String(255), nullable=False) folder_name = db.Column(db.String(255), nullable=False) is_processed = db.Column(db.Boolean, default=False) first_seen_at = db.Column(db.DateTime, default=datetime.utcnow) processed_at = db.Column(db.DateTime, nullable=True) created_at = db.Column(db.DateTime, default=datetime.utcnow) updated_at = db.Column(db.DateTime, default=datetime.utcnow, onupdate=datetime.utcnow) user = db.relationship('User', backref=db.backref('processed_emails', lazy=True)) folder = db.relationship('Folder', backref=db.backref('processed_emails', lazy=True)) def __repr__(self): return f''