import time import mistletoe import gevent import requests from files.helpers.wrappers import * from files.helpers.sanitize import * from files.helpers.filters import * from files.helpers.markdown import * from files.helpers.session import * from files.helpers.alerts import send_notification from files.helpers.discord import send_message from files.helpers.const import * from files.classes import * from flask import * from io import BytesIO from files.__main__ import app, limiter, cache, db_session from PIL import Image as PILimage from .front import frontlist, changeloglist from urllib.parse import ParseResult, urlunparse, urlparse, quote site = environ.get("DOMAIN").strip() CATBOX_KEY = environ.get("CATBOX_KEY").strip() with open("snappy.txt", "r") as f: snappyquotes = f.read().split("{[para]}") @app.post("/toggle_club/") @auth_required def toggle_club(pid, v): post = get_post(pid) if post.author_id != v.id or not v.paid_dues: abort(403) post.club = not post.club g.db.add(post) if post.author_id!=v.id: ma=ModAction( kind="club" if post.club else "unclub", user_id=v.id, target_submission_id=post.id, ) g.db.add(ma) g.db.commit() if post.club: return {"message": "Post has been marked as club-only!"} else: return {"message": "Post has been unmarked as club-only!"} @app.post("/publish/") @limiter.limit("1/second") @auth_required @validate_formkey def publish(pid, v): post = get_post(pid) if not post.author_id == v.id: abort(403) post.private = False g.db.add(post) cache.delete_memoized(frontlist) for follow in v.followers: user = get_account(follow.user_id) send_notification(AUTOJANNY_ACCOUNT, user, f"@{v.username} has made a new post: [{post.title}](http://{site}{post.permalink})") g.db.commit() return {"message": "Post published!"} @app.get("/submit") @auth_required def submit_get(v): return render_template("submit.html", v=v) @app.get("/post/") @app.get("/post//") @app.get("/logged_out/post/") @app.get("/logged_out/post//") @auth_desired def post_id(pid, anything=None, v=None): if not v and not request.path.startswith('/logged_out') and not request.headers.get("Authorization"): return redirect(f"/logged_out{request.full_path}") if v and request.path.startswith('/logged_out'): v = None try: pid = int(pid) except Exception as e: pass if v: defaultsortingcomments = v.defaultsortingcomments else: defaultsortingcomments = "top" sort=request.values.get("sort", defaultsortingcomments) try: pid = int(pid) except: try: pid = int(pid, 36) except: abort(404) post = get_post(pid, v=v) if post.club and not (v and v.paid_dues): abort(403) if v: votes = g.db.query(CommentVote).options(lazyload('*')).filter_by(user_id=v.id).subquery() blocking = v.blocking.subquery() blocked = v.blocked.subquery() comments = g.db.query( Comment, votes.c.vote_type, blocking.c.id, blocked.c.id, ) if not (v and v.shadowbanned) and not (v and v.admin_level == 6): shadowbanned = [x[0] for x in g.db.query(User.id).options(lazyload('*')).filter(User.shadowbanned != None).all()] comments = comments.filter(Comment.author_id.notin_(shadowbanned)) comments=comments.filter( Comment.parent_submission == post.id, Comment.author_id != AUTOPOLLER_ACCOUNT, ).join( votes, votes.c.comment_id == Comment.id, isouter=True ).join( blocking, blocking.c.target_id == Comment.author_id, isouter=True ).join( blocked, blocked.c.user_id == Comment.author_id, isouter=True ) if sort == "new": comments = comments.order_by(Comment.created_utc.desc()) elif sort == "old": comments = comments.order_by(Comment.created_utc.asc()) elif sort == "controversial": comments = comments.order_by(-1 * Comment.upvotes * Comment.downvotes * Comment.downvotes) elif sort == "top": comments = comments.order_by(-Comment.upvotes - Comment.downvotes) elif sort == "bottom": comments = comments.order_by(Comment.upvotes - Comment.downvotes) output = [] for c in comments.all(): comment = c[0] comment.voted = c[1] or 0 comment.is_blocking = c[2] or 0 comment.is_blocked = c[3] or 0 output.append(comment) post.replies = [x for x in output if x.is_pinned] + [x for x in output if x.level == 1 and not x.is_pinned] else: shadowbanned = [x[0] for x in g.db.query(User.id).options(lazyload('*')).filter(User.shadowbanned != None).all()] comments = g.db.query(Comment).filter(Comment.parent_submission == post.id, Comment.author_id != AUTOPOLLER_ACCOUNT, Comment.author_id.notin_(shadowbanned)) if sort == "new": comments = comments.order_by(Comment.created_utc.desc()) elif sort == "old": comments = comments.order_by(Comment.created_utc.asc()) elif sort == "controversial": comments = comments.order_by(-1 * Comment.upvotes * Comment.downvotes * Comment.downvotes) elif sort == "top": comments = comments.order_by(-Comment.upvotes - Comment.downvotes) elif sort == "bottom": comments = comments.order_by(Comment.upvotes - Comment.downvotes) post.replies = comments.filter(Comment.is_pinned != None).all() + comments.filter(Comment.level == 1, Comment.is_pinned == None).all() post.views += 1 g.db.add(post) if isinstance(session.get('over_18', 0), dict): session["over_18"] = 0 if post.over_18 and not (v and v.over_18) and not session.get('over_18', 0) >= int(time.time()): if request.headers.get("Authorization"): return {"error":"Must be 18+ to view"}, 451 else: return render_template("errors/nsfw.html", v=v) g.db.commit() if request.headers.get("Authorization"): return post.json else: if post.is_banned and not (v and (v.admin_level >= 3 or post.author_id == v.id)): template = "submission_banned.html" else: template = "submission.html" return render_template(template, v=v, p=post, sort=sort, render_replies=True) @app.post("/edit_post/") @limiter.limit("1/second") @auth_required @validate_formkey def edit_post(pid, v): p = get_post(pid) if not p.author_id == v.id: abort(403) title = request.values.get("title", "").strip() body = request.values.get("body", "").strip() if title != p.title: p.title = title p.title_html = filter_title(title) if body != p.body: for i in re.finditer('^(https:\/\/.*\.(png|jpg|jpeg|gif|webp|PNG|JPG|JPEG|GIF|WEBP|9999))', body, re.MULTILINE): if "wikipedia" not in i.group(1): body = body.replace(i.group(1), f'![]({i.group(1)})') body_md = CustomRenderer().render(mistletoe.Document(body)) body_html = sanitize(body_md) bans = filter_comment_html(body_html) if bans: ban = bans[0] reason = f"Remove the {ban.domain} link from your post and try again." if ban.reason: reason += f" {ban.reason}" return {"error": reason}, 403 p.body = body p.body_html = body_html if "rama" in request.host and "ivermectin" in body_html.lower(): p.is_banned = True p.ban_reason = "ToS Violation" g.db.add(p) body = VAXX_MSG.format(username=v.username) body_md = CustomRenderer().render(mistletoe.Document(body)) body_jannied_html = sanitize(body_md) c_jannied = Comment(author_id=AUTOJANNY_ACCOUNT, parent_submission=p.id, level=1, over_18=False, is_bot=True, app_id=None, is_pinned=True, distinguish_level=6, body_html=body_jannied_html, body=body ) g.db.add(c_jannied) g.db.flush() n = Notification(comment_id=c_jannied.id, user_id=v.id) g.db.add(n) if v.agendaposter and "trans lives matter" not in body_html.lower(): p.is_banned = True p.ban_reason = "ToS Violation" g.db.add(p) body = AGENDAPOSTER_MSG.format(username=v.username) body_md = CustomRenderer().render(mistletoe.Document(body)) body_jannied_html = sanitize(body_md) c_jannied = Comment(author_id=AUTOJANNY_ACCOUNT, parent_submission=p.id, level=1, over_18=False, is_bot=True, app_id=None, is_pinned=True, distinguish_level=6, body_html=body_jannied_html, body=body ) g.db.add(c_jannied) g.db.flush() n = Notification(comment_id=c_jannied.id, user_id=v.id) g.db.add(n) notify_users = set() soup = BeautifulSoup(body_html, features="html.parser") for mention in soup.find_all("a", href=re.compile("^/@(\w+)")): username = mention["href"].split("@")[1] user = g.db.query(User).options(lazyload('*')).filter_by(username=username).first() if user and not v.any_block_exists(user) and user.id != v.id: notify_users.add(user) message = f"@{v.username} has mentioned you: http://{site}{p.permalink}" for x in notify_users: existing = g.db.query(Comment).options(lazyload('*')).filter(Comment.author_id == NOTIFICATIONS_ACCOUNT, Comment.body == message, Comment.notifiedto == x.id).first() if not existing: send_notification(NOTIFICATIONS_ACCOUNT, x, message) if title != p.title or body != p.body: if int(time.time()) - p.created_utc > 60 * 3: p.edited_utc = int(time.time()) g.db.add(p) g.db.commit() return redirect(p.permalink) @app.get("/submit/title") @limiter.limit("6/minute") @auth_required def get_post_title(v): url = request.values.get("url", None) if not url: return abort(400) headers = {"User-Agent": f"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/89.0.4389.72 Safari/537.36"} try: x = requests.get(url, headers=headers, timeout=5) except BaseException: return {"error": "Could not reach page"}, 400 if not x.status_code == 200: return {"error": f"Page returned {x.status_code}"}, x.status_code try: soup = BeautifulSoup(x.content, 'html.parser') return {"url": url, "title": soup.find('title').string} except BaseException: return {"error": f"Could not find a title"}, 400 def archiveorg(url): try: requests.get(f'https://web.archive.org/save/{url}', headers={'User-Agent': 'Mozilla/4.0 (compatible; MSIE 5.5; Windows NT)'}, timeout=100) except Exception as e: print(e) def thumbnail_thread(pid): def expand_url(post_url, fragment_url): if fragment_url.startswith("https://"): return fragment_url elif fragment_url.startswith("http://"): return f"https://{fragment_url.split('http://')[1]}" elif fragment_url.startswith('//'): return f"https:{fragment_url}" elif fragment_url.startswith('/'): parsed_url = urlparse(post_url) return f"https://{parsed_url.netloc}{fragment_url}" else: return f"{post_url}{'/' if not post_url.endswith('/') else ''}{fragment_url}" db = db_session() post = db.query(Submission).filter_by(id=pid).first() if not post: time.sleep(5) post = db.query(Submission).filter_by(id=pid).first() fetch_url=post.url headers={"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/89.0.4389.72 Safari/537.36"} try: x=requests.get(fetch_url, headers=headers) except: db.close() return if x.status_code != 200: db.close() return if x.headers.get("Content-Type","").startswith("text/html"): soup=BeautifulSoup(x.content, 'html.parser') thumb_candidate_urls=[] meta_tags = [ "ruqqus:thumbnail", "twitter:image", "og:image", "thumbnail" ] for tag_name in meta_tags: tag = soup.find( 'meta', attrs={ "name": tag_name, "content": True } ) if not tag: tag = soup.find( 'meta', attrs={ 'property': tag_name, 'content': True } ) if tag: thumb_candidate_urls.append(expand_url(post.url, tag['content'])) for tag in soup.find_all("img", attrs={'src':True}): thumb_candidate_urls.append(expand_url(post.url, tag['src'])) for url in thumb_candidate_urls: try: image_req=requests.get(url, headers=headers) except: continue if image_req.status_code >= 400: continue if not image_req.headers.get("Content-Type","").startswith("image/"): continue if image_req.headers.get("Content-Type","").startswith("image/svg"): continue image = PILimage.open(BytesIO(image_req.content)) if image.width < 30 or image.height < 30: continue break else: db.close() return elif x.headers.get("Content-Type","").startswith("image/"): image_req=x image = PILimage.open(BytesIO(x.content)) else: db.close() return name = f'/images/{int(time.time())}{secrets.token_urlsafe(2)}.gif' with open(name, "wb") as file: for chunk in image_req.iter_content(1024): file.write(chunk) post.thumburl = "https://" + site + process_image(name, True) db.add(post) db.commit() db.close() return @app.post("/submit") @limiter.limit("1/second") @limiter.limit("6/minute") @is_not_banned @validate_formkey def submit_post(v): if request.content_length > 4 * 1024 * 1024: return "Max file size is 4 MB.", 413 title = request.values.get("title", "").strip() url = request.values.get("url", "").strip() if url: if "/i.imgur.com/" in url: url = url.replace(".png", ".webp").replace(".jpg", ".webp").replace(".jpeg", ".webp") elif "/media.giphy.com/" in url or "/c.tenor.com/" in url: url = url.replace(".gif", ".webp") elif "/i.ibb.com/" in url: url = url.replace(".png", ".webp").replace(".jpg", ".webp").replace(".jpeg", ".webp").replace(".gif", ".webp") for rd in ["https://reddit.com/", "https://new.reddit.com/", "https://www.reddit.com/", "https://redd.it/"]: url = url.replace(rd, "https://old.reddit.com/") url = url.replace("old.reddit.com/gallery", "new.reddit.com/gallery") url = url.replace("https://mobile.twitter.com", "https://twitter.com") if url.startswith("https://streamable.com/") and not url.startswith("https://streamable.com/e/"): url = url.replace("https://streamable.com/", "https://streamable.com/e/") parsed_url = urlparse(url) domain = parsed_url.netloc # qd = parse_qs(parsed_url.query) # filtered = dict((k, v) for k, v in qd.items() if not k.startswith('utm_')) # new_url = ParseResult(scheme="https", # netloc=parsed_url.netloc, # path=parsed_url.path, # params=parsed_url.params, # query=urlencode(filtered, doseq=True), # fragment=parsed_url.fragment) # url = urlunparse(new_url) repost = g.db.query(Submission).options(lazyload('*')).filter( Submission.url.ilike(url), Submission.deleted_utc == 0, Submission.is_banned == False ).first() if repost: return redirect(repost.permalink) domain_obj = get_domain(domain) if domain_obj: if request.headers.get("Authorization"): return {"error":domain_obj.reason}, 400 else: return render_template("submit.html", v=v, error=domain_obj.reason, title=title, url=url, body=request.values.get("body", "")), 400 elif "twitter.com" in domain: try: embed = requests.get("https://publish.twitter.com/oembed", params={"url":url, "omit_script":"t"}).json()["html"] except: embed = None elif "youtu" in domain: try: yt_id = re.match(re.compile("^.*(youtu.be\/|v\/|u\/\w\/|embed\/|watch\?v=|shorts\/|\&v=)([^#\&\?]*).*"), url).group(2) params = parse_qs(urlparse(url).query) t = params.get('t', params.get('start', [0]))[0] if t: embed = f"https://youtube.com/embed/{yt_id}?start={t}" else: embed = f"https://youtube.com/embed/{yt_id}" except: embed = None elif app.config['SERVER_NAME'] in domain and "/post/" in url and "context" not in url: id = url.split("/post/")[1] if "/" in id: id = id.split("/")[0] embed = id else: embed = None else: embed = None if not url and not request.values.get("body") and not request.files.get("file", None): if request.headers.get("Authorization"): return {"error": "`url` or `body` parameter required."}, 400 else: return render_template("submit.html", v=v, error="Please enter a url or some text.", title=title, url=url, body=request.values.get("body", "")), 400 if not title: if request.headers.get("Authorization"): return {"error": "Please enter a better title"}, 400 else: return render_template("submit.html", v=v, error="Please enter a better title.", title=title, url=url, body=request.values.get("body", "")), 400 elif len(title) > 500: if request.headers.get("Authorization"): return {"error": "500 character limit for titles"}, 400 else: render_template("submit.html", v=v, error="500 character limit for titles.", title=title[:500], url=url, body=request.values.get("body", "")), 400 body = request.values.get("body", "").strip() dup = g.db.query(Submission).options(lazyload('*')).filter( Submission.author_id == v.id, Submission.deleted_utc == 0, Submission.title == title, Submission.url == url, Submission.body == body ).first() if dup: return redirect(dup.permalink) now = int(time.time()) cutoff = now - 60 * 60 * 24 similar_posts = g.db.query(Submission).options( lazyload('*') ).filter( Submission.author_id == v.id, Submission.title.op('<->')(title) < app.config["SPAM_SIMILARITY_THRESHOLD"], Submission.created_utc > cutoff ).all() if url: similar_urls = g.db.query(Submission).options( lazyload('*') ).filter( Submission.author_id == v.id, Submission.url.op('<->')(url) < app.config["SPAM_URL_SIMILARITY_THRESHOLD"], Submission.created_utc > cutoff ).all() else: similar_urls = [] threshold = app.config["SPAM_SIMILAR_COUNT_THRESHOLD"] if v.age >= (60 * 60 * 24 * 7): threshold *= 3 elif v.age >= (60 * 60 * 24): threshold *= 2 if max(len(similar_urls), len(similar_posts)) >= threshold: text = "Your account has been suspended for 1 day for the following reason:\n\n> Too much spam!" send_notification(NOTIFICATIONS_ACCOUNT, v, text) v.ban(reason="Spamming.", days=1) for alt in v.alts: if not alt.is_suspended: alt.ban(reason="Spamming.", days=1) for post in similar_posts + similar_urls: post.is_banned = True post.is_pinned = False post.ban_reason = "Automatic spam removal. This happened because the post's creator submitted too much similar content too quickly." g.db.add(post) ma=ModAction( user_id=AUTOJANNY_ACCOUNT, target_submission_id=post.id, kind="ban_post", note="spam" ) g.db.add(ma) return redirect("/notifications") if len(str(body)) > 10000: if request.headers.get("Authorization"): return {"error":"10000 character limit for text body."}, 400 else: return render_template("submit.html", v=v, error="10000 character limit for text body.", title=title, url=url, body=request.values.get("body", "")), 400 if len(url) > 2048: if request.headers.get("Authorization"): return {"error":"2048 character limit for URLs."}, 400 else: return render_template("submit.html", v=v, error="2048 character limit for URLs.", title=title, url=url,body=request.values.get("body", "")), 400 for i in re.finditer('^(https:\/\/.*\.(png|jpg|jpeg|gif|webp|PNG|JPG|JPEG|GIF|WEBP|9999))', body, re.MULTILINE): if "wikipedia" not in i.group(1): body = body.replace(i.group(1), f'![]({i.group(1)})') body = re.sub('([^\n])\n([^\n])', r'\1\n\n\2', body) options = [] for i in re.finditer('\s*\$\$([^\$\n]+)\$\$\s*', body): options.append(i.group(1)) body = body.replace(i.group(0), "") body_md = CustomRenderer().render(mistletoe.Document(body)) body_html = sanitize(body_md) if len(body_html) > 20000: abort(400) bans = filter_comment_html(body_html) if bans: ban = bans[0] reason = f"Remove the {ban.domain} link from your post and try again." if ban.reason: reason += f" {ban.reason}" if request.headers.get("Authorization"): return {"error": reason}, 403 else: return render_template("submit.html", v=v, error=reason, title=title, url=url, body=request.values.get("body", "")), 403 if v.paid_dues: club = bool(request.values.get("club","")) else: club = False new_post = Submission( private=bool(request.values.get("private","")), club=club, author_id=v.id, over_18=bool(request.values.get("over_18","")), app_id=v.client.application.id if v.client else None, is_bot = request.headers.get("X-User-Type","").lower()=="bot", url=url, body=body, body_html=body_html, embed_url=embed, title=title, title_html=filter_title(title) ) g.db.add(new_post) g.db.flush() for option in options: c = Comment(author_id=AUTOPOLLER_ACCOUNT, parent_submission=new_post.id, level=1, body_html=filter_title(option), ) g.db.add(c) vote = Vote(user_id=v.id, vote_type=1, submission_id=new_post.id ) g.db.add(vote) g.db.flush() if request.files.get('file') and request.headers.get("cf-ipcountry") != "T1": file = request.files['file'] if not file.content_type.startswith(('image/', 'video/')): if request.headers.get("Authorization"): return {"error": f"File type not allowed"}, 400 else: return render_template("submit.html", v=v, error=f"File type not allowed.", title=title, body=request.values.get("body", "")), 400 if file.content_type.startswith('video/') and v.coins < app.config["VIDEO_COIN_REQUIREMENT"] and v.admin_level < 1: if request.headers.get("Authorization"): return { "error": f"You need at least {app.config['VIDEO_COIN_REQUIREMENT']} coins to upload videos" }, 403 else: return render_template( "submit.html", v=v, error=f"You need at least {app.config['VIDEO_COIN_REQUIREMENT']} coins to upload videos.", title=title, body=request.values.get("body", "") ), 403 if file.content_type.startswith('image/'): name = f'/images/{int(time.time())}{secrets.token_urlsafe(2)}.gif' file.save(name) new_post.url = request.host_url[:-1] + process_image(name) elif file.content_type.startswith('video/'): file.save("video.mp4") with open("video.mp4", 'rb') as f: new_post.url = requests.post('https://catbox.moe/user/api.php', data={'userhash':CATBOX_KEY, 'reqtype':'fileupload'}, files={'fileToUpload':f}).text g.db.add(new_post) g.db.flush() if (new_post.url or request.files.get('file')) and (v.is_activated or request.headers.get('cf-ipcountry')!="T1"): gevent.spawn( thumbnail_thread, new_post.id) notify_users = set() soup = BeautifulSoup(body_html, features="html.parser") for mention in soup.find_all("a", href=re.compile("^/@(\w+)")): username = mention["href"].split("@")[1] user = g.db.query(User).options(lazyload('*')).filter_by(username=username).first() if user and not v.any_block_exists(user) and user.id != v.id: notify_users.add(user) for x in notify_users: send_notification(NOTIFICATIONS_ACCOUNT, x, f"@{v.username} has mentioned you: http://{site}{new_post.permalink}") if not new_post.private: for follow in v.followers: user = get_account(follow.user_id) send_notification(AUTOJANNY_ACCOUNT, user, f"@{v.username} has made a new post: [{title}](http://{site}{new_post.permalink})") g.db.add(new_post) g.db.flush() if "rama" in request.host and "ivermectin" in new_post.body_html.lower(): new_post.is_banned = True new_post.ban_reason = "ToS Violation" g.db.add(new_post) body = VAXX_MSG.format(username=v.username) body_md = CustomRenderer().render(mistletoe.Document(body)) body_jannied_html = sanitize(body_md) c_jannied = Comment(author_id=AUTOJANNY_ACCOUNT, parent_submission=new_post.id, level=1, over_18=False, is_bot=True, app_id=None, is_pinned=True, distinguish_level=6, body_html=body_jannied_html, body=body, ) g.db.add(c_jannied) g.db.flush() n = Notification(comment_id=c_jannied.id, user_id=v.id) g.db.add(n) if v.agendaposter and "trans lives matter" not in new_post.body_html.lower(): new_post.is_banned = True new_post.ban_reason = "ToS Violation" g.db.add(new_post) body = AGENDAPOSTER_MSG.format(username=v.username) body_md = CustomRenderer().render(mistletoe.Document(body)) body_jannied_html = sanitize(body_md) c_jannied = Comment(author_id=AUTOJANNY_ACCOUNT, parent_submission=new_post.id, level=1, over_18=False, is_bot=True, app_id=None, is_pinned=True, distinguish_level=6, body_html=body_jannied_html, body=body, ) g.db.add(c_jannied) g.db.flush() n = Notification(comment_id=c_jannied.id, user_id=v.id) g.db.add(n) if "rama" in request.host or new_post.url: new_post.comment_count = 1 g.db.add(new_post) if "rama" in request.host: if v.id == 995: if random.random() < 0.02: body = "i love you carp" else: body = "![](https://rdrama.net/assets/images/emojis/fuckoffcarp.webp)" elif v.id == 3833: if random.random() < 0.5: body = "wow, this lawlzpost sucks!" else: body = "wow, a good lawlzpost for once!" else: body = random.choice(snappyquotes) body += "\n\n---\n\n" else: body = "" if new_post.url: body += f"Snapshots:\n\n* [reveddit.com](https://reveddit.com/{new_post.url})\n* [archive.org](https://web.archive.org/{new_post.url})\n* [archive.ph](https://archive.ph/?url={quote(new_post.url)}&run=1) (click to archive)" gevent.spawn(archiveorg, new_post.url) body_md = CustomRenderer().render(mistletoe.Document(body)) body_html = sanitize(body_md) c = Comment(author_id=SNAPPY_ACCOUNT, distinguish_level=6, parent_submission=new_post.id, level=1, over_18=False, is_bot=True, app_id=None, body_html=body_html, body=body, ) g.db.add(c) g.db.flush() n = Notification(comment_id=c.id, user_id=v.id) g.db.add(n) g.db.flush() v.post_count = v.submissions.filter_by(is_banned=False, deleted_utc=0).count() g.db.add(v) cache.delete_memoized(frontlist) cache.delete_memoized(User.userpagelisting) if "[changelog]" in new_post.title or "(changelog)" in new_post.title: send_message(f"http://{site}{new_post.permalink}") cache.delete_memoized(changeloglist) g.db.commit() if request.headers.get("Authorization"): return new_post.json else: return redirect(new_post.permalink) @app.post("/delete_post/") @limiter.limit("1/second") @auth_required @validate_formkey def delete_post_pid(pid, v): post = get_post(pid) if not post.author_id == v.id: abort(403) post.deleted_utc = int(time.time()) post.is_pinned = False post.stickied = None g.db.add(post) cache.delete_memoized(frontlist) g.db.commit() return {"message": "Post deleted!"} @app.post("/undelete_post/") @limiter.limit("1/second") @auth_required @validate_formkey def undelete_post_pid(pid, v): post = get_post(pid) if not post.author_id == v.id: abort(403) post.deleted_utc =0 g.db.add(post) cache.delete_memoized(frontlist) g.db.commit() return {"message": "Post undeleted!"} @app.post("/toggle_comment_nsfw/") @auth_required @validate_formkey def toggle_comment_nsfw(cid, v): comment = g.db.query(Comment).options(lazyload('*')).filter_by(id=cid).first() if not comment.author_id == v.id and not v.admin_level >= 3: abort(403) comment.over_18 = not comment.over_18 g.db.add(comment) g.db.flush() g.db.commit() if comment.over_18: return {"message": "Comment has been marked as +18!"} else: return {"message": "Comment has been unmarked as +18!"} @app.post("/toggle_post_nsfw/") @auth_required @validate_formkey def toggle_post_nsfw(pid, v): post = get_post(pid) if not post.author_id == v.id and not v.admin_level >= 3: abort(403) post.over_18 = not post.over_18 g.db.add(post) if post.author_id!=v.id: ma=ModAction( kind="set_nsfw" if post.over_18 else "unset_nsfw", user_id=v.id, target_submission_id=post.id, ) g.db.add(ma) g.db.commit() if post.over_18: return {"message": "Post has been marked as +18!"} else: return {"message": "Post has been unmarked as +18!"} @app.post("/save_post/") @limiter.limit("1/second") @auth_required @validate_formkey def save_post(pid, v): post=get_post(pid) save = g.db.query(SaveRelationship).options(lazyload('*')).filter_by(user_id=v.id, submission_id=post.id, type=1).first() if not save: new_save=SaveRelationship(user_id=v.id, submission_id=post.id, type=1) g.db.add(new_save) g.db.commit() return {"message": "Post saved!"} @app.post("/unsave_post/") @limiter.limit("1/second") @auth_required @validate_formkey def unsave_post(pid, v): post=get_post(pid) save = g.db.query(SaveRelationship).options(lazyload('*')).filter_by(user_id=v.id, submission_id=post.id, type=1).first() if save: g.db.delete(save) g.db.commit() return {"message": "Post unsaved!"} @app.post("/pin/") @auth_required def api_pin_post(post_id, v): post = g.db.query(Submission).options(lazyload('*')).filter_by(id=post_id).first() if post: post.is_pinned = not post.is_pinned g.db.add(post) g.db.commit() if post.is_pinned: return {"message": "Post pinned!"} else: return {"message": "Post unpinned!"}