UPDATE: Adjusted underlying file system to use user-centric instead of type-centric formatting
This commit is contained in:
@@ -7,9 +7,12 @@ from utils.email import send_email
|
|||||||
from utils.user_utils import get_user_id
|
from utils.user_utils import get_user_id
|
||||||
from utils.utils import sanitize
|
from utils.utils import sanitize
|
||||||
from secrets import token_hex
|
from secrets import token_hex
|
||||||
|
from utils.path_manager import PathManager
|
||||||
|
|
||||||
auth_bp = Blueprint("auth", __name__)
|
auth_bp = Blueprint("auth", __name__)
|
||||||
|
|
||||||
|
path_manager = PathManager()
|
||||||
|
|
||||||
@auth_bp.route("/signup", methods=["POST"])
|
@auth_bp.route("/signup", methods=["POST"])
|
||||||
@cross_origin(supports_credentials=True)
|
@cross_origin(supports_credentials=True)
|
||||||
def signup():
|
def signup():
|
||||||
@@ -90,6 +93,9 @@ def signup():
|
|||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
# Create user directories for stream data
|
||||||
|
path_manager.create_user(username)
|
||||||
|
|
||||||
# Create session for new user, to avoid them having unnecessary state info
|
# Create session for new user, to avoid them having unnecessary state info
|
||||||
session.clear()
|
session.clear()
|
||||||
session["username"] = username
|
session["username"] = username
|
||||||
|
|||||||
@@ -203,15 +203,17 @@ def init_stream():
|
|||||||
FROM users
|
FROM users
|
||||||
WHERE stream_key = ?""", (stream_key,))
|
WHERE stream_key = ?""", (stream_key,))
|
||||||
|
|
||||||
|
# No user found from stream key
|
||||||
if not user_info:
|
if not user_info:
|
||||||
print("Unauthorized - Invalid stream key", flush=True)
|
print("Unauthorized - Invalid stream key", flush=True)
|
||||||
return "Unauthorized - Invalid stream key", 403
|
return "Unauthorized - Invalid stream key", 403
|
||||||
|
|
||||||
# Create necessary directories
|
|
||||||
username = user_info["username"]
|
username = user_info["username"]
|
||||||
create_user_directories(username)
|
|
||||||
|
|
||||||
return redirect(f"/stream/{username}")
|
# FOR TESTING
|
||||||
|
path_manager.create_user(username)
|
||||||
|
|
||||||
|
return redirect(username + "/" + path_manager.stream_directory_name)
|
||||||
|
|
||||||
|
|
||||||
@stream_bp.route("/publish_stream", methods=["POST"])
|
@stream_bp.route("/publish_stream", methods=["POST"])
|
||||||
|
|||||||
Reference in New Issue
Block a user