2 # Copyright (C) 2018 rubenwardy
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.
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.
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/>.
19 from flask_user import *
20 import flask_menu as menu
22 from app.models import *
23 from celery import uuid, group
24 from app.tasks.importtasks import importRepoScreenshot, makeVCSRelease, checkZipRelease, updateMetaFromRelease, importForeignDownloads
25 from app.tasks.forumtasks import importTopicList, checkAllForumAccounts
26 from flask_wtf import FlaskForm
28 from app.utils import loginUser, rank_required, addNotification
31 @bp.route("/admin/", methods=["GET", "POST"])
32 @rank_required(UserRank.ADMIN)
34 if request.method == "POST":
35 action = request.form["action"]
37 if action == "delstuckreleases":
38 PackageRelease.query.filter(PackageRelease.task_id != None).delete()
40 return redirect(url_for("admin.admin_page"))
42 elif action == "checkreleases":
43 releases = PackageRelease.query.filter(PackageRelease.url.like("/uploads/%")).all()
46 for release in releases:
47 zippath = release.url.replace("/uploads/", app.config["UPLOAD_DIR"])
48 tasks.append(checkZipRelease.s(release.id, zippath))
50 result = group(tasks).apply_async()
52 while not result.ready():
56 return redirect(url_for("todo.view"))
58 elif action == "reimportpackages":
60 for package in Package.query.filter_by(soft_deleted=False).all():
61 release = package.releases.first()
63 zippath = release.url.replace("/uploads/", app.config["UPLOAD_DIR"])
64 tasks.append(updateMetaFromRelease.s(release.id, zippath))
66 result = group(tasks).apply_async()
68 while not result.ready():
72 return redirect(url_for("todo.view"))
74 elif action == "importforeign":
75 releases = PackageRelease.query.filter(PackageRelease.url.like("http%")).all()
78 for release in releases:
79 tasks.append(importForeignDownloads.s(release.id))
81 result = group(tasks).apply_async()
83 while not result.ready():
87 return redirect(url_for("todo.view"))
89 elif action == "importmodlist":
90 task = importTopicList.delay()
91 return redirect(url_for("tasks.check", id=task.id, r=url_for("todo.topics")))
93 elif action == "checkusers":
94 task = checkAllForumAccounts.delay()
95 return redirect(url_for("tasks.check", id=task.id, r=url_for("admin.admin_page")))
97 elif action == "importscreenshots":
98 packages = Package.query \
99 .filter_by(soft_deleted=False) \
100 .outerjoin(PackageScreenshot, Package.id==PackageScreenshot.package_id) \
101 .filter(PackageScreenshot.id==None) \
103 for package in packages:
104 importRepoScreenshot.delay(package.id)
106 return redirect(url_for("admin.admin_page"))
108 elif action == "restore":
109 package = Package.query.get(request.form["package"])
111 flash("Unknown package", "danger")
113 package.soft_deleted = False
115 return redirect(url_for("admin.admin_page"))
117 elif action == "recalcscores":
118 for p in Package.query.all():
122 return redirect(url_for("admin.admin_page"))
124 elif action == "cleanuploads":
125 upload_dir = app.config['UPLOAD_DIR']
127 (_, _, filenames) = next(os.walk(upload_dir))
128 existing_uploads = set(filenames)
130 if len(existing_uploads) != 0:
131 def getURLsFromDB(column):
132 results = db.session.query(column).filter(column != None, column != "").all()
133 return set([os.path.basename(x[0]) for x in results])
135 release_urls = getURLsFromDB(PackageRelease.url)
136 screenshot_urls = getURLsFromDB(PackageScreenshot.url)
138 db_urls = release_urls.union(screenshot_urls)
139 unreachable = existing_uploads.difference(db_urls)
142 print("On Disk: ", existing_uploads, file=sys.stderr)
143 print("In DB: ", db_urls, file=sys.stderr)
144 print("Unreachable: ", unreachable, file=sys.stderr)
146 for filename in unreachable:
147 os.remove(os.path.join(upload_dir, filename))
149 flash("Deleted " + str(len(unreachable)) + " unreachable uploads", "success")
151 flash("No downloads to create", "danger")
153 return redirect(url_for("admin.admin_page"))
155 elif action == "delmetapackages":
156 query = MetaPackage.query.filter(~MetaPackage.dependencies.any(), ~MetaPackage.packages.any())
157 count = query.count()
158 query.delete(synchronize_session=False)
161 flash("Deleted " + str(count) + " unused meta packages", "success")
162 return redirect(url_for("admin.admin_page"))
164 flash("Unknown action: " + action, "danger")
166 deleted_packages = Package.query.filter_by(soft_deleted=True).all()
167 return render_template("admin/list.html", deleted_packages=deleted_packages)
169 class SwitchUserForm(FlaskForm):
170 username = StringField("Username")
171 submit = SubmitField("Switch")
174 @bp.route("/admin/switchuser/", methods=["GET", "POST"])
175 @rank_required(UserRank.ADMIN)
177 form = SwitchUserForm(formdata=request.form)
178 if request.method == "POST" and form.validate():
179 user = User.query.filter_by(username=form["username"].data).first()
181 flash("Unable to find user", "danger")
182 elif loginUser(user):
183 return redirect(url_for("users.profile", username=current_user.username))
185 flash("Unable to login as user", "danger")
188 # Process GET or invalid POST
189 return render_template("admin/switch_user.html", form=form)