2016-03-20 16:36:56 +02:00
|
|
|
from freeposte.admin import db
|
2016-02-20 14:57:26 +02:00
|
|
|
|
2016-03-19 21:37:48 +02:00
|
|
|
from sqlalchemy.ext import declarative
|
|
|
|
from passlib import context
|
2016-03-20 12:31:14 +02:00
|
|
|
from datetime import datetime
|
2016-03-19 21:37:48 +02:00
|
|
|
|
2016-03-20 16:36:56 +02:00
|
|
|
import re
|
|
|
|
|
2016-03-19 21:37:48 +02:00
|
|
|
|
|
|
|
# Many-to-many association table for domain administrators
|
|
|
|
admins = db.Table('admin',
|
|
|
|
db.Column('domain_name', db.String(80), db.ForeignKey('domain.name')),
|
|
|
|
db.Column('user_domain_name', db.String(80)),
|
|
|
|
db.Column('user_localpart', db.String(80)),
|
|
|
|
db.ForeignKeyConstraint(
|
|
|
|
('user_domain_name', 'user_localpart'),
|
|
|
|
('user.domain_name', 'user.localpart')
|
|
|
|
)
|
|
|
|
)
|
2016-02-20 14:57:26 +02:00
|
|
|
|
2016-02-20 21:11:59 +02:00
|
|
|
|
2016-03-20 12:31:14 +02:00
|
|
|
class Base(db.Model):
|
|
|
|
""" Base class for all models
|
|
|
|
"""
|
|
|
|
|
|
|
|
__abstract__ = True
|
|
|
|
|
|
|
|
created_at = db.Column(db.Date, nullable=False, default=datetime.now)
|
|
|
|
updated_at = db.Column(db.Date, nullable=True, onupdate=datetime.now)
|
2016-03-20 12:38:37 +02:00
|
|
|
comment = db.Column(db.String(255), nullable=True)
|
2016-03-20 12:31:14 +02:00
|
|
|
|
|
|
|
|
|
|
|
class Domain(Base):
|
2016-03-19 21:37:48 +02:00
|
|
|
""" A DNS domain that has mail addresses associated to it.
|
|
|
|
"""
|
|
|
|
name = db.Column(db.String(80), primary_key=True, nullable=False)
|
|
|
|
admins = db.relationship('User', secondary=admins,
|
|
|
|
backref=db.backref('admin_of'), lazy='dynamic')
|
|
|
|
max_users = db.Column(db.Integer, nullable=True)
|
|
|
|
max_aliases = db.Column(db.Integer, nullable=True)
|
2016-02-20 14:57:26 +02:00
|
|
|
|
2016-03-22 20:47:15 +02:00
|
|
|
def has_address(self, localpart):
|
|
|
|
for address in self.users + self.aliases:
|
|
|
|
if address.localpart == localpart:
|
|
|
|
return True
|
|
|
|
else:
|
|
|
|
return False
|
|
|
|
|
2016-02-20 14:57:26 +02:00
|
|
|
def __str__(self):
|
|
|
|
return self.name
|
|
|
|
|
|
|
|
|
2016-03-20 12:31:14 +02:00
|
|
|
class Address(Base):
|
2016-03-19 21:37:48 +02:00
|
|
|
""" Abstraction for a mail address (localpart and domain).
|
|
|
|
"""
|
|
|
|
__abstract__ = True
|
|
|
|
|
|
|
|
localpart = db.Column(db.String(80), primary_key=True, nullable=False)
|
|
|
|
|
|
|
|
@declarative.declared_attr
|
|
|
|
def domain_name(cls):
|
|
|
|
return db.Column(db.String(80), db.ForeignKey(Domain.name),
|
|
|
|
primary_key=True, nullable=False)
|
2016-02-20 14:57:26 +02:00
|
|
|
|
|
|
|
def __str__(self):
|
2016-03-19 21:37:48 +02:00
|
|
|
return '{0}@{1}'.format(self.localpart, self.domain_name)
|
2016-02-20 14:57:26 +02:00
|
|
|
|
2016-03-19 21:37:48 +02:00
|
|
|
def get_id(self):
|
|
|
|
return str(self)
|
2016-02-20 14:57:26 +02:00
|
|
|
|
2016-03-19 21:37:48 +02:00
|
|
|
@classmethod
|
|
|
|
def get_by_email(cls, email):
|
|
|
|
localpart, domain = email.split('@', maxsplit=1)
|
|
|
|
# Get the user object
|
|
|
|
return cls.query.filter_by(domain_name=domain, localpart=localpart).first()
|
2016-02-20 14:57:26 +02:00
|
|
|
|
2016-03-19 21:37:48 +02:00
|
|
|
|
|
|
|
class User(Address):
|
|
|
|
""" A user is a mail address that has a password to access a mailbox.
|
|
|
|
"""
|
|
|
|
domain = db.relationship(Domain, backref='users')
|
|
|
|
password = db.Column(db.String(255), nullable=False)
|
|
|
|
quota_bytes = db.Column(db.Integer(), nullable=False, default=10**9)
|
|
|
|
global_admin = db.Column(db.Boolean(), nullable=False, default=False)
|
|
|
|
|
2016-03-20 12:00:01 +02:00
|
|
|
# Filters
|
|
|
|
forward = db.Column(db.String(160), nullable=True, default=None)
|
2016-03-20 12:14:27 +02:00
|
|
|
reply_subject = db.Column(db.String(255), nullable=True, default=None)
|
2016-03-20 12:00:01 +02:00
|
|
|
reply_body = db.Column(db.Text(), nullable=True, default=None)
|
|
|
|
|
2016-03-20 12:09:06 +02:00
|
|
|
# Settings
|
|
|
|
displayed_name = db.Column(db.String(160), nullable=False, default="")
|
|
|
|
spam_enabled = db.Column(db.Boolean(), nullable=False, default=True)
|
|
|
|
spam_threshold = db.Column(db.Numeric(), nullable=False, default=5.0)
|
|
|
|
|
|
|
|
# Flask-login attributes
|
2016-03-19 21:37:48 +02:00
|
|
|
is_authenticated = True
|
|
|
|
is_active = True
|
|
|
|
is_anonymous = False
|
|
|
|
|
2016-03-20 16:36:56 +02:00
|
|
|
pw_context = context.CryptContext(
|
|
|
|
["sha512_crypt", "sha256_crypt", "md5_crypt"]
|
|
|
|
)
|
2016-03-19 21:37:48 +02:00
|
|
|
|
|
|
|
def check_password(self, password):
|
2016-03-20 16:36:56 +02:00
|
|
|
reference = re.match('({[^}]+})?(.*)', self.password).group(2)
|
|
|
|
return User.pw_context.verify(password, reference)
|
2016-03-19 21:37:48 +02:00
|
|
|
|
|
|
|
def set_password(self, password):
|
2016-03-20 16:36:56 +02:00
|
|
|
self.password = '{SHA512-CRYPT}' + User.pw_context.encrypt(password)
|
2016-03-19 21:37:48 +02:00
|
|
|
|
|
|
|
def get_managed_domains(self):
|
|
|
|
if self.global_admin:
|
|
|
|
return Domain.query.all()
|
|
|
|
else:
|
|
|
|
return self.admin_of
|
|
|
|
|
|
|
|
@classmethod
|
|
|
|
def login(cls, email, password):
|
|
|
|
user = cls.get_by_email(email)
|
|
|
|
return user if (user and user.check_password(password)) else None
|
|
|
|
|
|
|
|
|
|
|
|
class Alias(Address):
|
|
|
|
""" An alias is a mail address that redirects to some other addresses.
|
|
|
|
"""
|
|
|
|
domain = db.relationship(Domain, backref='aliases')
|
|
|
|
destination = db.Column(db.String(), nullable=False)
|