feat: GET /moodle/files endpoint, MinioRepository

src/modules/moodle/routes.py

@@ -3,11 +3,13 @@
 from fastapi.responses import Response, StreamingResponse
 from minio.deleteobjects import DeleteObject
 from pymongo import UpdateOne
+from typing import List, Dict
 
 from src.api.dependencies import VerifiedDep
 from src.modules.moodle.schemas import InCourses, InSections, InContents
 from src.modules.moodle.utils import content_to_minio_object, module_to_minio_prefix, checker
 from src.storages.minio import minio_client
+from src.repositories.minio.repository import minio_repository
 from src.storages.mongo import MoodleCourse, MoodleEntry
 from src.storages.mongo.moodle import MoodleEntrySchema, MoodleContentSchema
 
@@ -34,6 +36,16 @@ async def preview_moodle(course_id: int, module_id: int, filename: str):
     )
 
 
+@router.get(
+    "/files",
+    response_model=List[Dict[str, any]],
+    responses={200: {"description": "Success"}},
+)
+async def get_moodle_files(_: VerifiedDep) -> List[Dict[str, any]]:
+    moodle_objects = minio_repository.get_moodle_objects()
+    return moodle_objects
+
+
 @router.post(
     "/batch-courses",
     responses={200: {"description": "Success"}},

src/repositories/minio/repository.py

@@ -0,0 +1,37 @@
+from typing import List, Dict
+from minio import Minio
+from minio.error import S3Error
+from src.api.logging_ import logger
+from src.storages.minio import minio_client as client
+
+
+class MinioRepository:
+    def __init__(self, minio_client: Minio):
+        self.minio_client = minio_client
+
+    def get_moodle_objects(self) -> List[Dict[str, any]]:
+        try:
+            # List all objects with the "moodle/" prefix
+            objects = self.minio_client.list_objects(bucket_name="search", prefix="moodle/")
+            moodle_objects = []
+            for obj in objects:
+                # would it work like this?
+                parts = obj.object_name.split("/")
+                if len(parts) >= 3:
+                    course_id = int(parts[1])
+                    module_id = int(parts[2])
+                    filename = parts[-1]
+                    moodle_object = {
+                        "course_id": course_id,
+                        "module_id": module_id,
+                        "filename": filename,
+                        "minio_data": obj,
+                    }
+                    moodle_objects.append(moodle_object)
+            return moodle_objects
+        except S3Error as e:
+            logger.error(f"An error occurred while listing Moodle objects: {e}")
+            return []
+
+
+minio_repository: MinioRepository = MinioRepository(client)