REFACTOR: Cleaned up routes
This commit is contained in:
@@ -388,18 +388,22 @@ def end_stream():
|
|||||||
FROM users
|
FROM users
|
||||||
WHERE stream_key = ?""", (stream_key,))
|
WHERE stream_key = ?""", (stream_key,))
|
||||||
|
|
||||||
|
# Return unauthorized if no user found
|
||||||
if not user_info:
|
if not user_info:
|
||||||
print("Unauthorized - No user found from stream key", flush=True)
|
print("Unauthorized - No user found from stream key", flush=True)
|
||||||
return "Unauthorized", 403
|
return "Unauthorized", 403
|
||||||
|
|
||||||
|
# Get user info
|
||||||
user_id = user_info["user_id"]
|
user_id = user_info["user_id"]
|
||||||
username = user_info["username"]
|
username = user_info["username"]
|
||||||
|
|
||||||
|
# End stream
|
||||||
result, message = end_user_stream(stream_key, user_id, username)
|
result, message = end_user_stream(stream_key, user_id, username)
|
||||||
|
|
||||||
if result:
|
# Return error if stream could not be ended
|
||||||
print(f"Stream ended: {message}", flush=True)
|
if not result:
|
||||||
return "Stream ended", 200
|
|
||||||
else:
|
|
||||||
print(f"Error ending stream: {message}", flush=True)
|
print(f"Error ending stream: {message}", flush=True)
|
||||||
return "Error ending stream", 500
|
return "Error ending stream", 500
|
||||||
|
|
||||||
|
print(f"Stream ended: {message}", flush=True)
|
||||||
|
return "Stream ended", 200
|
||||||
|
|||||||
Reference in New Issue
Block a user