Merge remote-tracking branch 'upstream/master' into refactor-config
This commit is contained in:
@@ -25,4 +25,4 @@ ENV FLASK_APP mailu
|
||||
|
||||
CMD /start.py
|
||||
|
||||
HEALTHCHECK CMD curl -f -L http://localhost/ui || exit 1
|
||||
HEALTHCHECK CMD curl -f -L http://localhost/ui/login?next=ui.index || exit 1
|
||||
|
||||
@@ -6,7 +6,9 @@ import flask
|
||||
|
||||
@internal.route("/postfix/domain/<domain_name>")
|
||||
def postfix_mailbox_domain(domain_name):
|
||||
domain = models.Domain.query.get(domain_name) or flask.abort(404)
|
||||
domain = models.Domain.query.get(domain_name) or \
|
||||
models.Alternative.query.get(domain_name) or \
|
||||
flask.abort(404)
|
||||
return flask.jsonify(domain.name)
|
||||
|
||||
|
||||
@@ -18,37 +20,34 @@ def postfix_mailbox_map(email):
|
||||
|
||||
@internal.route("/postfix/alias/<alias>")
|
||||
def postfix_alias_map(alias):
|
||||
localpart, domain = alias.split('@', 1) if '@' in alias else (None, alias)
|
||||
alternative = models.Alternative.query.get(domain)
|
||||
if alternative:
|
||||
domain = alternative.domain_name
|
||||
email = '{}@{}'.format(localpart, domain)
|
||||
localpart, domain_name = models.Email.resolve_domain(alias)
|
||||
if localpart is None:
|
||||
return flask.jsonify(domain)
|
||||
else:
|
||||
alias_obj = models.Alias.resolve(localpart, domain)
|
||||
if alias_obj:
|
||||
return flask.jsonify(",".join(alias_obj.destination))
|
||||
user_obj = models.User.query.get(email)
|
||||
if user_obj:
|
||||
return flask.jsonify(user_obj.destination)
|
||||
return flask.abort(404)
|
||||
return flask.jsonify(domain_name)
|
||||
destination = models.Email.resolve_destination(localpart, domain_name)
|
||||
return flask.jsonify(",".join(destination)) if destination else flask.abort(404)
|
||||
|
||||
|
||||
@internal.route("/postfix/transport/<email>")
|
||||
def postfix_transport(email):
|
||||
localpart, domain = email.split('@', 1) if '@' in email else (None, email)
|
||||
relay = models.Relay.query.get(domain) or flask.abort(404)
|
||||
if email == '*':
|
||||
return flask.abort(404)
|
||||
localpart, domain_name = models.Email.resolve_domain(email)
|
||||
relay = models.Relay.query.get(domain_name) or flask.abort(404)
|
||||
return flask.jsonify("smtp:[{}]".format(relay.smtp))
|
||||
|
||||
|
||||
@internal.route("/postfix/sender/<sender>")
|
||||
def postfix_sender(sender):
|
||||
@internal.route("/postfix/sender/login/<sender>")
|
||||
def postfix_sender_login(sender):
|
||||
localpart, domain_name = models.Email.resolve_domain(sender)
|
||||
if localpart is None:
|
||||
return flask.abort(404)
|
||||
destination = models.Email.resolve_destination(localpart, domain_name, True)
|
||||
return flask.jsonify(",".join(destination)) if destination else flask.abort(404)
|
||||
|
||||
|
||||
@internal.route("/postfix/sender/access/<sender>")
|
||||
def postfix_sender_access(sender):
|
||||
""" Simply reject any sender that pretends to be from a local domain
|
||||
"""
|
||||
localpart, domain_name = sender.split('@', 1) if '@' in sender else (None, sender)
|
||||
domain = models.Domain.query.get(domain_name)
|
||||
alternative = models.Alternative.query.get(domain_name)
|
||||
if domain or alternative:
|
||||
return flask.jsonify("REJECT")
|
||||
return flask.abort(404)
|
||||
localpart, domain_name = models.Email.resolve_domain(sender)
|
||||
return flask.jsonify("REJECT") if models.Domain.query.get(domain_name) else flask.abort(404)
|
||||
|
||||
@@ -72,7 +72,7 @@ class CommaSeparatedList(db.TypeDecorator):
|
||||
return ",".join(value)
|
||||
|
||||
def process_result_value(self, value, dialect):
|
||||
return filter(bool, value.split(","))
|
||||
return filter(bool, value.split(",")) if value else []
|
||||
|
||||
|
||||
class JSONEncoded(db.TypeDecorator):
|
||||
@@ -250,6 +250,28 @@ class Email(object):
|
||||
msg['To'] = to_address
|
||||
smtp.sendmail(from_address, [to_address], msg.as_string())
|
||||
|
||||
@classmethod
|
||||
def resolve_domain(cls, email):
|
||||
localpart, domain_name = email.split('@', 1) if '@' in email else (None, email)
|
||||
alternative = Alternative.query.get(domain_name)
|
||||
if alternative:
|
||||
domain_name = alternative.domain_name
|
||||
return (localpart, domain_name)
|
||||
|
||||
@classmethod
|
||||
def resolve_destination(cls, localpart, domain_name, ignore_forward_keep=False):
|
||||
alias = Alias.resolve(localpart, domain_name)
|
||||
if alias:
|
||||
return alias.destination
|
||||
user = User.query.get('{}@{}'.format(localpart, domain_name))
|
||||
if user:
|
||||
if user.forward_enabled:
|
||||
destination = user.forward_destination
|
||||
if user.forward_keep or ignore_forward_keep:
|
||||
destination.append(user.email)
|
||||
else:
|
||||
destination = [user.email]
|
||||
return destination
|
||||
|
||||
def __str__(self):
|
||||
return self.email
|
||||
@@ -274,7 +296,7 @@ class User(Base, Email):
|
||||
|
||||
# Filters
|
||||
forward_enabled = db.Column(db.Boolean(), nullable=False, default=False)
|
||||
forward_destination = db.Column(db.String(255), nullable=True, default=None)
|
||||
forward_destination = db.Column(CommaSeparatedList(), nullable=True, default=[])
|
||||
forward_keep = db.Column(db.Boolean(), nullable=False, default=True)
|
||||
reply_enabled = db.Column(db.Boolean(), nullable=False, default=False)
|
||||
reply_subject = db.Column(db.String(255), nullable=True, default=None)
|
||||
|
||||
@@ -90,9 +90,10 @@ class UserSignupForm(flask_wtf.FlaskForm):
|
||||
localpart = fields.StringField(_('Email address'), [validators.DataRequired(), validators.Regexp(LOCALPART_REGEX)])
|
||||
pw = fields.PasswordField(_('Password'), [validators.DataRequired()])
|
||||
pw2 = fields.PasswordField(_('Confirm password'), [validators.EqualTo('pw')])
|
||||
captcha = flask_wtf.RecaptchaField()
|
||||
submit = fields.SubmitField(_('Sign up'))
|
||||
|
||||
class UserSignupFormCaptcha(UserSignupForm):
|
||||
captcha = flask_wtf.RecaptchaField()
|
||||
|
||||
class UserSettingsForm(flask_wtf.FlaskForm):
|
||||
displayed_name = fields.StringField(_('Displayed name'))
|
||||
|
||||
@@ -14,7 +14,9 @@
|
||||
{% call macros.box() %}
|
||||
{{ macros.form_field(form.localpart, append='<span class="input-group-addon">@'+domain.name+'</span>') }}
|
||||
{{ macros.form_fields((form.pw, form.pw2)) }}
|
||||
{{ macros.form_field(form.captcha) }}
|
||||
{% if form.captcha %}
|
||||
{{ macros.form_field(form.captcha) }}
|
||||
{% endif %}
|
||||
{{ macros.form_field(form.submit) }}
|
||||
{% endcall %}
|
||||
</form>
|
||||
|
||||
@@ -171,7 +171,11 @@ def user_signup(domain_name=None):
|
||||
available_domains=available_domains)
|
||||
domain = available_domains.get(domain_name) or flask.abort(404)
|
||||
quota_bytes = domain.max_quota_bytes or app.config['DEFAULT_QUOTA']
|
||||
form = forms.UserSignupForm()
|
||||
if app.config['RECAPTCHA_PUBLIC_KEY'] == "" or app.config['RECAPTCHA_PRIVATE_KEY'] == "":
|
||||
form = forms.UserSignupForm()
|
||||
else:
|
||||
form = forms.UserSignupFormCaptcha()
|
||||
|
||||
if form.validate_on_submit():
|
||||
if domain.has_email(form.localpart.data):
|
||||
flask.flash('Email is already used', 'error')
|
||||
|
||||
Reference in New Issue
Block a user