import os from shutil import copyfile from sqlalchemy import func from files.helpers.media import process_files import files.helpers.stats as statshelper from files.classes.award import AWARDS from files.classes.badges import Badge, BadgeDef from files.classes.mod_logs import ModAction from files.classes.userblock import UserBlock from files.helpers.actions import * from files.helpers.alerts import * from files.helpers.config.const import * from files.helpers.config.modaction_types import * from files.routes.wrappers import * from files.__main__ import app, cache, limiter @app.get("/r/drama/comments//") @app.get("/r/Drama/comments/<int:id>/<title>") def rdrama(id, title): id = ''.join(f'{x}/' for x in id) return redirect(f'/archives/drama/comments/{id}{title}.html') @app.get("/r/<subreddit>") @auth_desired def subreddit(subreddit, v): reddit = v.reddit if v else "old.reddit.com" return redirect(f'https://{reddit}/r/{subreddit}') @app.get("/reddit/<subreddit>/comments/<path:path>") @app.get("/r/<subreddit>/comments/<path:path>") @auth_desired def reddit_post(subreddit, v, path): post_id = path.rsplit("/", 1)[0].replace('/', '') reddit = v.reddit if v else "old.reddit.com" return redirect(f'https://{reddit}/{post_id}') @app.get("/marseys") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def marseys(v:User): marseys = get_marseys(g.db) authors = get_accounts_dict([m.author_id for m in marseys], v=v, graceful=True, include_shadowbanned=False) original = os.listdir("/asset_submissions/marseys/original") for marsey in marseys: marsey.user = authors.get(marsey.author_id) for x in IMAGE_FORMATS: if f'{marsey.name}.{x}' in original: marsey.og = f'{marsey.name}.{x}' break return render_template("marseys.html", v=v, marseys=marseys) @app.get("/emojis") def emoji_list(): return get_emojis(g.db) @cache.cached(timeout=86400, key_prefix=MARSEYS_CACHE_KEY) def get_marseys(db:scoped_session): if not FEATURES['MARSEYS']: return [] marseys = [] for marsey, author in db.query(Marsey, User).join(User, Marsey.author_id == User.id).filter(Marsey.submitter_id == None).order_by(Marsey.count.desc()): marsey.author = author.username if FEATURES['ASSET_SUBMISSIONS'] else None setattr(marsey, "class", "Marsey") marseys.append(marsey) return marseys @cache.cached(timeout=600, key_prefix=EMOJIS_CACHE_KEY) def get_emojis(db:scoped_session): emojis = [m.json() for m in get_marseys(db)] for src in EMOJI_SRCS: with open(src, "r", encoding="utf-8") as f: emojis = emojis + json.load(f) return emojis @app.get('/sidebar') @auth_desired def sidebar(v:Optional[User]): return render_template('sidebar.html', v=v) @app.get("/stats") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def participation_stats(v:User): stats = cache.get(f'{SITE}_stats') or {} if v.client: return stats return render_template("stats.html", v=v, title="Content Statistics", data=stats) @app.get("/chart") def chart(): return redirect('/weekly_chart') @app.get("/weekly_chart") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def weekly_chart(v:User): return send_file(statshelper.chart_path(kind="weekly", site=SITE)) @app.get("/daily_chart") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def daily_chart(v:User): return send_file(statshelper.chart_path(kind="daily", site=SITE)) @app.get("/patrons") @app.get("/paypigs") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @admin_level_required(PERMS['VIEW_PATRONS']) def patrons(v): users = g.db.query(User).filter(User.patron > 0).order_by(User.patron.desc(), User.id).all() return render_template("admin/patrons.html", v=v, users=users, benefactor_def=AWARDS['benefactor']) @app.get("/admins") @app.get("/badmins") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def admins(v:User): admins = g.db.query(User).filter(User.admin_level >= PERMS['ADMIN_MOP_VISIBLE']).order_by(User.truescore.desc()).all() return render_template("admins.html", v=v, admins=admins) @app.get("/log") @app.get("/modlog") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def log(v:User): try: page = max(int(request.values.get("page", 1)), 1) except: page = 1 admin = request.values.get("admin") if admin: admin_id = get_id(admin) else: admin_id = 0 kind = request.values.get("kind") if v and v.admin_level >= PERMS['USER_SHADOWBAN']: if v and v.admin_level >= PERMS['PROGSTACK']: types = MODACTION_TYPES else: types = MODACTION_TYPES__FILTERED else: types = MODACTION_TYPES_FILTERED if kind and kind not in types: kind = None actions = [] else: actions = g.db.query(ModAction) if not (v and v.admin_level >= PERMS['USER_SHADOWBAN']): actions = actions.filter(ModAction.kind.notin_(MODACTION_PRIVILEGED_TYPES)) if not (v and v.admin_level >= PERMS['PROGSTACK']): actions = actions.filter(ModAction.kind.notin_(MODACTION_PRIVILEGED__TYPES)) if admin_id: actions = actions.filter_by(user_id=admin_id) kinds = set([x.kind for x in actions]) kinds.add(kind) types2 = {} for k,val in types.items(): if k in kinds: types2[k] = val types = types2 if kind: actions = actions.filter_by(kind=kind) actions = actions.order_by(ModAction.id.desc()).offset(PAGE_SIZE*(page-1)).limit(PAGE_SIZE+1).all() next_exists=len(actions) > PAGE_SIZE actions=actions[:PAGE_SIZE] admins = [x[0] for x in g.db.query(User.username).filter(User.admin_level >= PERMS['ADMIN_MOP_VISIBLE']).order_by(User.username).all()] return render_template("log.html", v=v, admins=admins, types=types, admin=admin, type=kind, actions=actions, next_exists=next_exists, page=page, single_user_url='admin') @app.get("/log/<int:id>") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def log_item(id, v): try: id = int(id) except: abort(404) action=g.db.get(ModAction, id) if not action: abort(404) admins = [x[0] for x in g.db.query(User.username).filter(User.admin_level >= PERMS['ADMIN_MOP_VISIBLE']).all()] if v and v.admin_level >= PERMS['USER_SHADOWBAN']: if v and v.admin_level >= PERMS['PROGSTACK']: types = MODACTION_TYPES else: types = MODACTION_TYPES__FILTERED else: types = MODACTION_TYPES_FILTERED return render_template("log.html", v=v, actions=[action], next_exists=False, page=1, action=action, admins=admins, types=types, single_user_url='admin') @app.get("/directory") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def static_megathread_index(v:User): return render_template("megathread_index.html", v=v) @app.get("/api") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def api(v): return render_template("api.html", v=v) @app.get("/contact") @app.get("/contactus") @app.get("/contact_us") @app.get("/press") @app.get("/media") @app.get("/admin/chat") @auth_desired def contact(v:Optional[User]): return render_template("contact.html", v=v, msg=get_msg()) @app.post("/contact") @limiter.limit("1/second;1/2 minutes;10/day") @limiter.limit("1/second;1/2 minutes;10/day", key_func=get_ID) @auth_required def submit_contact(v): body = request.values.get("message") if not body: abort(400) if v.is_muted: abort(403) body = f'This message has been sent automatically to all admins via [/contact](/contact)\n\nMessage:\n\n{body}' body += process_files(request.files, v) body = body.strip() body_html = sanitize(body) execute_antispam_duplicate_comment_check(v, body_html) new_comment = Comment(author_id=v.id, parent_submission=None, level=1, body_html=body_html, sentto=MODMAIL_ID ) g.db.add(new_comment) g.db.flush() execute_blackjack(v, new_comment, new_comment.body_html, 'modmail') execute_under_siege(v, new_comment, new_comment.body_html, 'modmail') new_comment.top_comment_id = new_comment.id admins = g.db.query(User).filter(User.admin_level >= PERMS['NOTIFICATIONS_MODMAIL'], User.id != AEVANN_ID) for admin in admins.all(): notif = Notification(comment_id=new_comment.id, user_id=admin.id) g.db.add(notif) return redirect("/contact?msg=Your message has been sent to the admins!") @app.get('/archives') def archivesindex(): return redirect("/archives/index.html") no = (21,22,23,24,25,26,27) @cache.memoize(timeout=3600) def badge_list(site): badges = g.db.query(BadgeDef).filter(BadgeDef.id.notin_(no)).order_by(BadgeDef.id).all() counts_raw = g.db.query(Badge.badge_id, func.count()).group_by(Badge.badge_id).all() users = g.db.query(User).count() counts = {} for c in counts_raw: counts[c[0]] = (c[1], float(c[1]) * 100 / max(users, 1)) return badges, counts @app.get("/badges") @feature_required('BADGES') @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def badges(v:User): badges, counts = badge_list(SITE) return render_template("badges.html", v=v, badges=badges, counts=counts) @app.get("/blocks") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @admin_level_required(PERMS['USER_BLOCKS_VISIBLE']) def blocks(v): blocks=g.db.query(UserBlock).all() users = [] targets = [] for x in blocks: acc_user = get_account(x.user_id) acc_tgt = get_account(x.target_id) if acc_user.shadowbanned or acc_tgt.shadowbanned: continue users.append(acc_user) targets.append(acc_tgt) return render_template("blocks.html", v=v, users=users, targets=targets) @app.get("/formatting") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def formatting(v:User): return render_template("formatting.html", v=v) @app.get("/app") @auth_desired def mobile_app(v:Optional[User]): return render_template("app.html", v=v) @app.post("/dismiss_mobile_tip") def dismiss_mobile_tip(): session["tooltip_last_dismissed"] = int(time.time()) return "", 204 @app.get("/transfers/<int:id>") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def transfers_id(id, v): try: id = int(id) except: abort(404) transfer = g.db.get(Comment, id) if not transfer: abort(404) return render_template("transfers.html", v=v, page=1, comments=[transfer], standalone=True, next_exists=False) @app.get("/transfers") @limiter.limit(DEFAULT_RATELIMIT, key_func=get_ID) @auth_required def transfers(v:User): comments = g.db.query(Comment).filter(Comment.author_id == AUTOJANNY_ID, Comment.parent_submission == None, Comment.body_html.like("%</a> has transferred %")).order_by(Comment.id.desc()) try: page = max(int(request.values.get("page", 1)), 1) except: page = 1 comments = comments.offset(PAGE_SIZE * (page - 1)).limit(PAGE_SIZE + 1).all() next_exists = len(comments) > PAGE_SIZE comments = comments[:PAGE_SIZE] if v.client: return {"data": [x.json(g.db) for x in comments]} else: return render_template("transfers.html", v=v, page=page, comments=comments, standalone=True, next_exists=next_exists) if not os.path.exists(f'files/templates/donate_{SITE_NAME}.html'): copyfile('files/templates/donate_rDrama.html', f'files/templates/donate_{SITE_NAME}.html') @app.get('/donate') @auth_desired_with_logingate def donate(v): return render_template(f'donate_{SITE_NAME}.html', v=v)