skorotkiewicz/rDrama
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fd

Browse source
This commit is contained in:
fireworks88 2021-09-07 00:13:52 +02:00
parent 23bf42ffae
commit 59dbe78c78
1 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

5
files/routes/posts.py
View file

@ -534,10 +534,13 @@ IMGUR_KEY = environ.get("IMGUR_KEY", "").strip()
def check_processing_thread(v, post, link, db): def check_processing_thread(v, post, link, db):
print("thread")
image_id = link.split('/')[-1].rstrip('.mp4') image_id = link.split('/')[-1].rstrip('.mp4')
headers = {"Authorization": f"Client-ID {IMGUR_KEY}"} headers = {"Authorization": f"Client-ID {IMGUR_KEY}"}
while True: while True:
print("sex")
# break on error to prevent zombie threads # break on error to prevent zombie threads
try: try:
time.sleep(15) time.sleep(15)
@ -896,6 +899,7 @@ def submit_post(v):
post_url = upload_video(file) post_url = upload_video(file)
new_post.url = post_url new_post.url = post_url
new_post.processing = True new_post.processing = True
print("starting new thread")
gevent.spawn(check_processing_thread, v.id, new_post, post_url, g.db) gevent.spawn(check_processing_thread, v.id, new_post, post_url, g.db)
except UploadException as e: except UploadException as e:
if request.headers.get("Authorization"): if request.headers.get("Authorization"):
@ -918,6 +922,7 @@ def submit_post(v):
post_url = upload_video(file) post_url = upload_video(file)
new_post.url = post_url new_post.url = post_url
new_post.processing = True new_post.processing = True
print("starting new thread")
gevent.spawn(check_processing_thread, v.id, new_post, post_url, g.db) gevent.spawn(check_processing_thread, v.id, new_post, post_url, g.db)
except UploadException as e: except UploadException as e:
if request.headers.get("Authorization"): if request.headers.get("Authorization"):