299 lines
8.7 KiB
Python
299 lines
8.7 KiB
Python
from files.helpers.wrappers import *
|
|
import re
|
|
from sqlalchemy import *
|
|
from flask import *
|
|
from files.__main__ import app
|
|
|
|
|
|
valid_params=[
|
|
'author',
|
|
'domain',
|
|
'over18'
|
|
]
|
|
|
|
def searchparse(text):
|
|
|
|
|
|
criteria = {x[0]:x[1] for x in query_regex.findall(text)}
|
|
|
|
for x in criteria:
|
|
if x in valid_params:
|
|
text = text.replace(f"{x}:{criteria[x]}", "")
|
|
|
|
text=text.strip()
|
|
|
|
if text:
|
|
criteria['q']=text
|
|
|
|
return criteria
|
|
|
|
|
|
|
|
|
|
|
|
@app.get("/search/posts")
|
|
@auth_required
|
|
def searchposts(v):
|
|
|
|
query = request.values.get("q", '').strip()
|
|
|
|
page = max(1, int(request.values.get("page", 1)))
|
|
|
|
sort = request.values.get("sort", "new").lower()
|
|
t = request.values.get('t', 'all').lower()
|
|
|
|
criteria=searchparse(query)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
posts = g.db.query(Submission.id)
|
|
|
|
if not v.paid_dues: posts = posts.filter_by(club=False)
|
|
|
|
if v.admin_level < 2:
|
|
posts = posts.filter(Submission.deleted_utc == 0, Submission.is_banned == False, Submission.private == False, Submission.author_id.notin_(v.userblocks))
|
|
|
|
|
|
|
|
if 'author' in criteria:
|
|
posts = posts.filter(Submission.ghost == False)
|
|
author = get_user(criteria['author'])
|
|
if not author: return {"error": "User not found"}
|
|
if author.is_private and author.id != v.id and v.admin_level < 2 and not v.eye:
|
|
if request.headers.get("Authorization"):
|
|
return {"error": f"@{author.username}'s profile is private; You can't use the 'author' syntax on them"}
|
|
return render_template("search.html",
|
|
v=v,
|
|
query=query,
|
|
total=0,
|
|
page=page,
|
|
listing=[],
|
|
sort=sort,
|
|
t=t,
|
|
next_exists=False,
|
|
domain=None,
|
|
domain_obj=None,
|
|
error=f"@{author.username}'s profile is private; You can't use the 'author' syntax on them."
|
|
)
|
|
else: posts = posts.filter(Submission.author_id == author.id)
|
|
|
|
if 'q' in criteria:
|
|
words=criteria['q'].split()
|
|
words = criteria['q'].replace('\\', '').replace('_', '\_').replace('%', '\%').strip().split()
|
|
words=[Submission.title.ilike('%'+x+'%') for x in words]
|
|
posts=posts.filter(*words)
|
|
|
|
if 'over18' in criteria: posts = posts.filter(Submission.over_18==True)
|
|
|
|
if 'domain' in criteria:
|
|
domain=criteria['domain']
|
|
|
|
domain = domain.replace('\\', '').replace('_', '\_').replace('%', '').strip()
|
|
|
|
posts=posts.filter(
|
|
or_(
|
|
Submission.url.ilike("https://"+domain+'/%'),
|
|
Submission.url.ilike("https://"+domain+'/%'),
|
|
Submission.url.ilike("https://"+domain),
|
|
Submission.url.ilike("https://"+domain),
|
|
Submission.url.ilike("https://www."+domain+'/%'),
|
|
Submission.url.ilike("https://www."+domain+'/%'),
|
|
Submission.url.ilike("https://www."+domain),
|
|
Submission.url.ilike("https://www."+domain),
|
|
Submission.url.ilike("https://old." + domain + '/%'),
|
|
Submission.url.ilike("https://old." + domain + '/%'),
|
|
Submission.url.ilike("https://old." + domain),
|
|
Submission.url.ilike("https://old." + domain)
|
|
)
|
|
)
|
|
|
|
|
|
if t:
|
|
now = int(time.time())
|
|
if t == 'hour':
|
|
cutoff = now - 3600
|
|
elif t == 'day':
|
|
cutoff = now - 86400
|
|
elif t == 'week':
|
|
cutoff = now - 604800
|
|
elif t == 'month':
|
|
cutoff = now - 2592000
|
|
elif t == 'year':
|
|
cutoff = now - 31536000
|
|
else:
|
|
cutoff = 0
|
|
posts = posts.filter(Submission.created_utc >= cutoff)
|
|
|
|
if sort == "new":
|
|
posts = posts.order_by(Submission.created_utc.desc())
|
|
elif sort == "old":
|
|
posts = posts.order_by(Submission.created_utc)
|
|
elif sort == "controversial":
|
|
posts = posts.order_by((Submission.upvotes+1)/(Submission.downvotes+1) + (Submission.downvotes+1)/(Submission.upvotes+1), Submission.downvotes.desc())
|
|
elif sort == "top":
|
|
posts = posts.order_by(Submission.downvotes - Submission.upvotes)
|
|
elif sort == "bottom":
|
|
posts = posts.order_by(Submission.upvotes - Submission.downvotes)
|
|
elif sort == "comments":
|
|
posts = posts.order_by(Submission.comment_count.desc())
|
|
|
|
total = posts.count()
|
|
|
|
posts = posts.offset(25 * (page - 1)).limit(26).all()
|
|
|
|
ids = [x[0] for x in posts]
|
|
|
|
|
|
|
|
|
|
next_exists = (len(ids) > 25)
|
|
ids = ids[:25]
|
|
|
|
posts = get_posts(ids, v=v)
|
|
|
|
if v and v.admin_level>3 and "domain" in criteria:
|
|
domain=criteria['domain']
|
|
domain_obj=get_domain(domain)
|
|
else:
|
|
domain=None
|
|
domain_obj=None
|
|
|
|
if request.headers.get("Authorization"): return {"total":total, "data":[x.json for x in posts]}
|
|
|
|
return render_template("search.html",
|
|
v=v,
|
|
query=query,
|
|
total=total,
|
|
page=page,
|
|
listing=posts,
|
|
sort=sort,
|
|
t=t,
|
|
next_exists=next_exists,
|
|
domain=domain,
|
|
domain_obj=domain_obj
|
|
)
|
|
|
|
@app.get("/search/comments")
|
|
@auth_required
|
|
def searchcomments(v):
|
|
|
|
|
|
query = request.values.get("q", '').strip()
|
|
|
|
try: page = max(1, int(request.values.get("page", 1)))
|
|
except: page = 1
|
|
|
|
sort = request.values.get("sort", "new").lower()
|
|
t = request.values.get('t', 'all').lower()
|
|
|
|
criteria = searchparse(query)
|
|
|
|
comments = g.db.query(Comment.id).filter(Comment.parent_submission != None)
|
|
|
|
if 'author' in criteria:
|
|
comments = comments.filter(Comment.ghost == False)
|
|
author = get_user(criteria['author'])
|
|
if not author: return {"error": "User not found"}
|
|
if author.is_private and author.id != v.id and v.admin_level < 2 and not v.eye:
|
|
if request.headers.get("Authorization"):
|
|
return {"error": f"@{author.username}'s profile is private; You can't use the 'author' syntax on them"}
|
|
|
|
return render_template("search_comments.html", v=v, query=query, total=0, page=page, comments=[], sort=sort, t=t, next_exists=False, error=f"@{author.username}'s profile is private; You can't use the 'author' syntax on them.")
|
|
|
|
else: comments = comments.filter(Comment.author_id == author.id)
|
|
|
|
if 'q' in criteria:
|
|
words = criteria['q'].replace('\\', '').replace('_', '\_').replace('%', '\%').strip().split()
|
|
|
|
words = [Comment.body.ilike('%'+x+'%') for x in words]
|
|
comments = comments.filter(*words)
|
|
|
|
if 'over18' in criteria: comments = comments.filter(Comment.over_18 == True)
|
|
|
|
if t:
|
|
now = int(time.time())
|
|
if t == 'hour':
|
|
cutoff = now - 3600
|
|
elif t == 'day':
|
|
cutoff = now - 86400
|
|
elif t == 'week':
|
|
cutoff = now - 604800
|
|
elif t == 'month':
|
|
cutoff = now - 2592000
|
|
elif t == 'year':
|
|
cutoff = now - 31536000
|
|
else:
|
|
cutoff = 0
|
|
comments = comments.filter(Comment.created_utc >= cutoff)
|
|
|
|
|
|
if v.admin_level < 2:
|
|
private = [x[0] for x in g.db.query(Submission.id).filter(Submission.private == True).all()]
|
|
|
|
comments = comments.filter(Comment.author_id.notin_(v.userblocks), Comment.is_banned==False, Comment.deleted_utc == 0, Comment.parent_submission.notin_(private))
|
|
|
|
|
|
if not v.paid_dues:
|
|
club = [x[0] for x in g.db.query(Submission.id).filter(Submission.club == True).all()]
|
|
comments = comments.filter(Comment.parent_submission.notin_(club))
|
|
|
|
|
|
if sort == "new":
|
|
comments = comments.order_by(Comment.created_utc.desc())
|
|
elif sort == "old":
|
|
comments = comments.order_by(Comment.created_utc)
|
|
elif sort == "controversial":
|
|
comments = comments.order_by((Comment.upvotes+1)/(Comment.downvotes+1) + (Comment.downvotes+1)/(Comment.upvotes+1), Comment.downvotes.desc())
|
|
elif sort == "top":
|
|
comments = comments.order_by(Comment.downvotes - Comment.upvotes)
|
|
elif sort == "bottom":
|
|
comments = comments.order_by(Comment.upvotes - Comment.downvotes)
|
|
|
|
total = comments.count()
|
|
|
|
comments = comments.offset(25 * (page - 1)).limit(26).all()
|
|
|
|
ids = [x[0] for x in comments]
|
|
|
|
next_exists = (len(ids) > 25)
|
|
ids = ids[:25]
|
|
|
|
comments = get_comments(ids, v=v)
|
|
|
|
if request.headers.get("Authorization"): return {"total":total, "data":[x.json for x in comments]}
|
|
return render_template("search_comments.html", v=v, query=query, total=total, page=page, comments=comments, sort=sort, t=t, next_exists=next_exists, standalone=True)
|
|
|
|
|
|
@app.get("/search/users")
|
|
@auth_required
|
|
def searchusers(v):
|
|
|
|
query = request.values.get("q", '').strip()
|
|
|
|
page = max(1, int(request.values.get("page", 1)))
|
|
sort = request.values.get("sort", "new").lower()
|
|
t = request.values.get('t', 'all').lower()
|
|
term=query.lstrip('@')
|
|
term = term.replace('\\','').replace('_','\_').replace('%','')
|
|
|
|
users=g.db.query(User).filter(User.username.ilike(f'%{term}%'))
|
|
|
|
users=users.order_by(User.username.ilike(term).desc(), User.stored_subscriber_count.desc())
|
|
|
|
total=users.count()
|
|
|
|
users=[x for x in users.offset(25 * (page-1)).limit(26)]
|
|
next_exists=(len(users)>25)
|
|
users=users[:25]
|
|
|
|
if request.headers.get("Authorization"): return {"data": [x.json for x in users]}
|
|
return render_template("search_users.html", v=v, query=query, total=total, page=page, users=users, sort=sort, t=t, next_exists=next_exists) |