Implmeent RAM Cache (partially)

Author: rf20008

helpful_modules/problems_module/AbstractKVCache.py

@@ -127,7 +127,6 @@ async def del_all_by_user_id(self, user_id: int) -> None:
                 continue
             if belongs:
                 await self.remove_thing(key)
-    @abstractmethod
     async def delete_all_by_guild_id(self, guild_id: int) -> None:
         all_items = await self.items()
         for key, value in all_items:
@@ -137,10 +136,8 @@ async def delete_all_by_guild_id(self, guild_id: int) -> None:
                 continue
             if belongs:
                 await self.remove_thing(key)
-    @abstractmethod
     async def get_all_items_starting_with(self, thing_start: str) -> list[tuple[str, IdentifiableDictConvertible]]:
         return list(filter(lambda tu: tu[0].startswith(thing_start), await self.items()))
-    @abstractmethod
     async def get_appeal_view_infos(self) -> list[AppealViewInfo]:
         """
         Retrieve all appeal view information stored in Redis.

helpful_modules/problems_module/__init__.py

@@ -26,6 +26,7 @@
 # Author: Samuel Guo (64931063+rf20008@users.noreply.github.com)
 
 from . import *
+from .errors import *
 from .appeal import Appeal, AppealViewInfo, AppealType
 from .appeal_question import AppealQuestion, APPEAL_QUESTION_TYPE_NAMES
 from .base_problem import BaseProblem
@@ -34,7 +35,7 @@
 from .computational_problem import ComputationalProblem
 from .denylistable import Denylistable, DenylistType, DenylistMetadata
 from .dict_convertible import DictConvertible
-from .errors import *
+
 from .GuildData import CheckForUserPassage, GuildData
 from .linear_algebra_problem import LinearAlgebraProblem
 from .parse_problem import convert_dict_to_problem, convert_row_to_problem

helpful_modules/problems_module/cache_ABC.py

@@ -34,7 +34,10 @@
 from .errors import (
     FormatException,
     SQLNotSupportedInRedisException,
-    ThingNotFound
+    ThingNotFound,
+ProblemNotFound,
+QuizNotFound,
+AppealViewInfoNotFound
 )
 from .GuildData import GuildData
 from .quizzes import Quiz

helpful_modules/problems_module/cache_rewrite_with_redis/NewRedisCache.py

@@ -21,26 +21,19 @@
 
 Author: Samuel Guo (64931063+rf20008@users.noreply.github.com)
 """
-from abc import ABC, abstractmethod
+from abc import ABC
 import typing
-from typing import List
-import warnings
 import orjson
 import asyncio
-from ...FileDictionaryReader import AsyncFileDict
-from ..appeal import Appeal, AppealViewInfo
-from ..base_problem import BaseProblem
-from ..dict_convertible import DictConvertible, IdentifiableDictConvertible
+from helpful_modules.FileDictionaryReader import AsyncFileDict
+from helpful_modules.problems_module.dict_convertible import DictConvertible, IdentifiableDictConvertible
 from redis import asyncio as aioredis  # type: ignore
-from ..errors import (
-    FormatException,
-    SQLNotSupportedInRedisException, ThingNotFound,
-    CorruptedDataException, OwnershipNotDeterminableException
+from helpful_modules.problems_module.errors import (
+    SQLNotSupportedInRedisException,
+    ThingNotFound,
+    CorruptedDataException,
+    OwnershipNotDeterminableException
 )
-from ..GuildData import GuildData
-from ..quizzes import Quiz
-from ..user_data import UserData
-from ..verification_code_info import VerificationCodeInfo
 from ..AbstractKVCache import AbstractKVBasedCache, PREFIX_REGISTRY
 from ..cache_ABC import TYPE_ERROR_NOT_FOUND
 MUST_IMPLEMENT_ERROR = NotImplementedError("Subclasses must implement this")
@@ -87,7 +80,6 @@ def __init__(self, redis_url: str, password: str) -> None:
         self.lock = asyncio.Lock()
 
 
-    @abstractmethod
     async def get_all_things(self) -> list[IdentifiableDictConvertible]:
         """Return a list of EVERYTHING in the database"""
         return [value for key, value in await self.items()]
@@ -372,4 +364,4 @@ async def initialize_sql_table(self):
             "SQL is not supported in Redis, and creating sql tables is not supported in Redis either"
         )
 if __name__ == "__main__":
-    r = RedisCache2()
+g    r = RedisCache2()