Description
diff --git a/src/routers/trail.py b/src/routers/trail.py
index aac85c77..f2eb38b5 100644
--- a/src/routers/trail.py
+++ b/src/routers/trail.py
@@ -1,6 +1,6 @@
from fastapi import APIRouter, Depends, Request
from src.security.auth import get_current_user
-from src.services.trail import Trail, add_activity_to_trail, add_course_to_trail, create_trail, get_user_trail_with_orgslug, get_user_trail, remove_course_from_trail
+from src.services.trail.trail import Trail, add_activity_to_trail, add_course_to_trail, create_trail, get_user_trail_with_orgslug, get_user_trail, remove_course_from_trail
router = APIRouter()
diff --git a/src/services/trail/__init__.py b/src/services/trail/__init__.py
new file mode 100644
index 00000000..e69de29b
diff --git a/src/services/trail.py b/src/services/trail/trail.py
similarity index 93%
rename from src/services/trail.py
rename to src/services/trail/trail.py
index 30e86143..08e38700 100644
--- a/src/services/trail.py
+++ b/src/services/trail/trail.py
@@ -172,6 +172,12 @@ async def add_activity_to_trail(
{"user_id": user.user_id, "courses.course_id": courseid, "org_id": org_id}
)
+ if user.user_id == "anonymous":
+ raise HTTPException(
+ status_code=status.HTTP_401_UNAUTHORIZED,
+ detail="Anonymous users cannot add activity to trail",
+ )
+
if not trail:
return Trail(masked=False, courses=[])
@@ -201,7 +207,13 @@ async def add_course_to_trail(
) -> Trail:
trails = request.app.db["trails"]
orgs = request.app.db["organizations"]
-
+
+ if user.user_id == "anonymous":
+ raise HTTPException(
+ status_code=status.HTTP_401_UNAUTHORIZED,
+ detail="Anonymous users cannot add activity to trail",
+ )
+
org = await orgs.find_one({"slug": orgslug})
org = PublicOrganization(**org)
@@ -247,6 +259,12 @@ async def remove_course_from_trail(
trails = request.app.db["trails"]
orgs = request.app.db["organizations"]
+ if user.user_id == "anonymous":
+ raise HTTPException(
+ status_code=status.HTTP_401_UNAUTHORIZED,
+ detail="Anonymous users cannot add activity to trail",
+ )
+
org = await orgs.find_one({"slug": orgslug})
org = PublicOrganization(**org)