app/blueprints/users/profile.py

   1 # Content DB
   2 # Copyright (C) 2018  rubenwardy
   3 #
   4 # This program is free software: you can redistribute it and/or modify
   5 # it under the terms of the GNU General Public License as published by
   6 # the Free Software Foundation, either version 3 of the License, or
   7 # (at your option) any later version.
   8 #
   9 # This program is distributed in the hope that it will be useful,
  10 # but WITHOUT ANY WARRANTY; without even the implied warranty of
  11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12 # GNU General Public License for more details.
  13 #
  14 # You should have received a copy of the GNU General Public License
  15 # along with this program.  If not, see <https://www.gnu.org/licenses/>.
  16
  17
  18 from flask import *
  19 from flask_user import signals, current_user, user_manager
  20 from flask_login import login_user, logout_user
  21 from app.markdown import render_markdown
  22 from . import bp
  23 from app.models import *
  24 from flask_wtf import FlaskForm
  25 from wtforms import *
  26 from wtforms.validators import *
  27 from app.utils import randomString, loginUser, rank_required, nonEmptyOrNone, addAuditLog
  28 from app.tasks.forumtasks import checkForumAccount
  29 from app.tasks.emails import sendVerifyEmail, sendEmailRaw
  30 from app.tasks.phpbbparser import getProfile
  31
  32 # Define the User profile form
  33 class UserProfileForm(FlaskForm):
  34         display_name = StringField("Display name", [Optional(), Length(2, 100)])
  35         forums_username = StringField("Forums Username", [Optional(), Length(2, 50)])
  36         github_username = StringField("GitHub Username", [Optional(), Length(2, 50)])
  37         email = StringField("Email", [Optional(), Email()], filters = [lambda x: x or None])
  38         website_url = StringField("Website URL", [Optional(), URL()], filters = [lambda x: x or None])
  39         donate_url = StringField("Donation URL", [Optional(), URL()], filters = [lambda x: x or None])
  40         rank = SelectField("Rank", [Optional()], choices=UserRank.choices(), coerce=UserRank.coerce, default=UserRank.NEW_MEMBER)
  41         submit = SubmitField("Save")
  42
  43
  44 @bp.route("/users/", methods=["GET"])
  45 def list_all():
  46         users = User.query.order_by(db.desc(User.rank), db.asc(User.display_name)).all()
  47         return render_template("users/list.html", users=users)
  48
  49
  50 @bp.route("/users/<username>/", methods=["GET", "POST"])
  51 def profile(username):
  52         user = User.query.filter_by(username=username).first()
  53         if not user:
  54                 abort(404)
  55
  56         form = None
  57         if user.checkPerm(current_user, Permission.CHANGE_USERNAMES) or \
  58                         user.checkPerm(current_user, Permission.CHANGE_EMAIL) or \
  59                         user.checkPerm(current_user, Permission.CHANGE_RANK):
  60                 # Initialize form
  61                 form = UserProfileForm(formdata=request.form, obj=user)
  62
  63                 # Process valid POST
  64                 if request.method=="POST" and form.validate():
  65                         severity = AuditSeverity.NORMAL if current_user == user else AuditSeverity.MODERATION
  66                         addAuditLog(severity, current_user, "Edited {}'s profile".format(user.display_name),
  67                                         url_for("users.profile", username=username))
  68
  69                         # Copy form fields to user_profile fields
  70                         if user.checkPerm(current_user, Permission.CHANGE_USERNAMES):
  71                                 user.display_name = form.display_name.data
  72                                 user.forums_username = nonEmptyOrNone(form.forums_username.data)
  73                                 user.github_username = nonEmptyOrNone(form.github_username.data)
  74
  75                         if user.checkPerm(current_user, Permission.CHANGE_PROFILE_URLS):
  76                                 user.website_url  = form["website_url"].data
  77                                 user.donate_url   = form["donate_url"].data
  78
  79                         if user.checkPerm(current_user, Permission.CHANGE_RANK):
  80                                 newRank = form["rank"].data
  81                                 if current_user.rank.atLeast(newRank):
  82                                         if newRank != user.rank:
  83                                                 user.rank = form["rank"].data
  84                                                 msg = "Set rank of {} to {}".format(user.display_name, user.rank.getTitle())
  85                                                 addAuditLog(AuditSeverity.MODERATION, current_user, msg, url_for("users.profile", username=username))
  86                                 else:
  87                                         flash("Can't promote a user to a rank higher than yourself!", "danger")
  88
  89                         if user.checkPerm(current_user, Permission.CHANGE_EMAIL):
  90                                 newEmail = form["email"].data
  91                                 if newEmail != user.email and newEmail.strip() != "":
  92                                         token = randomString(32)
  93
  94                                         msg = "Changed email of {}".format(user.display_name)
  95                                         addAuditLog(severity, current_user, msg, url_for("users.profile", username=username))
  96
  97                                         ver = UserEmailVerification()
  98                                         ver.user  = user
  99                                         ver.token = token
 100                                         ver.email = newEmail
 101                                         db.session.add(ver)
 102                                         db.session.commit()
 103
 104                                         task = sendVerifyEmail.delay(newEmail, token)
 105                                         return redirect(url_for("tasks.check", id=task.id, r=url_for("users.profile", username=username)))
 106
 107                         # Save user_profile
 108                         db.session.commit()
 109
 110                         # Redirect to home page
 111                         return redirect(url_for("users.profile", username=username))
 112
 113         packages = user.packages.filter_by(soft_deleted=False)
 114         if not current_user.is_authenticated or (user != current_user and not current_user.canAccessTodoList()):
 115                 packages = packages.filter_by(approved=True)
 116         packages = packages.order_by(db.asc(Package.title))
 117
 118         topics_to_add = None
 119         if current_user == user or user.checkPerm(current_user, Permission.CHANGE_AUTHOR):
 120                 topics_to_add = ForumTopic.query \
 121                                         .filter_by(author_id=user.id) \
 122                                         .filter(~ db.exists().where(Package.forums==ForumTopic.topic_id)) \
 123                                         .order_by(db.asc(ForumTopic.name), db.asc(ForumTopic.title)) \
 124                                         .all()
 125
 126         # Process GET or invalid POST
 127         return render_template("users/profile.html",
 128                         user=user, form=form, packages=packages, topics_to_add=topics_to_add)
 129
 130
 131 @bp.route("/users/<username>/check/", methods=["POST"])
 132 @login_required
 133 def user_check(username):
 134         user = User.query.filter_by(username=username).first()
 135         if user is None:
 136                 abort(404)
 137
 138         if current_user != user and not current_user.rank.atLeast(UserRank.MODERATOR):
 139                 abort(403)
 140
 141         if user.forums_username is None:
 142                 abort(404)
 143
 144         task = checkForumAccount.delay(user.forums_username)
 145         next_url = url_for("users.profile", username=username)
 146
 147         return redirect(url_for("tasks.check", id=task.id, r=next_url))
 148
 149
 150 class SendEmailForm(FlaskForm):
 151         subject = StringField("Subject", [InputRequired(), Length(1, 300)])
 152         text    = TextAreaField("Message", [InputRequired()])
 153         submit  = SubmitField("Send")
 154
 155
 156 @bp.route("/users/<username>/email/", methods=["GET", "POST"])
 157 @rank_required(UserRank.MODERATOR)
 158 def send_email(username):
 159         user = User.query.filter_by(username=username).first()
 160         if user is None:
 161                 abort(404)
 162
 163         next_url = url_for("users.profile", username=user.username)
 164
 165         if user.email is None:
 166                 flash("User has no email address!", "danger")
 167                 return redirect(next_url)
 168
 169         form = SendEmailForm(request.form)
 170         if form.validate_on_submit():
 171                 addAuditLog(AuditSeverity.MODERATION, current_user,
 172                                 "Sent email to {}".format(user.display_name), url_for("users.profile", username=username))
 173
 174                 text = form.text.data
 175                 html = render_markdown(text)
 176                 task = sendEmailRaw.delay([user.email], form.subject.data, text, html)
 177                 return redirect(url_for("tasks.check", id=task.id, r=next_url))
 178
 179         return render_template("users/send_email.html", form=form)
 180
 181
 182
 183 class SetPasswordForm(FlaskForm):
 184         email = StringField("Email", [Optional(), Email()])
 185         password = PasswordField("New password", [InputRequired(), Length(2, 100)])
 186         password2 = PasswordField("Verify password", [InputRequired(), Length(2, 100)])
 187         submit = SubmitField("Save")
 188
 189 @bp.route("/user/set-password/", methods=["GET", "POST"])
 190 @login_required
 191 def set_password():
 192         if current_user.hasPassword():
 193                 return redirect(url_for("user.change_password"))
 194
 195         form = SetPasswordForm(request.form)
 196         if current_user.email == None:
 197                 form.email.validators = [InputRequired(), Email()]
 198
 199         if request.method == "POST" and form.validate():
 200                 one = form.password.data
 201                 two = form.password2.data
 202                 if one == two:
 203                         # Hash password
 204                         hashed_password = user_manager.hash_password(form.password.data)
 205
 206                         # Change password
 207                         current_user.password = hashed_password
 208                         db.session.commit()
 209
 210                         # Send 'password_changed' email
 211                         if user_manager.USER_ENABLE_EMAIL and current_user.email:
 212                                 user_manager.email_manager.send_password_changed_email(current_user)
 213
 214                         # Send password_changed signal
 215                         signals.user_changed_password.send(current_app._get_current_object(), user=current_user)
 216
 217                         # Prepare one-time system message
 218                         flash('Your password has been changed successfully.', 'success')
 219
 220                         newEmail = form["email"].data
 221                         if newEmail != current_user.email and newEmail.strip() != "":
 222                                 token = randomString(32)
 223
 224                                 ver = UserEmailVerification()
 225                                 ver.user = current_user
 226                                 ver.token = token
 227                                 ver.email = newEmail
 228                                 db.session.add(ver)
 229                                 db.session.commit()
 230
 231                                 task = sendVerifyEmail.delay(newEmail, token)
 232                                 return redirect(url_for("tasks.check", id=task.id, r=url_for("users.profile", username=current_user.username)))
 233                         else:
 234                                 return redirect(url_for("user.login"))
 235                 else:
 236                         flash("Passwords do not match", "danger")
 237
 238         return render_template("users/set_password.html", form=form, optional=request.args.get("optional"))
 239
 240
 241 @bp.route("/users/verify/")
 242 def verify_email():
 243         token = request.args.get("token")
 244         ver = UserEmailVerification.query.filter_by(token=token).first()
 245         if ver is None:
 246                 flash("Unknown verification token!", "danger")
 247         else:
 248                 ver.user.email = ver.email
 249                 db.session.delete(ver)
 250                 db.session.commit()
 251
 252         if current_user.is_authenticated:
 253                 return redirect(url_for("users.profile", username=current_user.username))
 254         else:
 255                 return redirect(url_for("homepage.home"))