WIP

Author: jeffmaki

api/main.py

@@ -63,17 +63,21 @@ async def catch_all(
     current_user: UserInfo = Depends(validate_token),
     service: WorkspaceService = Depends(get_workspace_service),
 ):
-    validWorkspace = await service.get_workspace(
-        current_user.projectGroups, int(request.headers.get("X-Workspace") or "-1")
-    )
+    authorizedWorkspace = None
 
-    if validWorkspace is None:
-        raise HTTPException(
-            status_code=status.HTTP_401_UNAUTHORIZED,
-            detail="Invalid authentication credentials",
-            headers={"WWW-Authenticate": "Bearer"},
+    if(request.headers.get("X-Workspace") is not None):
+        authorizedWorkspace = await service.get_workspace(
+            current_user.projectGroups, int(request.headers.get("X-Workspace") or "-1")
         )
 
+        # user specified a workspace they wanted access to, but didn't get it
+        if authorizedWorkspace is None:
+            raise HTTPException(
+                status_code=status.HTTP_401_UNAUTHORIZED,
+                detail="Invalid authentication credentials",
+                headers={"WWW-Authenticate": "Bearer"},
+            )
+
     print(
         f"Path proxied: {request.url} workspace_id: {request.headers.get("X-Workspace")}"
     )
@@ -87,9 +91,11 @@ async def catch_all(
     new_headers.append(
         (bytes("Authorization", "utf-8"), request.headers.get("Authorization"))
     )
-    new_headers.append(
-        (bytes("X-Workspace", "utf-8"), bytes(str(validWorkspace.id), "utf-8"))
-    )
+
+    if(authorizedWorkspace is not None):
+        new_headers.append(
+            (bytes("X-Workspace", "utf-8"), bytes(str(authorizedWorkspace.id), "utf-8"))
+        )
     new_headers.append((bytes("Host", "utf-8"), bytes(client.base_url.host, "utf-8")))
 
     rp_req = client.build_request(

api/src/workspaces/routes.py

@@ -1,4 +1,4 @@
-from fastapi import APIRouter, Depends, status
+from fastapi import APIRouter, Depends, HTTPException, status
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from api.core.database import get_session
@@ -7,6 +7,7 @@
 from api.src.workspaces.repository import WorkspaceRepository
 from api.src.workspaces.schemas import (
     WorkspaceCreate,
+    WorkspaceLongQuestBase,
     WorkspaceResponse,
     WorkspaceUpdate,
 )
@@ -98,3 +99,64 @@ async def delete_workspace(
     except Exception as e:
         logger.error(f"Failed to delete workspace {workspace_id}: {str(e)}")
         raise
+
+
+@router.get("/{workspace_id}/quests/long", response_model=WorkspaceResponse)
+async def get_long_quest(
+    workspace_id: int,
+    service: WorkspaceService = Depends(get_workspace_service),
+    current_user: UserInfo = Depends(validate_token),
+) -> WorkspaceLongQuestBase | None:
+    try:
+        workspace = await service.get_workspace(
+            current_user.projectGroups, workspace_id
+        )
+        return workspace.longFormQuestDef
+    except Exception as e:
+        logger.error(f"Failed to fetch workspace {workspace_id}: {str(e)}")
+        raise
+
+
+@router.get("/{workspace_id}/quests/long/settings", response_model=WorkspaceLongQuestBase)
+async def get_long_quest_settings(
+    workspace_id: int,
+    service: WorkspaceService = Depends(get_workspace_service),
+    current_user: UserInfo = Depends(validate_token),
+) -> WorkspaceLongQuestBase | None:
+    try:
+        workspace = await service.get_workspace(
+            current_user.projectGroups, workspace_id
+        )
+
+        if(workspace.longFormQuestDef is None):
+            raise HTTPException(
+                status_code=status.HTTP_204_NO_CONTENT,
+                detail="No Content",
+            )
+
+        return workspace.longFormQuestDef
+    except Exception as e:
+        logger.error(f"Failed to fetch workspace {workspace_id}: {str(e)}")
+        raise
+
+@router.patch("/{workspace_id}/quests/long/settings", response_model=WorkspaceLongQuestBase)
+async def update_long_quest_settings(
+    workspace_id: int,
+    workspace_data: WorkspaceUpdate,
+    service: WorkspaceService = Depends(get_workspace_service),
+    current_user: UserInfo = Depends(validate_token),
+) -> WorkspaceLongQuestBase | None:
+    try:
+        workspace:WorkspaceUpdate = await service.get_workspace(
+            current_user.projectGroups, workspace_id
+        ) # type: ignore
+        
+#        workspace.longFormQuestDef = longform_quest_data
+
+        updatedWorkspace = await service.update_workspace(
+            current_user.projectGroups, workspace_id, workspace
+        )
+        return updatedWorkspace.longFormQuestDef
+    except Exception as e:
+        logger.error(f"Failed to update workspace {workspace_id}: {str(e)}")
+        raise