2022-05-04 23:09:46 +00:00
from files . helpers . wrappers import *
from files . helpers . get import *
from files . helpers . discord import *
2022-07-08 16:21:13 +00:00
from files . helpers . const import *
2022-05-04 23:09:46 +00:00
from files . __main__ import app , cache , limiter
from files . classes . submission import Submission
2022-06-10 09:47:41 +00:00
from files . helpers . awards import award_timers
2022-05-04 23:09:46 +00:00
@app.get ( " / " )
@app.get ( " /catalog " )
@app.get ( " /h/<sub> " )
@app.get ( " /s/<sub> " )
2022-05-06 04:55:15 +00:00
@app.get ( " /logged_out " )
@app.get ( " /logged_out/catalog " )
@app.get ( " /logged_out/h/<sub> " )
@app.get ( " /logged_out/s/<sub> " )
2022-05-04 23:09:46 +00:00
@limiter.limit ( " 3/second;30/minute;5000/hour;10000/day " )
@auth_desired
def front_all ( v , sub = None , subdomain = None ) :
2022-05-06 04:55:15 +00:00
2022-05-25 23:43:42 +00:00
if not v and not request . path . startswith ( ' /logged_out ' ) :
r = request . full_path
if r == ' /? ' : r = ' / '
return redirect ( f " /logged_out { r } " )
2022-05-09 08:47:35 +00:00
if v and request . path . startswith ( ' /logged_out ' ) : return redirect ( request . full_path . replace ( ' /logged_out ' , ' ' ) )
2022-05-06 04:55:15 +00:00
2022-05-04 23:09:46 +00:00
if sub : sub = g . db . query ( Sub ) . filter_by ( name = sub . strip ( ) . lower ( ) ) . one_or_none ( )
if ( request . path . startswith ( ' /h/ ' ) or request . path . startswith ( ' /s/ ' ) ) and not sub : abort ( 404 )
try : page = max ( int ( request . values . get ( " page " , 1 ) ) , 1 )
except : abort ( 400 )
if v :
defaultsorting = v . defaultsorting
if sub or SITE_NAME != ' rDrama ' : defaulttime = ' all '
else : defaulttime = v . defaulttime
else :
defaultsorting = " hot "
if sub or SITE_NAME != ' rDrama ' : defaulttime = ' all '
2022-07-08 16:21:13 +00:00
else : defaulttime = DEFAULT_TIME_FILTER
2022-05-04 23:09:46 +00:00
sort = request . values . get ( " sort " , defaultsorting )
t = request . values . get ( ' t ' , defaulttime )
ccmode = request . values . get ( ' ccmode ' , " false " ) . lower ( )
if sort == ' bump ' : t = ' all '
try : gt = int ( request . values . get ( " after " , 0 ) )
except : gt = 0
try : lt = int ( request . values . get ( " before " , 0 ) )
except : lt = 0
ids , next_exists = frontlist ( sort = sort ,
page = page ,
t = t ,
v = v ,
ccmode = ccmode ,
filter_words = v . filter_words if v else [ ] ,
gt = gt ,
lt = lt ,
sub = sub ,
site = SITE
)
posts = get_posts ( ids , v = v )
if v :
if v . hidevotedon : posts = [ x for x in posts if not hasattr ( x , ' voted ' ) or not x . voted ]
2022-06-10 09:47:41 +00:00
award_timers ( v )
2022-05-04 23:09:46 +00:00
if request . headers . get ( " Authorization " ) : return { " data " : [ x . json for x in posts ] , " next_exists " : next_exists }
return render_template ( " home.html " , v = v , listing = posts , next_exists = next_exists , sort = sort , t = t , page = page , ccmode = ccmode , sub = sub , home = True )
@cache.memoize ( timeout = 86400 )
def frontlist ( v = None , sort = " hot " , page = 1 , t = " all " , ids_only = True , ccmode = " false " , filter_words = ' ' , gt = 0 , lt = 0 , sub = None , site = None ) :
posts = g . db . query ( Submission )
if v and v . hidevotedon :
voted = [ x [ 0 ] for x in g . db . query ( Vote . submission_id ) . filter_by ( user_id = v . id ) . all ( ) ]
posts = posts . filter ( Submission . id . notin_ ( voted ) )
if sub : posts = posts . filter_by ( sub = sub . name )
elif v : posts = posts . filter ( or_ ( Submission . sub == None , Submission . sub . notin_ ( v . all_blocks ) ) )
if gt : posts = posts . filter ( Submission . created_utc > gt )
if lt : posts = posts . filter ( Submission . created_utc < lt )
if not gt and not lt :
if t == ' all ' : cutoff = 0
else :
now = int ( time . time ( ) )
if t == ' hour ' : cutoff = now - 3600
elif t == ' week ' : cutoff = now - 604800
elif t == ' month ' : cutoff = now - 2592000
elif t == ' year ' : cutoff = now - 31536000
else : cutoff = now - 86400
posts = posts . filter ( Submission . created_utc > = cutoff )
if ( ccmode == " true " ) :
posts = posts . filter ( Submission . club == True )
posts = posts . filter_by ( is_banned = False , private = False , deleted_utc = 0 )
if ( sort == " hot " or ( v and v . id == Q_ID ) ) and ccmode == " false " and not gt and not lt :
2022-07-01 23:11:48 +00:00
posts = posts . filter_by ( stickied = None , hole_pinned = None )
2022-05-04 23:09:46 +00:00
2022-05-24 20:43:49 +00:00
if v :
2022-05-04 23:09:46 +00:00
posts = posts . filter ( Submission . author_id . notin_ ( v . userblocks ) )
if not ( v and v . changelogsub ) :
posts = posts . filter ( not_ ( Submission . title . ilike ( ' [changelog] % ' ) ) )
if v and filter_words :
for word in filter_words :
word = word . replace ( ' \\ ' , ' ' ) . replace ( ' _ ' , ' \ _ ' ) . replace ( ' % ' , ' \ % ' ) . strip ( )
posts = posts . filter ( not_ ( Submission . title . ilike ( f ' % { word } % ' ) ) )
if not ( v and v . shadowbanned ) :
2022-07-03 06:12:53 +00:00
posts = posts . join ( Submission . author ) . filter ( User . shadowbanned == None )
2022-05-04 23:09:46 +00:00
if request . host == ' rdrama.net ' : num = 5
2022-05-07 04:13:19 +00:00
else : num = 0.5
2022-05-04 23:09:46 +00:00
2022-07-03 02:40:57 +00:00
if sort in ( " hot " , " warm " ) :
2022-05-04 23:09:46 +00:00
ti = int ( time . time ( ) ) + 3600
2022-06-30 15:24:05 +00:00
posts = posts . order_by ( - 1000000 * ( Submission . realupvotes + 1 + Submission . comment_count / num ) / ( func . power ( ( ( ti - Submission . created_utc ) / 1000 ) , 1.23 ) ) , Submission . created_utc . desc ( ) )
2022-05-04 23:09:46 +00:00
elif sort == " bump " :
posts = posts . filter ( Submission . comment_count > 1 ) . order_by ( Submission . bump_utc . desc ( ) , Submission . created_utc . desc ( ) )
2022-06-22 19:57:57 +00:00
else :
posts = sort_posts ( sort , posts )
2022-05-04 23:09:46 +00:00
if v : size = v . frontsize or 0
else : size = 25
posts = posts . offset ( size * ( page - 1 ) ) . limit ( size + 1 ) . all ( )
next_exists = ( len ( posts ) > size )
posts = posts [ : size ]
if ( sort == " hot " or ( v and v . id == Q_ID ) ) and page == 1 and ccmode == " false " and not gt and not lt :
2022-07-01 23:11:48 +00:00
if sub :
pins = g . db . query ( Submission ) . filter ( Submission . sub == sub . name , Submission . hole_pinned != None )
2022-07-01 23:18:41 +00:00
else :
2022-07-01 23:11:48 +00:00
pins = g . db . query ( Submission ) . filter ( Submission . stickied != None , Submission . is_banned == False )
2022-07-01 23:18:41 +00:00
if v :
pins = pins . filter ( or_ ( Submission . sub == None , Submission . sub . notin_ ( v . all_blocks ) ) )
for pin in pins :
if pin . stickied_utc and int ( time . time ( ) ) > pin . stickied_utc :
pin . stickied = None
pin . stickied_utc = None
g . db . add ( pin )
if v : pins = pins . filter ( Submission . author_id . notin_ ( v . userblocks ) )
2022-05-04 23:09:46 +00:00
2022-07-01 23:11:48 +00:00
pins = pins . order_by ( Submission . created_utc . desc ( ) ) . all ( )
2022-05-04 23:09:46 +00:00
posts = pins + posts
if ids_only : posts = [ x . id for x in posts ]
return posts , next_exists
@app.get ( " /changelog " )
@auth_required
def changelog ( v ) :
try : page = max ( int ( request . values . get ( " page " , 1 ) ) , 1 )
except : page = 1
sort = request . values . get ( " sort " , " new " )
t = request . values . get ( ' t ' , " all " )
ids = changeloglist ( sort = sort ,
page = page ,
t = t ,
v = v ,
site = SITE
)
next_exists = ( len ( ids ) > 25 )
ids = ids [ : 25 ]
posts = get_posts ( ids , v = v )
if request . headers . get ( " Authorization " ) : return { " data " : [ x . json for x in posts ] , " next_exists " : next_exists }
return render_template ( " changelog.html " , v = v , listing = posts , next_exists = next_exists , sort = sort , t = t , page = page )
@cache.memoize ( timeout = 86400 )
def changeloglist ( v = None , sort = " new " , page = 1 , t = " all " , site = None ) :
2022-05-24 20:43:49 +00:00
posts = g . db . query ( Submission . id ) . filter_by ( is_banned = False , private = False , deleted_utc = 0 )
2022-05-04 23:09:46 +00:00
2022-06-13 21:41:29 +00:00
allowed = g . db . query ( User . id ) . filter ( User . admin_level > 0 ) . all ( ) + g . db . query ( Badge . user_id ) . filter_by ( badge_id = 3 ) . all ( )
allowed = [ x [ 0 ] for x in allowed ]
posts = posts . filter ( Submission . title . ilike ( ' _changelog % ' ) , Submission . author_id . in_ ( allowed ) )
2022-05-04 23:09:46 +00:00
if t != ' all ' :
cutoff = 0
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
posts = posts . filter ( Submission . created_utc > = cutoff )
2022-06-22 19:57:57 +00:00
posts = sort_posts ( sort , posts )
2022-05-04 23:09:46 +00:00
posts = posts . offset ( 25 * ( page - 1 ) ) . limit ( 26 ) . all ( )
return [ x [ 0 ] for x in posts ]
@app.get ( " /random_post " )
@auth_required
def random_post ( v ) :
p = g . db . query ( Submission . id ) . filter ( Submission . deleted_utc == 0 , Submission . is_banned == False , Submission . private == False ) . order_by ( func . random ( ) ) . first ( )
if p : p = p [ 0 ]
else : abort ( 404 )
return redirect ( f " /post/ { p } " )
@app.get ( " /random_user " )
@auth_required
def random_user ( v ) :
u = g . db . query ( User . username ) . filter ( User . song != None ) . order_by ( func . random ( ) ) . first ( )
if u : u = u [ 0 ]
else : abort ( 404 )
return redirect ( f " /@ { u } " )
@app.get ( " /comments " )
@auth_required
def all_comments ( v ) :
try : page = max ( int ( request . values . get ( " page " , 1 ) ) , 1 )
except : page = 1
sort = request . values . get ( " sort " , " new " )
2022-07-08 16:21:13 +00:00
t = request . values . get ( " t " , DEFAULT_TIME_FILTER )
2022-05-04 23:09:46 +00:00
try : gt = int ( request . values . get ( " after " , 0 ) )
except : gt = 0
try : lt = int ( request . values . get ( " before " , 0 ) )
except : lt = 0
idlist = comment_idlist ( v = v ,
page = page ,
sort = sort ,
t = t ,
gt = gt ,
lt = lt ,
site = SITE
)
comments = get_comments ( idlist , v = v )
next_exists = len ( idlist ) > 25
idlist = idlist [ : 25 ]
if request . headers . get ( " Authorization " ) : return { " data " : [ x . json for x in comments ] }
return render_template ( " home_comments.html " , v = v , sort = sort , t = t , page = page , comments = comments , standalone = True , next_exists = next_exists )
@cache.memoize ( timeout = 86400 )
def comment_idlist ( page = 1 , v = None , nsfw = False , sort = " new " , t = " all " , gt = 0 , lt = 0 , site = None ) :
2022-07-02 06:48:04 +00:00
comments = g . db . query ( Comment . id ) . filter ( Comment . parent_submission != None , Comment . author_id . notin_ ( v . userblocks ) )
2022-05-04 23:09:46 +00:00
if v . admin_level < 2 :
private = [ x [ 0 ] for x in g . db . query ( Submission . id ) . filter ( Submission . private == True ) . all ( ) ]
2022-05-24 20:43:49 +00:00
comments = comments . filter ( Comment . is_banned == False , Comment . deleted_utc == 0 , Comment . parent_submission . notin_ ( private ) )
2022-05-04 23:09:46 +00:00
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 gt : comments = comments . filter ( Comment . created_utc > gt )
if lt : comments = comments . filter ( Comment . created_utc < lt )
if not gt and not lt :
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 )
2022-06-22 19:50:20 +00:00
comments = sort_comments ( sort , comments )
2022-05-04 23:09:46 +00:00
comments = comments . offset ( 25 * ( page - 1 ) ) . limit ( 26 ) . all ( )
return [ x [ 0 ] for x in comments ]
@app.get ( " /transfers " )
@auth_required
def transfers ( v ) :
2022-07-08 19:03:04 +00:00
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 ( ) )
2022-05-04 23:09:46 +00:00
if request . headers . get ( " Authorization " ) : return { " data " : [ x . json for x in comments . all ( ) ] }
try : page = max ( int ( request . values . get ( " page " , 1 ) ) , 1 )
except : page = 1
comments = comments . offset ( 25 * ( page - 1 ) ) . limit ( 26 ) . all ( )
next_exists = len ( comments ) > 25
comments = comments [ : 25 ]
2022-06-11 13:19:39 +00:00
return render_template ( " transfers.html " , v = v , page = page , comments = comments , standalone = True , next_exists = next_exists )