Overhaul Scope System

Adds discord role support to the pre-existing scopes system to power
more complex access permissions.

Signed-off-by: Hassan Abouelela <[email protected]>

1 files changed, 38 insertions, 7 deletions

diff --git a/backend/authentication/user.py b/backend/authentication/user.py
index 857c2ed..0ec0188 100644
--- a/backend/authentication/user.py
+++ b/backend/authentication/user.py
@@ -1,20 +1,27 @@
+import typing
 import typing as t
 
 import jwt
+from pymongo.database import Database
 from starlette.authentication import BaseUser
-from starlette.requests import Request
 
+from backend import discord, models
 from backend.constants import SECRET_KEY
-from backend.discord import fetch_user_details
 
 
 class User(BaseUser):
     """Starlette BaseUser implementation for JWT authentication."""
 
-    def __init__(self, token: str, payload: dict[str, t.Any]) -> None:
+    def __init__(
+        self,
+        token: str,
+        payload: dict[str, t.Any],
+        member: typing.Optional[models.DiscordMember],
+    ) -> None:
         self.token = token
         self.payload = payload
         self.admin = False
+        self.member = member
 
     @property
     def is_authenticated(self) -> bool:
@@ -34,16 +41,40 @@ class User(BaseUser):
     def decoded_token(self) -> dict[str, any]:
         return jwt.decode(self.token, SECRET_KEY, algorithms=["HS256"])
 
-    async def fetch_admin_status(self, request: Request) -> bool:
-        self.admin = await request.state.db.admins.find_one(
+    async def get_user_roles(self, database: Database) -> list[str]:
+        """Get a list of the user's discord roles."""
+        if not self.member:
+            return []
+
+        server_roles = await discord.get_roles(database)
+        roles = []
+
+        for role in server_roles:
+            if role.id in self.member.roles:
+                roles.append(role.name)
+
+        if "admin" in roles:
+            # Protect against collision with the forms admin role
+            roles.remove("admin")
+            roles.append("discord admin")
+
+        return roles
+
+    async def fetch_admin_status(self, database: Database) -> bool:
+        self.admin = await database.admins.find_one(
             {"_id": self.payload["id"]}
         ) is not None
 
         return self.admin
 
-    async def refresh_data(self) -> None:
+    async def refresh_data(self, database: Database) -> None:
         """Fetches user data from discord, and updates the instance."""
-        self.payload = await fetch_user_details(self.decoded_token.get("token"))
+        self.member = await discord.get_member(database, self.payload["id"])
+
+        if self.member:
+            self.payload = self.member.user.dict()
+        else:
+            self.payload = await discord.fetch_user_details(self.decoded_token.get("token"))
 
         updated_info = self.decoded_token
         updated_info["user_details"] = self.payload